GbkInputChannel

Value Members

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

   Definition Classes

   AnyRef

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

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

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

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. lazy val bypassOutputNodes: Seq[ParallelDo]

   Definition Classes

   GbkInputChannel → InputChannel

8. def cleanup(context: InputOutputContext): Unit

   setup the parallelDos of this input channel

   setup the parallelDos of this input channel

   Definition Classes

   MscrInputChannel → InputChannel

9. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

10. implicit var configuration: Configuration

    Attributes

    protected

    Definition Classes

    MscrInputChannel

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

12. var emitters: Map[Int, EmitterWriter]

    Attributes

    protected

    Definition Classes

    MscrInputChannel

13. var environments: Map[ParallelDo, Any]

    Attributes

    protected

    Definition Classes

    MscrInputChannel

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

    Definition Classes

    AnyRef

15. def equals(a: Any): Boolean

    Definition Classes

    InputChannel → AnyRef → Any

16. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef → Any

18. lazy val graphNodes: Layering

    Definition Classes

    MscrInputChannel

19. val groupByKeys: Seq[GroupByKey]

20. def hashCode(): Int

    Definition Classes

    InputChannel → AnyRef → Any

21. def id: Int

    Definition Classes

    InputChannel

22. lazy val inputNodes: Seq[CompNode]

    sourceNode + environments for the parallelDo nodes

    sourceNode + environments for the parallelDo nodes

    Definition Classes

    MscrInputChannel → InputChannel

23. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

24. lazy val keyTypes: KeyTypes

    Definition Classes

    GbkInputChannel → InputChannel

25. lazy val lastMappers: Seq[ParallelDo]

    Definition Classes

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

    MscrInputChannel

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

    Definition Classes

    MscrInputChannel

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

    Definition Classes

    AnyRef

31. val nodes: Layering

    Definition Classes

    GbkInputChannel → MscrInputChannel

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 */ }]

    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. lazy val terminalNodes: Seq[GroupByKey]

    Definition Classes

    GbkInputChannel → MscrInputChannel

45. var tks: Map[Int, TaggedKey]

    Attributes

    protected

    Definition Classes

    MscrInputChannel

46. def toString(): String

    Definition Classes

    MscrInputChannel → AnyRef → Any

47. var tvs: Map[Int, TaggedValue]

    Attributes

    protected

    Definition Classes

    MscrInputChannel

48. lazy val valueTypes: ValueTypes

    Definition Classes

    GbkInputChannel → InputChannel

49. var vectorEmitter: VectorEmitterWriter

    Attributes

    protected

    Definition Classes

    MscrInputChannel

50. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )