org.infinispan.distexec.mapreduce

Interface Collector<K,V>

All Known Subinterfaces:

MapReduceManagerImpl.CollectableCollector<K,V>

All Known Implementing Classes:

MapReduceManagerImpl.DefaultCollector

public interface Collector<K,V>

OutputCollector is the intermediate key/value result data output collector given to each Mapper

Since:

5.0

Author:

Mircea Markus, Sanne Grinovero

See Also:

Mapper.map(Object, Object, Collector)

Method Summary

Methods

Modifier and Type	Method and Description
void	emit(K key, V value) Intermediate key/value callback used by Mapper implementor

Method Detail

emit

void emit(K key,
        V value)

Intermediate key/value callback used by Mapper implementor

Parameters:

key - intermediate key

value - intermediate value