com.hazelcast.mapreduce.impl.task
Class ReducerTask<Key,Chunk>

java.lang.Object
  com.hazelcast.mapreduce.impl.task.ReducerTask<Key,Chunk>

Type Parameters:

Key - type of the emitted key

Chunk - type of the intermediate chunk data

All Implemented Interfaces:

Runnable

public class ReducerTask<Key,Chunk>
extends Object
implements Runnable

This task implementation executes the reducing phase. It collects all arriving chunks and processes them one by one. There is one ReducerTask per job per node to have a clear idea of the resulting load a job may create.

Constructor Summary

ReducerTask(String name, String jobId, JobSupervisor supervisor)

Method Summary

void	cancel()
String	getJobId()
String	getName()
void	processChunk(int partitionId, Address sender, Map<Key,Chunk> chunk)
void	processChunk(Map<Key,Chunk> chunk)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReducerTask

public ReducerTask(String name,
                   String jobId,
                   JobSupervisor supervisor)

Method Detail

getName

public String getName()

getJobId

public String getJobId()

cancel

public void cancel()

processChunk

public void processChunk(Map<Key,Chunk> chunk)

processChunk

public void processChunk(int partitionId,
                         Address sender,
                         Map<Key,Chunk> chunk)

run

public void run()

Specified by:

run in interface Runnable