FloatingInputChannel

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. lazy val bypassOutputNodes: Seq[ParallelDo]

   

   output nodes (parallelDos) which are not going in a reducer

   output nodes (parallelDos) which are not going in a reducer

   Definition Classes

   FloatingInputChannel → InputChannel

6. def bypassTags: Seq[Int]

   

   tags for bypass nodes

   tags for bypass nodes

   Definition Classes

   InputChannel

7. def cleanup(context: InputOutputContext): Unit

   

   setup the parallelDos of this input channel

   setup the parallelDos of this input channel

   Definition Classes

   MscrInputChannel → InputChannel

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. implicit var configuration: Configuration

   

   Attributes

   protected

   Definition Classes

   MscrInputChannel

10. def createEmitter(tag: Int, ioContext: InputOutputContext): EmitterWriter with InputOutputContextScoobiJobContext

    

    create an emitter for a given output tag, which will either emit values with auto-generated keys for a FloatingInputChannel, or key/values for a GbkInputChannel

    create an emitter for a given output tag, which will either emit values with auto-generated keys for a FloatingInputChannel, or key/values for a GbkInputChannel

    Attributes

    protected

    Definition Classes

    FloatingInputChannel → MscrInputChannel

11. var emitters: Map[Int, EmitterWriter]

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

12. var environments: Map[ParallelDo, Any]

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

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

    

    Definition Classes

    AnyRef

14. def equals(a: Any): Boolean

    

    Definition Classes

    InputChannel → AnyRef → Any

15. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

17. val graph: Graph

    

    Definition Classes

    FloatingInputChannel → MscrInputChannel

18. lazy val graphNodes: Graph

    

    Definition Classes

    MscrInputChannel

19. def hashCode(): Int

    

    Definition Classes

    InputChannel → AnyRef → Any

20. def id: Int

    

    Definition Classes

    InputChannel

21. lazy val inputNodes: Seq[CompNode]

    

    sourceNode + environments for the parallelDo nodes

    sourceNode + environments for the parallelDo nodes

    Definition Classes

    MscrInputChannel → InputChannel

22. def isEmpty: Boolean

    

23. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

24. lazy val keyTypes: KeyTypes

    

    types of the keys which are emitted by this InputChannel, by tag

    types of the keys which are emitted by this InputChannel, by tag

    Definition Classes

    FloatingInputChannel → InputChannel

25. lazy val lastMappers: Seq[ParallelDo]

    

    last mappers in the "tree" of mappers using the input channel source node A mapper is not the "last" if its parent is a parallelDo that is included in the list of mappers

    last mappers in the "tree" of mappers using the input channel source node A mapper is not the "last" if its parent is a parallelDo that is included in the list of mappers

    Definition Classes

    FloatingInputChannel → MscrInputChannel

26. implicit lazy val logger: Log

    

    Definition Classes

    MscrInputChannel

27. def map(key: Any, value: Any, context: InputOutputContext): Unit

    

    map a given key/value and emit it

    map a given key/value and emit it

    Definition Classes

    MscrInputChannel → InputChannel

28. lazy val mappers: Seq[ParallelDo]

    

    collect all the mappers which are connected to the source node and connect to one of the terminal nodes for this channel

    collect all the mappers which are connected to the source node and connect to one of the terminal nodes for this channel

    Definition Classes

    FloatingInputChannel → MscrInputChannel

29. def mappersToString(name: String, mps: Seq[ParallelDo]): String

    

    Definition Classes

    MscrInputChannel

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

    

    Definition Classes

    AnyRef

31. final def notify(): Unit

    

    Definition Classes

    AnyRef

32. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

33. lazy val outputNodes: Seq[ParallelDo]

    

    nodes where this input channel writes to

    nodes where this input channel writes to

    Definition Classes

    FloatingInputChannel → InputChannel

34. def outputTags(mapper: ParallelDo): Seq[Int]

    
    returns

    the output tag for a given "last" mapper

    Attributes

    protected

    Definition Classes

    FloatingInputChannel → MscrInputChannel

35. def processNodes: Seq[ProcessNode]

    
    returns

    all the ProcessNodes for this channel

    Definition Classes

    FloatingInputChannel → Channel

36. def scoobiConfiguration(configuration: Configuration): ScoobiConfigurationImpl

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

37. implicit var scoobiConfiguration: ScoobiConfiguration

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

38. def setup(context: InputOutputContext): Unit

    

    store the current TaggedKey/TaggedValue which are going to be a container for all key/values to map, by tag

    store the current TaggedKey/TaggedValue which are going to be a container for all key/values to map, by tag

    Definition Classes

    MscrInputChannel → InputChannel

39. lazy val source: Source

    

    data source for this input channel if the

    data source for this input channel if the

    Definition Classes

    MscrInputChannel → InputChannel

40. val sourceNode: CompNode

    

    main source node providing data for this input channel

    main source node providing data for this input channel

    Definition Classes

    FloatingInputChannel → InputChannel

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

    

    Definition Classes

    AnyRef

42. lazy val tags: Seq[Int]

    

    collect all the tags accessible from this source node

    collect all the tags accessible from this source node

    Definition Classes

    FloatingInputChannel → InputChannel

43. val terminalNodes: Seq[CompNode]

    

44. var tks: Map[Int, TaggedKey]

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

45. def toString(): String

    

    Definition Classes

    MscrInputChannel → AnyRef → Any

46. var tvs: Map[Int, TaggedValue]

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

47. lazy val valueTypes: ValueTypes

    

    types of the values which are emitted by this InputChannel, by tag

    types of the values which are emitted by this InputChannel, by tag

    Definition Classes

    FloatingInputChannel → InputChannel

48. var vectorEmitter: VectorEmitterWriter

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

49. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )