Package org.redisson.mapreduce

Class Collector<K,​V>

  • Type Parameters:
    K - key
    V - value
    All Implemented Interfaces:
    RCollector<K,​V>
    public class Collector<K,​V>
extends 
implements RCollector<K,​V>
    Author:
    Nikita Koksharov

    • Constructor Summary

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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void emit​(K key, V value)
      Store key/value

      • Methods inherited from class java.lang.

        , , , , , , , , , ,

    • Constructor Detail

      • Collector

        public Collector​(Codec codec,
                 RedissonClient client,
                  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