com.hazelcast.client.impl.protocol.parameters
Interface MapReduceTemplate


public interface MapReduceTemplate


Method Summary
 void cancel(String name, String jobId)
           
 void forCustom(String name, String jobId, Data predicate, Data mapper, Data combinerFactory, Data reducerFactory, Data keyValueSource, int chunkSize, List<Data> keys, String topologyChangedStrategy)
           
 void forList(String name, String jobId, Data predicate, Data mapper, Data combinerFactory, Data reducerFactory, String listName, int chunkSize, List<Data> keys, String topologyChangedStrategy)
           
 void forMap(String name, String jobId, Data predicate, Data mapper, Data combinerFactory, Data reducerFactory, String mapName, int chunkSize, List<Data> keys, String topologyChangedStrategy)
           
 void forMultiMap(String name, String jobId, Data predicate, Data mapper, Data combinerFactory, Data reducerFactory, String multiMapName, int chunkSize, List<Data> keys, String topologyChangedStrategy)
           
 void forSet(String name, String jobId, Data predicate, Data mapper, Data combinerFactory, Data reducerFactory, String setName, int chunkSize, List<Data> keys, String topologyChangedStrategy)
           
 void jobProcessInformation(String name, String jobId)
           
 

Method Detail

cancel

void cancel(String name,
            String jobId)

jobProcessInformation

void jobProcessInformation(String name,
                           String jobId)

forMap

void forMap(String name,
            String jobId,
            Data predicate,
            Data mapper,
            Data combinerFactory,
            Data reducerFactory,
            String mapName,
            int chunkSize,
            List<Data> keys,
            String topologyChangedStrategy)

forList

void forList(String name,
             String jobId,
             Data predicate,
             Data mapper,
             Data combinerFactory,
             Data reducerFactory,
             String listName,
             int chunkSize,
             List<Data> keys,
             String topologyChangedStrategy)

forSet

void forSet(String name,
            String jobId,
            Data predicate,
            Data mapper,
            Data combinerFactory,
            Data reducerFactory,
            String setName,
            int chunkSize,
            List<Data> keys,
            String topologyChangedStrategy)

forMultiMap

void forMultiMap(String name,
                 String jobId,
                 Data predicate,
                 Data mapper,
                 Data combinerFactory,
                 Data reducerFactory,
                 String multiMapName,
                 int chunkSize,
                 List<Data> keys,
                 String topologyChangedStrategy)

forCustom

void forCustom(String name,
               String jobId,
               Data predicate,
               Data mapper,
               Data combinerFactory,
               Data reducerFactory,
               Data keyValueSource,
               int chunkSize,
               List<Data> keys,
               String topologyChangedStrategy)


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.