com.hazelcast.mapreduce.impl.task
Class MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk>

java.lang.Object
  com.hazelcast.mapreduce.impl.task.MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk>

Type Parameters:

KeyIn - type of the input key

ValueIn - type of the input value

KeyOut - type of the emitted key

ValueOut - type of the emitted value

Chunk - type of the intermediate chunk (retrieved from combiners)

public class MapCombineTask<KeyIn,ValueIn,KeyOut,ValueOut,Chunk>
extends Object

This class acutally executed the mapping-combine phase. It is responsible for opening / closing the KeyValueSource implementation and possible configuring the partitionId to operate on.

Constructor Summary

MapCombineTask(JobTaskConfiguration configuration, JobSupervisor supervisor, MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase)

Method Summary

void	cancel()
int	getChunkSize()
String	getJobId()
String	getName()
void	process()
void	processMapping(int partitionId, DefaultContext<KeyOut,ValueOut> context, KeyValueSource<KeyIn,ValueIn> keyValueSource)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapCombineTask

public MapCombineTask(JobTaskConfiguration configuration,
                      JobSupervisor supervisor,
                      MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase)

Method Detail

getName

public String getName()

getJobId

public String getJobId()

getChunkSize

public int getChunkSize()

cancel

public void cancel()

process

public void process()

processMapping

public final void processMapping(int partitionId,
                                 DefaultContext<KeyOut,ValueOut> context,
                                 KeyValueSource<KeyIn,ValueIn> keyValueSource)
                          throws Exception

Throws:

Exception