Package org.redisson.api.mapreduce

Interface RMapReduceExecutor<VIn,KOut,VOut>

  • Type Parameters:
    VIn - input value
    KOut - output key
    VOut - output value
    All Known Subinterfaces:
    RCollectionMapReduce<VIn,KOut,VOut>, RMapReduce<KIn,VIn,KOut,VOut>
    All Known Implementing Classes:
    RedissonCollectionMapReduce, RedissonMapReduce
    public interface RMapReduceExecutor<VIn,KOut,VOut>
    Contains methods for MapReduce process execution.
    Author:
    Nikita Koksharov

    • Method Detail

      • execute

        Map<KOut,VOut> execute()
        Executes MapReduce process across Redisson Nodes
        Returns:
        map containing reduced keys and values

      • executeAsync

        RFuture<Map<KOut,VOut>> executeAsync()
        Executes MapReduce process across Redisson Nodes in asynchronous mode
        Returns:
        map containing reduced keys and values

      • execute

        void execute(String resultMapName)
        Executes MapReduce process across Redisson Nodes and stores result in map with resultMapName
        Parameters:
        resultMapName - - destination map name

      • executeAsync

        RFuture<Void> executeAsync(String resultMapName)
        Executes MapReduce process across Redisson Nodes in asynchronous mode and stores result in map with resultMapName
        Parameters:
        resultMapName - - destination map name
        Returns:
        void

      • execute

        <R> R execute(RCollator<KOut,VOut,R> collator)
        Executes MapReduce process across Redisson Nodes and collides result using defined collator
        Type Parameters:
        R - result type
        Parameters:
        collator - applied to result
        Returns:
        collated result

      • executeAsync

        <R> RFuture<R> executeAsync(RCollator<KOut,VOut,R> collator)
        Executes MapReduce process across Redisson Nodes in asynchronous mode and collides result using defined collator
        Type Parameters:
        R - result type
        Parameters:
        collator - applied to result
        Returns:
        collated result