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 JunctionPipe[Head, Mid, End] to any2stringadd[JunctionPipe[Head, Mid, End]] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4.  def ->[B](y: B): (JunctionPipe[Head, Mid, End], B)

   Implicit

   This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to ArrowAssoc[JunctionPipe[Head, Mid, End]] performed by method ArrowAssoc in scala.Predef.

   Definition Classes

   ArrowAssoc

   Annotations

   @inline()

5.  def :-+[Next <: Identifiable[Next], Mid <: Identifiable[Mid]](headReducer: PartialReducerPipe[End, Mid, Next]): Pipe[Head, Next]

   This connects the Reducer to the input store, connecting it completely.

   This connects the Reducer to the input store, connecting it completely. This is expected to be called after a bigglue.pipes.Implicits.DataNode, and can be seen after gitID and clonedMap.

   Next

   The type at the end of the new pipeline.

   Mid

   The type that the mapper ends up outputting given the input End.

   headReducer

   The reducer to connect to the input store.

   returns

   A connected ReducerPipe that connects this pipeline to the reducer.

   Definition Classes

   Pipe

6.  def :--[Next <: Identifiable[Next], Mid <: Identifiable[Mid]](headMapper: PartialMapperPipe[End, Mid, Next]): Pipe[Head, Next]

   This connects the Mapper to the input store, connecting it completely.

   This connects the Mapper to the input store, connecting it completely. This is expected to be called after a bigglue.pipes.Implicits.DataNode, and can be seen after gitID and clonedMap.

   Next

   The type at the end of the new pipeline.

   Mid

   The type that the mapper ends up outputting given the input End.

   headMapper

   The mapper to connect to the input store.

   returns

   A connected MapperPipe that connects this pipeline to the mapper.

   Definition Classes

   Pipe

7.  def :<[Next <: Identifiable[Next]](parPipes: PartialPipe[End, Next]): Pipe[Head, Next]

   Definition Classes

   Pipe

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

   Definition Classes

   AnyRef → Any

9.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

10.  def check(conf: PipeConfig): Unit

    This is called within the example with pipe.check(conf).

    This is called within the example with pipe.check(conf). In basic terms, this checks to see whether the pipeline that we have created is valid. See MapperPipe.check() or ReducerPipe.check()

    conf

    The configuration file that we are checking with.

    Definition Classes

    JunctionPipe → Pipe

11.  def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

12.  def end(): DataStore[End]

    This is the data store at the end of the pipeline.

    This is the data store at the end of the pipeline.

    returns

    The data store at the end of the pipeline. In all cases, this is authorMap in the example.

    Definition Classes

    JunctionPipe → Pipe

13.  def ensuring(cond: (JunctionPipe[Head, Mid, End]) ⇒ Boolean, msg: ⇒ Any): JunctionPipe[Head, Mid, End]

    Implicit

    This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to Ensuring[JunctionPipe[Head, Mid, End]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

14.  def ensuring(cond: (JunctionPipe[Head, Mid, End]) ⇒ Boolean): JunctionPipe[Head, Mid, End]

    Implicit

    This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to Ensuring[JunctionPipe[Head, Mid, End]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

15.  def ensuring(cond: Boolean, msg: ⇒ Any): JunctionPipe[Head, Mid, End]

    Implicit

    This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to Ensuring[JunctionPipe[Head, Mid, End]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

16.  def ensuring(cond: Boolean): JunctionPipe[Head, Mid, End]

    Implicit

    This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to Ensuring[JunctionPipe[Head, Mid, End]] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

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

    Definition Classes

    AnyRef

18.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    Implicit

    This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to StringFormat[JunctionPipe[Head, Mid, End]] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

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

    Definition Classes

    AnyRef → Any

21.  def head(): DataStore[Head]

    This is the data store at the start of the pipeline.

    This is the data store at the start of the pipeline.

    returns

    The data store at the start of the pipeline.

    Definition Classes

    JunctionPipe → Pipe

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

    This is called with the example with pipe.init(conf).

    This is called with the example with pipe.init(conf). This initializes the pipeline and all of the parts within it. See MapperPipe.init() or ReducerPipe.init()

    conf

    The configuration file that we are initializing with. This ideally is the configuration file that is being used to check the pipeline.

    Definition Classes

    JunctionPipe → Pipe

23.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

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

    Definition Classes

    AnyRef

25.  final def notify(): Unit

    Definition Classes

    AnyRef

26.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

27.  val p1: Pipe[Head, Mid]
28.  val p2: PartialPipe[Mid, End]
29.  def persist(): Unit

    This starts/restarts the pipeline.

    This starts/restarts the pipeline. See MapperPipe.persist() or ReducerPipe.persist()

    Definition Classes

    JunctionPipe → Pipe

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

    Definition Classes

    AnyRef

31.  def terminate(): Unit

    Definition Classes

    JunctionPipe → Pipe

32.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

35.  def ||[OHead <: Identifiable[OHead], OEnd <: Identifiable[OEnd]](o: Pipe[OHead, OEnd]): PairPipes[Head, OHead, End, OEnd]

    Definition Classes

    Pipe

36.  def →[B](y: B): (JunctionPipe[Head, Mid, End], B)

    Implicit

    This member is added by an implicit conversion from JunctionPipe[Head, Mid, End] to ArrowAssoc[JunctionPipe[Head, Mid, End]] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc