com.hazelcast.client.impl.protocol.template

Interface MapReduceCodecTemplate

public interface MapReduceCodecTemplate

Method Summary

Methods

Modifier and Type	Method and Description
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,
          @Nullable
          Data predicate,
          Data mapper,
          @Nullable
          Data combinerFactory,
          @Nullable
          Data reducerFactory,
          String mapName,
          int chunkSize,
          @Nullable
          List<Data> keys,
          @Nullable
          String topologyChangedStrategy)

forList

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

forSet

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

forMultiMap

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

forCustom

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