Pipe

Value Members

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

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

5. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

6. final def eq(arg0: AnyRef): Boolean

   

   Definition Classes

   AnyRef

7. def equals(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

8. def finalize(): Unit

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

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

9. final def getClass(): Class[_]

   

   Definition Classes

   AnyRef → Any

10. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

11. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

12. def maybeTo(opFunc: Option[(O) ⇒ O]): Pipe[O]

    

    Potentially create a new software.uncharted.sparkpipe.Pipe by linking this software.uncharted.sparkpipe.Pipe to an optional operation

    Potentially create a new software.uncharted.sparkpipe.Pipe by linking this software.uncharted.sparkpipe.Pipe to an optional operation

    opFunc

    an optional parameter to chain onto the end of this software.uncharted.sparkpipe.Pipe, forming a new software.uncharted.sparkpipe.Pipe

    returns

    a new software.uncharted.sparkpipe.Pipe[I,A], which is the composition of this software.uncharted.sparkpipe.Pipe[I,O] and the new operation O=>A iff opFunc is defined. Pipe is unchanged otherwise.

13. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

14. final def notify(): Unit

    

    Definition Classes

    AnyRef

15. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

16. def reset(): Unit

    

    Clears this software.uncharted.sparkpipe.Pipe's cache, as well as any parent pipe's cache, forcing the next call to run() to execute from the head of its chain of operations

17. def run(): O

    

    Run this pipe, producing a value which is cached until reset()

    Run this pipe, producing a value which is cached until reset()

    returns

    the output of the tail of this software.uncharted.sparkpipe.Pipe, cached until reset() is called.

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

    

    Definition Classes

    AnyRef

19. def to[A](opFunc: (O) ⇒ A): Pipe[A]

    

    Create a new software.uncharted.sparkpipe.Pipe by linking this software.uncharted.sparkpipe.Pipe to a new operation

    Create a new software.uncharted.sparkpipe.Pipe by linking this software.uncharted.sparkpipe.Pipe to a new operation

    A

    the output type of the new operation

    opFunc

    a parameter to chain onto the end of this software.uncharted.sparkpipe.Pipe, forming a new software.uncharted.sparkpipe.Pipe

    returns

    a new software.uncharted.sparkpipe.Pipe[I,A], which is the composition of this software.uncharted.sparkpipe.Pipe[I,O] and the new operation O=>A.

20. def toString(): String

    

    Definition Classes

    AnyRef → Any

21. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

23. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )