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 InMemIdDataMap[Data] to any2stringadd[InMemIdDataMap[Data]] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

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

   Implicit

   This member is added by an implicit conversion from InMemIdDataMap[Data] to ArrowAssoc[InMemIdDataMap[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

   InMemIdDataMap → 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 contains(key: Identity[Data]): Boolean

    Definition Classes

    InMemIdDataMap → DataMap

14.  def displayName(): String

    Definition Classes

    DataStore

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

    Definition Classes

    Upstream

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

    Implicit

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

    Definition Classes

    Ensuring

17.  def ensuring(cond: (InMemIdDataMap[Data]) ⇒ Boolean): InMemIdDataMap[Data]

    Implicit

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

    Definition Classes

    Ensuring

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

    Implicit

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

    Definition Classes

    Ensuring

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

    Implicit

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

    Definition Classes

    Ensuring

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

    Definition Classes

    AnyRef

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

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    InMemIdDataMap → DataStore

23.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    Implicit

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

    Definition Classes

    StringFormat

    Annotations

    @inline()

25.  def get(key: Identity[Data]): Option[Data]

    Definition Classes

    InMemIdDataMap → DataMap

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

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    ConfigBuilds

28.  def getOrElse(key: Identity[Data], default: Data): Data

    Definition Classes

    DataMap

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

    InMemIdDataMap → DataStore

33.  var map: Map[Identity[Data], 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(key: Identity[Data], data: Data): Unit

    Definition Classes

    DataMap

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

    Definition Classes

    DataStore

40.  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

41.  def put_(key: Identity[Data], data: Data): Unit

    Definition Classes

    InMemIdDataMap → DataMap

42.  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

    InMemIdDataMap → DataStore

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

    Definition Classes

    Upstream

44.  def remove(key: Identity[Data]): Unit

    Definition Classes

    InMemIdDataMap → DataMap

45.  def remove(keys: Seq[Identity[Data]]): Unit

    Definition Classes

    InMemIdDataMap → DataMap

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

    Definition Classes

    ConfigBuilds

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

    Definition Classes

    DataStore

48.  def size(): Int

    Definition Classes

    InMemIdDataMap → DataStore

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

    Definition Classes

    AnyRef

50.  def terminate(): Unit

    Definition Classes

    DataStore

51.  def toString(): String

    Definition Classes

    InMemIdDataMap → AnyRef → Any

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

    Definition Classes

    Upstream

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

    Definition Classes

    Upstream

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

    Definition Classes

    Upstream

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

    Definition Classes

    Upstream

56.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

59.  def →[B](y: B): (InMemIdDataMap[Data], B)

    Implicit

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

    Definition Classes

    ArrowAssoc