KeyIn
- type of the input keyValueIn
- type of the input valueKeyOut
- type of the emitted keyValueOut
- type of the emitted valueChunk
- type of the intermediate chunk (retrieved from combiners)public class MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk> extends Object
KeyValueSource
implementation and possible configuring the
partitionId to operate on.Constructor and Description |
---|
MapCombineTask(JobTaskConfiguration configuration,
JobSupervisor supervisor,
MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
int |
getChunkSize() |
String |
getJobId() |
String |
getName() |
static <K,V> Map<Address,Map<K,V>> |
mapResultToMember(JobSupervisor supervisor,
Map<K,V> result) |
void |
process() |
void |
processMapping(int partitionId,
DefaultContext<KeyOut,ValueOut> context,
KeyValueSource<KeyIn,ValueIn> keyValueSource,
boolean partitionProcessor) |
public MapCombineTask(JobTaskConfiguration configuration, JobSupervisor supervisor, MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase)
public String getName()
public String getJobId()
public int getChunkSize()
public void cancel()
public void process()
public final void processMapping(int partitionId, DefaultContext<KeyOut,ValueOut> context, KeyValueSource<KeyIn,ValueIn> keyValueSource, boolean partitionProcessor) throws Exception
Exception
public static <K,V> Map<Address,Map<K,V>> mapResultToMember(JobSupervisor supervisor, Map<K,V> result)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.