Uses of Interface
org.apache.crunch.Emitter

Packages that use Emitter
org.apache.crunch   
org.apache.crunch.fn   
org.apache.crunch.impl.mr.emit   
org.apache.crunch.lib   
org.apache.crunch.lib.join   
org.apache.crunch.test Provides a collection of test utilities. 
org.apache.crunch.util   
 

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.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.impl.mr.emit
 

Classes in org.apache.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 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.test
 

Classes in org.apache.crunch.test that implement Emitter
 class InMemoryEmitter<T>
          An Emitter instance that writes emitted records to a backing List.
 

Uses of Emitter in org.apache.crunch.util
 

Methods in org.apache.crunch.util with parameters of type Emitter
 void Protos.TextToProtoFn.process(String input, Emitter<M> emitter)
           
 



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