Partitioner (stroom-query SNAPSHOT API)

All Superinterfaces:

Reader<K2,V2>

All Known Implementing Classes:

ItemPartitioner, SimplePartitioner
```
public interface Partitioner<K2,V2,K3,V3>
extends Reader<K2,V2>
```
The job of the partitioner is to take output from the mapper and partition it by key. Values with matching keys are gathered into collections so that a reducer can reduce all items with a matching key. An instance of a partitioner may create tasks for each key so that reducers can be run in parallel either locally or across a cluster.

- Method Summary
  
  Modifier and Type Method Description
  
  void partition()
  
  void setOutputCollector(OutputCollector<K3,V3> outputCollector)
  - Methods inherited from interface stroom.mapreduce.v2.Reader
    read

Method Detail

partition
```
void partition()
```

setOutputCollector

void setOutputCollector(OutputCollector<K3,V3> outputCollector)