Package org.redisson.mapreduce

Class Collector<K,V>

java.lang.Object

org.redisson.mapreduce.Collector<K,V>

Type Parameters:

K - key

V - value

All Implemented Interfaces:

RCollector<K,V>

public class Collector<K,V>
extends Object
implements RCollector<K,V>

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
Collector(Codec codec, RedissonClient client, String name, int parts, long timeout)

Method Summary

Modifier and Type	Method	Description
void	emit(K key, V value)	Store key/value

Methods inherited from class java.lang.Object

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

Constructor Detail

Collector

public Collector(Codec codec,
                 RedissonClient client,
                 String name,
                 int parts,
                 long timeout)

Method Detail

emit

public void emit(K key,
                 V value)

Description copied from interface: RCollector

Store key/value

Specified by:

emit in interface RCollector<K,V>

Parameters:

key - available to reduce

value - available to reduce