public class TransferableJobProcessInformation extends Object implements JobProcessInformation, Portable
JobProcessInformation
is used to
transmit the currently processed number of records and the partition states to a requesting
client. This information can only be requested by the job emitting client and by requesting
it at the job owner.Constructor and Description |
---|
TransferableJobProcessInformation() |
TransferableJobProcessInformation(JobPartitionState[] partitionStates,
int processedRecords) |
Modifier and Type | Method and Description |
---|---|
int |
getClassId() |
int |
getFactoryId() |
JobPartitionState[] |
getPartitionStates()
Returns an array of
JobPartitionState s holding
information about the processing state (JobPartitionState.State )
and the processing owner of this partition.The index of the JobPartitionState inside of the
array is the number of the processed partition if the KeyValueSource
is PartitionIdAware or a randomly assigned id for
the different members of the cluster. |
int |
getProcessedRecords()
Returns the number of processed records.
The number of processed records is not a real time value but updated on regular base (after 1000 processed elements per node). |
void |
readPortable(PortableReader reader) |
void |
writePortable(PortableWriter writer) |
public TransferableJobProcessInformation()
public TransferableJobProcessInformation(JobPartitionState[] partitionStates, int processedRecords)
public JobPartitionState[] getPartitionStates()
JobProcessInformation
JobPartitionState
s holding
information about the processing state (JobPartitionState.State
)
and the processing owner of this partition.JobPartitionState
inside of the
array is the number of the processed partition if the KeyValueSource
is PartitionIdAware
or a randomly assigned id for
the different members of the cluster.getPartitionStates
in interface JobProcessInformation
public int getProcessedRecords()
JobProcessInformation
getProcessedRecords
in interface JobProcessInformation
public void writePortable(PortableWriter writer) throws IOException
writePortable
in interface Portable
IOException
public void readPortable(PortableReader reader) throws IOException
readPortable
in interface Portable
IOException
public int getFactoryId()
getFactoryId
in interface Portable
public int getClassId()
getClassId
in interface Portable
Copyright © 2014 Hazelcast, Inc.. All rights reserved.