Package stroom.mapreduce.v2

Class SimplePartitioner<K2,V2,K3,V3>

java.lang.Object

stroom.mapreduce.v2.SimplePartitioner<K2,V2,K3,V3>

All Implemented Interfaces:

Partitioner<K2,V2,K3,V3>, Reader<K2,V2>

Direct Known Subclasses:

ItemPartitioner

public abstract class SimplePartitioner<K2,V2,K3,V3>
extends java.lang.Object
implements Partitioner<K2,V2,K3,V3>

Constructor Summary

Constructors

Constructor	Description
SimplePartitioner()

Method Summary

Modifier and Type	Method	Description
protected void	collect(K2 key, V2 value)
protected abstract Reducer<K2,V2,K3,V3>	createReducer()
void	partition()
void	read(Source<K2,V2> source)
void	setOutputCollector(OutputCollector<K3,V3> outputCollector)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimplePartitioner

public SimplePartitioner()

Method Detail

collect

protected void collect(K2 key,
                       V2 value)

read

public void read(Source<K2,V2> source)

Specified by:

read in interface Reader<K2,V2>

partition

public void partition()

Specified by:

partition in interface Partitioner<K2,V2,K3,V3>

setOutputCollector

public void setOutputCollector(OutputCollector<K3,V3> outputCollector)

Specified by:

setOutputCollector in interface Partitioner<K2,V2,K3,V3>

createReducer

protected abstract Reducer<K2,V2,K3,V3> createReducer()