This project has retired. For details please refer to its Attic page.
IntermediateEmitter (Apache Crunch 0.3.0-incubating API)

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

java.lang.Object
  extended by 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(List<RTNode> children)
           
 
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
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IntermediateEmitter

public IntermediateEmitter(List<RTNode> children)
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>


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