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

Uses of Interface
org.apache.crunch.Emitter

Packages that use Emitter

org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.contrib.bloomfilter	Support for creating Bloom Filters.
org.apache.crunch.fn	Commonly used functions for manipulating collections.
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.
org.apache.crunch.lib.join	Inner and outer joins on collections.
org.apache.crunch.types	Common functionality for business object serialization.

Uses of Emitter in org.apache.crunch

Methods in org.apache.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 org.apache.crunch.contrib.bloomfilter

Methods in org.apache.crunch.contrib.bloomfilter with parameters of type Emitter

void	BloomFilterFn.cleanup(Emitter<Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> emitter)
void	BloomFilterFn.process(S input, Emitter<Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> emitter)

Uses of Emitter in org.apache.crunch.fn

Methods in org.apache.crunch.fn with parameters of type Emitter

void	PairMapFn.cleanup(Emitter<Pair<S,T>> emitter)
void	CompositeMapFn.cleanup(Emitter<T> 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 org.apache.crunch.lib

Methods in org.apache.crunch.lib with parameters of type Emitter

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

Uses of Emitter in org.apache.crunch.lib.join

Methods in org.apache.crunch.lib.join with parameters of type Emitter

void	LeftOuterJoinFn.cleanup(Emitter<Pair<K,Pair<U,V>>> emitter) Called during the cleanup of the MapReduce job this DoFn is associated with.
void	FullOuterJoinFn.cleanup(Emitter<Pair<K,Pair<U,V>>> emitter) Called during the cleanup of the MapReduce job this DoFn is associated with.
void	RightOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter) Performs the actual joining.
void	LeftOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter) Performs the actual joining.
abstract void	JoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter) Performs the actual joining.
void	InnerJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter) Performs the actual joining.
void	FullOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter) Performs the actual joining.
void	JoinFn.process(Pair<Pair<K,Integer>,Iterable<Pair<U,V>>> input, Emitter<Pair<K,Pair<U,V>>> emitter) Split up the input record to make coding a bit more manageable.

Uses of Emitter in org.apache.crunch.types

Methods in org.apache.crunch.types with parameters of type Emitter

void	Protos.TextToProtoFn.process(String input, Emitter<M> emitter)