org.apache.crunch

Interface Emitter<T>

public interface Emitter<T>

Interface for writing outputs from a DoFn.

Method Summary

Methods

Modifier and Type	Method and Description
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.