com.cloudera.crunch
Interface Emitter<T>

All Known Implementing Classes:

IntermediateEmitter, MultipleOutputEmitter, OutputEmitter

public interface Emitter<T>

Interface for writing outputs from a DoFn.

Method Summary

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

Method Detail

emit

void emit(T emitted)

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

Parameters:

emitted - The value to write

flush

void flush()

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