Key
- type of the emitted keyChunk
- type of the intermediate chunk datapublic class ReducerTask<Key,Chunk> extends Object implements Runnable
Constructor and Description |
---|
ReducerTask(String name,
String jobId,
JobSupervisor supervisor) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
String |
getJobId() |
String |
getName() |
void |
processChunk(int partitionId,
Address sender,
Map<Key,Chunk> chunk) |
void |
processChunk(Map<Key,Chunk> chunk) |
void |
run() |
public ReducerTask(String name, String jobId, JobSupervisor supervisor)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.