Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  def +(other: String): String

   Implicit

   This member is added by an implicit conversion from InMemDataQueue[Data] to any2stringadd[InMemDataQueue[Data]] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4.  def ->[B](y: B): (InMemDataQueue[Data], B)

   Implicit

   This member is added by an implicit conversion from InMemDataQueue[Data] to ArrowAssoc[InMemDataQueue[Data]] performed by method ArrowAssoc in scala.Predef.

   Definition Classes

   ArrowAssoc

   Annotations

   @inline()

5.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

6.  def add(data: Data): Unit

   Definition Classes

   DataStore

7.  def all(): Seq[Data]

   This gets everything from the data store.

   This gets everything from the data store.

   returns

   Every document that is stored in the data store.

   Definition Classes

   InMemDataQueue → DataStore

8.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

9.  def checkConfig(conf: PipeConfig): Unit

   Check that paths in configuration file relevant to host class are well-formed.

   Check that paths in configuration file relevant to host class are well-formed. Default does nothing.

   conf

   the config file to check

   Definition Classes

   ConfigChecker

10.  def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

11.  val configOpt: Option[PipeConfig]

    Definition Classes

    ConfigBuilds

12.  def constructBuilder(config: PipeConfig): DataStoreBuilder

    Definition Classes

    ConfigBuildsDataStore → ConfigBuilds

13.  def dequeue(): Option[Data]

    Definition Classes

    InMemDataQueue → DataQueue

14.  def displayName(): String

    Definition Classes

    DataStore

15.  val downstreamConnectors: Seq[Connector[Data]]

    Definition Classes

    Upstream

16.  def enqueue(data: Seq[Data]): Unit

    Definition Classes

    DataQueue

17.  def enqueue(data: Data): Unit

    Definition Classes

    DataQueue

18.  def ensuring(cond: (InMemDataQueue[Data]) ⇒ Boolean, msg: ⇒ Any): InMemDataQueue[Data]

    Implicit

    This member is added by an implicit conversion from InMemDataQueue[Data] to Ensuring[InMemDataQueue[Data]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

19.  def ensuring(cond: (InMemDataQueue[Data]) ⇒ Boolean): InMemDataQueue[Data]

    Implicit

    This member is added by an implicit conversion from InMemDataQueue[Data] to Ensuring[InMemDataQueue[Data]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

20.  def ensuring(cond: Boolean, msg: ⇒ Any): InMemDataQueue[Data]

    Implicit

    This member is added by an implicit conversion from InMemDataQueue[Data] to Ensuring[InMemDataQueue[Data]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

21.  def ensuring(cond: Boolean): InMemDataQueue[Data]

    Implicit

    This member is added by an implicit conversion from InMemDataQueue[Data] to Ensuring[InMemDataQueue[Data]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

22.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

23.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

24.  def extract(): Seq[Data]

    Definition Classes

    InMemDataQueue → DataStore

25.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

26.  def formatted(fmtstr: String): String

    Implicit

    This member is added by an implicit conversion from InMemDataQueue[Data] to StringFormat[InMemDataQueue[Data]] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

27.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

28.  def getConfig(config: PipeConfig): PipeConfig

    Definition Classes

    ConfigBuilds

29.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

30.  def init(conf: PipeConfig): Unit

    Definition Classes

    DataStore

31.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

32.  def iterator(): Iterator[Data]

    This returns an iterator that iterates over the data store.

    This returns an iterator that iterates over the data store.

    returns

    An iterator that iterates over the data store until all documents have been processed.

    Definition Classes

    InMemDataQueue → DataStore

33.  var ls: Vector[Data]
34.  var name: String

    Definition Classes

    DataStore

35.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

36.  final def notify(): Unit

    Definition Classes

    AnyRef

37.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

38.  def put(data: Data): Unit

    Definition Classes

    DataStore

39.  def put(data: Seq[Data]): Unit

    This puts the data into the data store using put_, and then sends the data down the pipeline if the data store is connected to the pipeline.

    This puts the data into the data store using put_, and then sends the data down the pipeline if the data store is connected to the pipeline.

    data

    The data that needs to be put into the data store.

    Definition Classes

    DataStore

40.  def put_(data: Seq[Data]): Unit

    This actually puts the data into the data store.

    This actually puts the data into the data store.

    data

    The data to be put into the data store.

    Definition Classes

    InMemDataQueue → DataStore

41.  def registerConnector(connector: Connector[Data]): Unit

    Definition Classes

    Upstream

42.  def setConfig(pipeConfig: PipeConfig): Unit

    Definition Classes

    ConfigBuilds

43.  def setName(newName: String): Unit

    Definition Classes

    DataStore

44.  def size(): Int

    Definition Classes

    InMemDataQueue → DataStore

45.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

46.  def terminate(): Unit

    Definition Classes

    DataStore

47.  def toString(): String

    Definition Classes

    AnyRef → Any

48.  def transmitDownstream(data: Data): Unit

    Definition Classes

    Upstream

49.  def transmitDownstream(data: Seq[Data]): Unit

    Definition Classes

    Upstream

50.  def transmitDownstreamModified(data: Data): Unit

    Definition Classes

    Upstream

51.  def transmitDownstreamModified(data: Seq[Data]): Unit

    Definition Classes

    Upstream

52.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

53.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

54.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

55.  def →[B](y: B): (InMemDataQueue[Data], B)

    Implicit

    This member is added by an implicit conversion from InMemDataQueue[Data] to ArrowAssoc[InMemDataQueue[Data]] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc