com.hazelcast.client.impl.protocol.parameters
Class MapReduceJobProcessInformationResultParameters

java.lang.Object
  com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationResultParameters

public class MapReduceJobProcessInformationResultParameters
extends Object

Field Summary

static ClientMessageType

TYPE ClientMessageType of this message

Method Summary

static int	calculateDataSize(JobPartitionState[] partitionStates, int processedRecords) sample data size estimation
static MapReduceJobProcessInformationResultParameters	decode(ClientMessage flyweight)
static ClientMessage	encode(JobPartitionState[] partitionStates, int processedRecords)

Methods inherited from class java.lang.Object

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

Field Detail

TYPE

public static final ClientMessageType TYPE

ClientMessageType of this message

Method Detail

decode

public static MapReduceJobProcessInformationResultParameters decode(ClientMessage flyweight)

encode

public static ClientMessage encode(JobPartitionState[] partitionStates,
                                   int processedRecords)

calculateDataSize

public static int calculateDataSize(JobPartitionState[] partitionStates,
                                    int processedRecords)

sample data size estimation

Returns:

size