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 void
collect(GroupKey key, Item value)
protected Reducer<GroupKey,Item,GroupKey,Item>
createReducer()
void
setOutputCollector(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:
createReducer
in classSimplePartitioner<GroupKey,Item,GroupKey,Item>
-
setOutputCollector
public void setOutputCollector(OutputCollector<GroupKey,Item> outputCollector)
- Specified by:
setOutputCollector
in interfacePartitioner<GroupKey,Item,GroupKey,Item>
- Overrides:
setOutputCollector
in classSimplePartitioner<GroupKey,Item,GroupKey,Item>
-
-