Package stroom.mapreduce.v2

Class MapperBase<K1,V1,K2,V2>

java.lang.Object

stroom.mapreduce.v2.MapperBase<K1,V1,K2,V2>

All Implemented Interfaces:

Mapper<K1,V1,K2,V2>, OutputCollector<K1,V1>

Direct Known Subclasses:

ItemMapper

public abstract class MapperBase<K1,V1,K2,V2>
extends java.lang.Object
implements Mapper<K1,V1,K2,V2>, OutputCollector<K1,V1>

Constructor Summary

Constructors

Constructor	Description
MapperBase(OutputCollector<K2,V2> outputCollector)

Method Summary

Modifier and Type	Method	Description
void	collect(K1 key, V1 value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface stroom.mapreduce.v2.Mapper

map

Constructor Detail

MapperBase

public MapperBase(OutputCollector<K2,V2> outputCollector)

Method Detail

collect

public void collect(K1 key,
                    V1 value)

Specified by:

collect in interface OutputCollector<K1,V1>