public interface MapReduceCodecTemplate
Modifier and Type | Method and Description |
---|---|
Object |
cancel(String name,
String jobId) |
Object |
forCustom(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
Data keyValueSource,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
Object |
forList(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String listName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
Object |
forMap(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String mapName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
Object |
forMultiMap(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String multiMapName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
Object |
forSet(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String setName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
Object |
jobProcessInformation(String name,
String jobId) |
Object cancel(String name, String jobId)
name
- Name of the distributed objectjobId
- Id of the job to cancelObject jobProcessInformation(String name, String jobId)
name
- Name of the distributed objectjobId
- Id of the jobObject 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)
name
- Name of the distributed objectjobId
- Id of the jobpredicate
- The filter to use during operationmapper
- The mapper for the operationcombinerFactory
- The combiner factory to usereducerFactory
- The reducer factory to be usedmapName
- Name of the Map object to work on.chunkSize
- The number of items for which the reduce shall be performedkeys
- The keys for the objects to be processedtopologyChangedStrategy
- The strategy to use if a topology change is detected.Object 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)
name
- Name of the distributed objectjobId
- Id of the jobpredicate
- The filter to use during operationmapper
- The mapper for the operationcombinerFactory
- The combiner factory to usereducerFactory
- The reducer factory to be usedlistName
- Name of the List object to work on.chunkSize
- The number of items for which the reduce shall be performedkeys
- The keys for the objects to be processedtopologyChangedStrategy
- The strategy to use if a topology change is detected.Object 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)
name
- Name of the distributed objectjobId
- Id of the jobpredicate
- The filter to use during operationmapper
- The mapper for the operationcombinerFactory
- The combiner factory to usereducerFactory
- The reducer factory to be usedsetName
- Name of the Set object to work on.chunkSize
- The number of items for which the reduce shall be performedkeys
- The keys for the objects to be processedtopologyChangedStrategy
- The strategy to use if a topology change is detected.Object 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)
name
- Name of the distributed objectjobId
- Id of the jobpredicate
- The filter to use during operationmapper
- The mapper for the operationcombinerFactory
- The combiner factory to usereducerFactory
- The reducer factory to be usedmultiMapName
- Name of the MultiMap object to work on.chunkSize
- The number of items for which the reduce shall be performedkeys
- The keys for the objects to be processedtopologyChangedStrategy
- The strategy to use if a topology change is detected.Object 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)
name
- Name of the distributed objectjobId
- Id of the jobpredicate
- The filter to use during operationmapper
- The mapper for the operationcombinerFactory
- The combiner factory to usereducerFactory
- The reducer factory to be usedkeyValueSource
- custom data sources for mapreduce algorithm. The object implements the
com.hazelcast.mapreduce.KeyValueSource interfacechunkSize
- The number of items for which the reduce shall be performedkeys
- The keys for the objects to be processedtopologyChangedStrategy
- The strategy to use if a topology change is detected.Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.