Package stroom.query.common.v2
Class ItemPartitioner
- java.lang.Object
-
- stroom.mapreduce.v2.SimplePartitioner<GroupKey,Item,GroupKey,Item>
-
- stroom.query.common.v2.ItemPartitioner
-
-
Constructor Summary
Constructors Constructor Description ItemPartitioner(int[] depths, int maxDepth)
-
Method Summary
Modifier and Type Method Description protected voidcollect(GroupKey key, Item value)protected Reducer<GroupKey,Item,GroupKey,Item>createReducer()voidsetOutputCollector(OutputCollector<GroupKey,Item> outputCollector)-
Methods inherited from class stroom.mapreduce.v2.SimplePartitioner
partition, read
-
-
-
-
Method Detail
-
createReducer
protected Reducer<GroupKey,Item,GroupKey,Item> createReducer()
- Specified by:
createReducerin classSimplePartitioner<GroupKey,Item,GroupKey,Item>
-
setOutputCollector
public void setOutputCollector(OutputCollector<GroupKey,Item> outputCollector)
- Specified by:
setOutputCollectorin interfacePartitioner<GroupKey,Item,GroupKey,Item>- Overrides:
setOutputCollectorin classSimplePartitioner<GroupKey,Item,GroupKey,Item>
-
-