|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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. |
Uses of Emitter in org.apache.crunch |
---|
Methods in org.apache.crunch with parameters of type Emitter | |
---|---|
void |
FilterFn.cleanup(Emitter<T> 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)
Deprecated. |
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)
Deprecated. |
void |
MapValuesFn.process(Pair<K,V1> input,
Emitter<Pair<K,V2>> emitter)
Deprecated. |
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)
|
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. |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |