|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.hazelcast.mapreduce.impl.notification.MapReduceNotification com.hazelcast.mapreduce.impl.notification.MemberAwareMapReduceNotification com.hazelcast.mapreduce.impl.notification.IntermediateChunkNotification<KeyOut,Value>
KeyOut
- type of the keyValue
- type of the valuepublic class IntermediateChunkNotification<KeyOut,Value>
Notification that is fired every time the chunk limit is reached and is send to the reducers
Constructor Summary | |
---|---|
IntermediateChunkNotification()
|
|
IntermediateChunkNotification(Address address,
String name,
String jobId,
Map<KeyOut,Value> chunk,
int partitionId)
|
Method Summary | |
---|---|
Map<KeyOut,Value> |
getChunk()
|
int |
getFactoryId()
Returns DataSerializableFactory factory id for this class. |
int |
getId()
Returns type identifier for this class. |
int |
getPartitionId()
|
void |
readData(ObjectDataInput in)
Reads fields from the input stream |
String |
toString()
|
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream |
Methods inherited from class com.hazelcast.mapreduce.impl.notification.MemberAwareMapReduceNotification |
---|
getAddress |
Methods inherited from class com.hazelcast.mapreduce.impl.notification.MapReduceNotification |
---|
getJobId, getName |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public IntermediateChunkNotification()
public IntermediateChunkNotification(Address address, String name, String jobId, Map<KeyOut,Value> chunk, int partitionId)
Method Detail |
---|
public Map<KeyOut,Value> getChunk()
public int getPartitionId()
public void writeData(ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
writeData
in class MemberAwareMapReduceNotification
out
- output
IOException
public void readData(ObjectDataInput in) throws IOException
DataSerializable
readData
in interface DataSerializable
readData
in class MemberAwareMapReduceNotification
in
- input
IOException
public int getFactoryId()
IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
public String toString()
toString
in class MemberAwareMapReduceNotification
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |