Project Crunch has retired. For details please refer to its Attic page.
Emitter (Apache Crunch 0.10.0 API)

org.apache.crunch
Interface Emitter<T>


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.



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.