Uses of Interface
com.cloudera.crunch.Emitter

Packages that use Emitter

com.cloudera.crunch
com.cloudera.crunch.fn
com.cloudera.crunch.impl.mr.emit
com.cloudera.crunch.lib

Uses of Emitter in com.cloudera.crunch

Methods in com.cloudera.crunch with parameters of type Emitter

void	DoFn.cleanup(Emitter<T> emitter) Called during the cleanup of the MapReduce job this DoFn is associated with.
void	CombineFn.AggregatorCombineFn.process(Pair<K,Iterable<V>> input, Emitter<Pair<K,V>> emitter)
void	MapFn.process(S input, Emitter<T> emitter)
abstract void	DoFn.process(S input, Emitter<T> emitter) Processes the records from a PCollection.
void	FilterFn.process(T input, Emitter<T> emitter)

Uses of Emitter in com.cloudera.crunch.fn

Methods in com.cloudera.crunch.fn with parameters of type Emitter

void	MapKeysFn.process(Pair<K1,V> input, Emitter<Pair<K2,V>> emitter)
void	MapValuesFn.process(Pair<K,V1> input, Emitter<Pair<K,V2>> emitter)

Uses of Emitter in com.cloudera.crunch.impl.mr.emit

Classes in com.cloudera.crunch.impl.mr.emit that implement Emitter

class	IntermediateEmitter An Emitter implementation that links the output of one DoFn to the input of another DoFn.
class	MultipleOutputEmitter<T,K,V>
class	OutputEmitter<T,K,V>

Uses of Emitter in com.cloudera.crunch.lib

Methods in com.cloudera.crunch.lib with parameters of type Emitter

void	Aggregate.TopKFn.cleanup(Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKCombineFn.process(Pair<Boolean,Iterable<Pair<K,V>>> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKFn.process(Pair<K,V> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Sample.SamplerFn.process(S input, Emitter<S> emitter)