MscrOutputChannel

abstract def inputNodes: Seq[CompNode]

sequence of all the nodes which may require some input data to be loaded, like a ParallelDo used as a reducer and needing its environment

abstract def reduce(key: Any, values: Iterable[Any], channelOutput: ChannelOutputFormat)(implicit configuration: Configuration): Unit

reduce key/values, given the current output format

abstract def sinks: Seq[Sink]

abstract def tag: Int

unique identifier for the Channel

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def cleanup(channelOutput: ChannelOutputFormat)(implicit configuration: Configuration): Unit

cleanup the channel, given the current output format

def clone(): AnyRef

def collectOutputs(outputFiles: Seq[Path])(implicit configuration: ScoobiConfiguration, fileSystems: FileSystems): Unit

copy all outputs files to the destinations specified by sink files

def convert(sink: Sink, x: Any)(implicit configuration: Configuration): (Any, Any)

use the output converter of a sink to convert a value to a key/value

def createEmitter(channelOutput: ChannelOutputFormat)(implicit configuration: Configuration): EmitterWriter with InputOutputContextScoobiJobContext

create an emitter to output values on the current tag for each sink.

var emitter: EmitterWriter

final def eq(arg0: AnyRef): Boolean

def equals(a: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

implicit lazy val logger: Log

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def scoobiConfiguration(configuration: Configuration): ScoobiConfiguration

create a ScoobiConfiguration from a Hadoop one

def setup(channelOutput: ChannelOutputFormat)(implicit configuration: Configuration): Unit

setup the nodes of the channel before writing data

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

def toString(): String

final def wait(): Unit

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

final def wait(arg0: Long): Unit