ListExtractor

case class ListExtractor[A](items: Seq[A], format: DataFormat, inference: InferenceEngine, concurrentItems: Int, itemTimeout: Option[FiniteDuration])(implicit toRdfElement: A => RDFElement) extends StreamExtractor[A]

StreamExtractor capable of extracting RDF items from an in-memory sequence of items

Type parameters:
A

Type of the items contained in the input list

Value parameters:
concurrentItems

Maximum number of items to be extracted and parsed for RDF in parallel (set it to 1 for sequential execution, bear in mind that high values won't necessarily translate into performance improvements unless you know what you are doing)

format

Format of the RDF data arriving from the Stream, the Extractor expects all data items to share format

inference

Inference of the RDF data arriving from the Stream, the Extractor expects all data items to share inference

items

List of elements to be used as input stream

toRdfElement

Helper function for converting the incoming items of type A into RDFElements (implicit conversions provided in RDFElementImplicits)

Source:
ListExtractor.scala
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any

Type members

Types

private type A

Value members

Inherited methods

protected def checkConfiguration(): Unit

Check the user-controlled inputs to this extractor, preventing the creation of it if necessary

Check the user-controlled inputs to this extractor, preventing the creation of it if necessary

Throws:
IllegalArgumentException

On invalid extractor parameters

Inherited from:
StreamExtractor
Source:
StreamExtractor.scala
def productElementNames: Iterator[String]
Inherited from:
Product
def productIterator: Iterator[Any]
Inherited from:
Product

Concrete fields

lazy override private[extractors] val inputStream: Stream[IO, A]

Inherited fields

lazy val dataStream: Stream[IO, RDFValidationItem]

The initial inputStream, transformed through toDataItems to get a stream of RDF Items

The initial inputStream, transformed through toDataItems to get a stream of RDF Items

Inherited from:
StreamExtractor
Source:
StreamExtractor.scala

Implicits

Implicits

implicit private val toRdfElement: A => RDFElement