com.nicta.scoobi.impl.plan.mscr

FloatingInputChannel

Related Doc: package mscr

class FloatingInputChannel extends MscrInputChannel

This input channel is a tree of Mappers which are not connected to Gbk nodes

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. FloatingInputChannel
  2. MscrInputChannel
  3. InputChannel
  4. Channel
  5. AnyRef
  6. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new FloatingInputChannel(sourceNode: CompNode, terminalNodes: Seq[CompNode], graph: Graph)

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
    FloatingInputChannelInputChannel
  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
    MscrInputChannelInputChannel
  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
    FloatingInputChannelMscrInputChannel
  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
    FloatingInputChannelMscrInputChannel
  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
    MscrInputChannelInputChannel
  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
    FloatingInputChannelInputChannel
  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
    FloatingInputChannelMscrInputChannel
  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
    MscrInputChannelInputChannel
  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
    FloatingInputChannelMscrInputChannel
  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
    FloatingInputChannelInputChannel
  34. def outputTags(mapper: ParallelDo): Seq[Int]

    returns

    the output tag for a given "last" mapper

    Attributes
    protected
    Definition Classes
    FloatingInputChannelMscrInputChannel
  35. def processNodes: Seq[ProcessNode]

    returns

    all the ProcessNodes for this channel

    Definition Classes
    FloatingInputChannelChannel
  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
    MscrInputChannelInputChannel
  39. lazy val source: Source

    data source for this input channel if the

    data source for this input channel if the

    Definition Classes
    MscrInputChannelInputChannel
  40. val sourceNode: CompNode

    main source node providing data for this input channel

    main source node providing data for this input channel

    Definition Classes
    FloatingInputChannelInputChannel
  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
    FloatingInputChannelInputChannel
  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
    FloatingInputChannelInputChannel
  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( ... )

Inherited from MscrInputChannel

Inherited from InputChannel

Inherited from Channel

Inherited from AnyRef

Inherited from Any

Ungrouped