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

org.apache.crunch.impl.mr.emit
Class OutputEmitter<T,K,V>

java.lang.Object
  org.apache.crunch.impl.mr.emit.OutputEmitter<T,K,V>

All Implemented Interfaces:

Emitter<T>

public class OutputEmitter<T,K,V>
extends Object
implements Emitter<T>

Constructor Summary

OutputEmitter(Converter<K,V,Object,Object> converter, org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,K,V> context)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputEmitter

public OutputEmitter(Converter<K,V,Object,Object> converter,
                     org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,K,V> context)

Method Detail

emit

public void emit(T emitted)

Description copied from interface: Emitter

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

Specified by:

emit in interface Emitter<T>

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<T>