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()
Returns class identifier for this portable class.
|
int |
getFactoryId()
Returns PortableFactory id for this portable class
|
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, it is updated on a regular basis (after 1000 processed elements per node). |
void |
readPortable(PortableReader reader)
Read portable fields using PortableReader
|
void |
writePortable(PortableWriter writer)
Serialize this portable object using PortableWriter
|
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
Portable
writePortable
in interface Portable
writer
- PortableWriterIOException
public void readPortable(PortableReader reader) throws IOException
Portable
readPortable
in interface Portable
reader
- PortableReaderIOException
public int getFactoryId()
Portable
getFactoryId
in interface Portable
public int getClassId()
Portable
getClassId
in interface Portable
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.