Class Hierarchy
- java.lang.Object
- stroom.mapreduce.v2.BlockingPairQueue<K,V> (implements stroom.mapreduce.v2.PairQueue<K,V>)
- stroom.mapreduce.v2.MapperBase<K1,V1,K2,V2> (implements stroom.mapreduce.v2.Mapper<K1,V1,K2,V2>, stroom.mapreduce.v2.OutputCollector<K,V>)
- stroom.mapreduce.v2.Pair<K,V> (implements java.io.Serializable)
- stroom.mapreduce.v2.SimplePartitioner<K2,V2,K3,V3> (implements stroom.mapreduce.v2.Partitioner<K2,V2,K3,V3>)
- stroom.mapreduce.v2.UnsafePairQueue<K,V> (implements stroom.mapreduce.v2.PairQueue<K,V>)
Interface Hierarchy
- java.lang.Iterable<T>
- stroom.mapreduce.v2.Source<K,V>
- stroom.mapreduce.v2.PairQueue<K,V> (also extends stroom.mapreduce.v2.OutputCollector<K,V>, java.io.Serializable)
- stroom.mapreduce.v2.Source<K,V>
- stroom.mapreduce.v2.Mapper<K1,V1,K2,V2>
- stroom.mapreduce.v2.OutputCollector<K,V>
- stroom.mapreduce.v2.Reader<K,V>
- stroom.mapreduce.v2.Partitioner<K2,V2,K3,V3>
- stroom.mapreduce.v2.Reducer<K1,V1,K2,V2>
- java.io.Serializable
- stroom.mapreduce.v2.PairQueue<K,V> (also extends stroom.mapreduce.v2.OutputCollector<K,V>, stroom.mapreduce.v2.Source<K,V>)