Interface RCollectionMapper<VIn,KOut,VOut>

  • Type Parameters:
    VIn - input value
    KOut - output key
    VOut - output value
    All Superinterfaces:
    Serializable

    public interface RCollectionMapper<VIn,KOut,VOut>
    extends Serializable
    Mapper task invoked during map phase of MapReduce process and launched across Redisson Nodes. Every task stores transformed result of input key and value into RCollector instance. Collected results are handled by RReducer instance once all Mapper tasks have finished.
    Author:
    Nikita Koksharov
    • Method Detail

      • map

        void map(VIn value,
                 RCollector<KOut,VOut> collector)
        Invoked for each Collection source entry
        Parameters:
        value - - input value
        collector - - instance shared across all Mapper tasks