Package stroom.mapreduce.v2
-
Interface Summary Interface Description Mapper<K1,V1,K2,V2> OutputCollector<K,V> PairQueue<K,V> Partitioner<K2,V2,K3,V3> The job of the partitioner is to take output from the mapper and partition it by key.Reader<K,V> Reducer<K1,V1,K2,V2> Source<K,V> -
Class Summary Class Description BlockingPairQueue<K,V> MapperBase<K1,V1,K2,V2> Pair<K,V> SimplePartitioner<K2,V2,K3,V3> UnsafePairQueue<K,V>