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 FileSystemDataMap[Input, Output] to any2stringadd[FileSystemDataMap[Input, Output]] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4.  def ->[B](y: B): (FileSystemDataMap[Input, Output], B)

   Implicit

   This member is added by an implicit conversion from FileSystemDataMap[Input, Output] to ArrowAssoc[FileSystemDataMap[Input, Output]] 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: Output): Unit

   Definition Classes

   DataStore

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

   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

   FileSystemDataMap → 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: Input): Boolean

    Definition Classes

    FileSystemDataMap → DataMap

14.  def displayName(): String

    Definition Classes

    DataStore

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

    Definition Classes

    Upstream

16.  def ensuring(cond: (FileSystemDataMap[Input, Output]) ⇒ Boolean, msg: ⇒ Any): FileSystemDataMap[Input, Output]

    Implicit

    This member is added by an implicit conversion from FileSystemDataMap[Input, Output] to Ensuring[FileSystemDataMap[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

17.  def ensuring(cond: (FileSystemDataMap[Input, Output]) ⇒ Boolean): FileSystemDataMap[Input, Output]

    Implicit

    This member is added by an implicit conversion from FileSystemDataMap[Input, Output] to Ensuring[FileSystemDataMap[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

18.  def ensuring(cond: Boolean, msg: ⇒ Any): FileSystemDataMap[Input, Output]

    Implicit

    This member is added by an implicit conversion from FileSystemDataMap[Input, Output] to Ensuring[FileSystemDataMap[Input, Output]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

19.  def ensuring(cond: Boolean): FileSystemDataMap[Input, Output]

    Implicit

    This member is added by an implicit conversion from FileSystemDataMap[Input, Output] to Ensuring[FileSystemDataMap[Input, Output]] 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[Output]

    Definition Classes

    FileSystemDataMap → 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 FileSystemDataMap[Input, Output] to StringFormat[FileSystemDataMap[Input, Output]] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

25.  def get(key: Input): Option[Output]

    Definition Classes

    FileSystemDataMap → DataMap

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

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    ConfigBuilds

28.  def getOrElse(key: Input, default: Output): Output

    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[Output]

    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

    FileSystemDataMap → DataStore

33.  var name: String

    Definition Classes

    DataStore

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

    Definition Classes

    AnyRef

35.  final def notify(): Unit

    Definition Classes

    AnyRef

36.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

37.  def put(key: Input, data: Output): Unit

    Definition Classes

    DataMap

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

    Definition Classes

    DataStore

39.  def put(data: Seq[Output]): 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_(key: Input, data: Output): Unit

    Definition Classes

    FileSystemDataMap → DataMap

41.  def put_(data: Seq[Output]): 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

    FileSystemDataMap → DataStore

42.  def registerConnector(connector: Connector[Output]): Unit

    Definition Classes

    Upstream

43.  def remove(keys: Seq[Input]): Unit

    Definition Classes

    FileSystemDataMap → DataMap

44.  def remove(key: Input): Unit

    Definition Classes

    FileSystemDataMap → DataMap

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

    Definition Classes

    ConfigBuilds

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

    Definition Classes

    DataStore

47.  def size(): Int

    Definition Classes

    FileSystemDataMap → DataStore

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

    Definition Classes

    AnyRef

49.  def terminate(): Unit

    Definition Classes

    DataStore

50.  def toString(): String

    Definition Classes

    AnyRef → Any

51.  def transmitDownstream(data: Output): Unit

    Definition Classes

    Upstream

52.  def transmitDownstream(data: Seq[Output]): Unit

    Definition Classes

    Upstream

53.  def transmitDownstreamModified(data: Output): Unit

    Definition Classes

    Upstream

54.  def transmitDownstreamModified(data: Seq[Output]): Unit

    Definition Classes

    Upstream

55.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

58.  def →[B](y: B): (FileSystemDataMap[Input, Output], B)

    Implicit

    This member is added by an implicit conversion from FileSystemDataMap[Input, Output] to ArrowAssoc[FileSystemDataMap[Input, Output]] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc