GbkInputChannel

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

   GbkInputChannel → 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

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

    

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

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

    

    Definition Classes

    AnyRef → Any

18. val graph: Graph

    

    Definition Classes

    GbkInputChannel → MscrInputChannel

19. lazy val graphNodes: Graph

    

    Definition Classes

    MscrInputChannel

20. val groupByKeys: Seq[GroupByKey]

    

21. def hashCode(): Int

    

    Definition Classes

    InputChannel → AnyRef → Any

22. def id: Int

    

    Definition Classes

    InputChannel

23. lazy val inputNodes: Seq[CompNode]

    

    sourceNode + environments for the parallelDo nodes

    sourceNode + environments for the parallelDo nodes

    Definition Classes

    MscrInputChannel → InputChannel

24. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

25. 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

    GbkInputChannel → InputChannel

26. 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

    GbkInputChannel → MscrInputChannel

27. implicit lazy val logger: Log

    

    Definition Classes

    MscrInputChannel

28. 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

29. 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

    GbkInputChannel → MscrInputChannel

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

    

    Definition Classes

    MscrInputChannel

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

    

    Definition Classes

    AnyRef

32. final def notify(): Unit

    

    Definition Classes

    AnyRef

33. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

34. lazy val outputNodes: Seq[ProcessNodeImpl with Serializable { ... /* 2 definitions in type refinement */ }]

    

    nodes where this input channel writes to

    nodes where this input channel writes to

    Definition Classes

    GbkInputChannel → InputChannel

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

    
    returns

    the output tag for a given "last" mapper

    Attributes

    protected

    Definition Classes

    GbkInputChannel → MscrInputChannel

36. def processNodes: Seq[ProcessNode]

    
    returns

    all the ProcessNodes for this channel

    Definition Classes

    GbkInputChannel → Channel

37. def scoobiConfiguration(configuration: Configuration): ScoobiConfigurationImpl

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

38. implicit var scoobiConfiguration: ScoobiConfiguration

    

    Attributes

    protected

    Definition Classes

    MscrInputChannel

39. 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

40. lazy val source: Source

    

    data source for this input channel if the

    data source for this input channel if the

    Definition Classes

    MscrInputChannel → InputChannel

41. val sourceNode: CompNode

    

    main source node providing data for this input channel

    main source node providing data for this input channel

    Definition Classes

    GbkInputChannel → InputChannel

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

    

    Definition Classes

    AnyRef

43. 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

    GbkInputChannel → InputChannel

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

    GbkInputChannel → 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( ... )