This project has retired. For details please refer to its Attic page.

org.apache.crunch.impl.mr.emit
Class IntermediateEmitter

java.lang.Object
  org.apache.crunch.impl.mr.emit.IntermediateEmitter

All Implemented Interfaces:

Emitter<Object>

public class IntermediateEmitter
extends Object
implements Emitter<Object>

An Emitter implementation that links the output of one DoFn to the input of another DoFn.

Constructor Summary

IntermediateEmitter(PType<Object> outputPType, List<RTNode> children, org.apache.hadoop.conf.Configuration conf, boolean disableDeepCopy)

Method Summary

void	emit(Object emitted) Write the emitted value to the next stage of the pipeline.
void	flush() Flushes any values cached by this emitter.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IntermediateEmitter

public IntermediateEmitter(PType<Object> outputPType,
                           List<RTNode> children,
                           org.apache.hadoop.conf.Configuration conf,
                           boolean disableDeepCopy)

Method Detail

emit

public void emit(Object emitted)

Description copied from interface: Emitter

Write the emitted value to the next stage of the pipeline.

Specified by:

emit in interface Emitter<Object>

Parameters:

emitted - The value to write

flush

public void flush()

Description copied from interface: Emitter

Flushes any values cached by this emitter. Called during the cleanup stage.

Specified by:

flush in interface Emitter<Object>