public class JobProcessInformationImpl extends Object implements JobProcessInformation
Constructor and Description |
---|
JobProcessInformationImpl(int partitionCount,
JobSupervisor supervisor) |
Modifier and Type | Method and Description |
---|---|
void |
addProcessedRecords(int records) |
void |
cancelPartitionState() |
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). |
String |
toString() |
boolean |
updatePartitionState(int partitionId,
JobPartitionState oldPartitionState,
JobPartitionState newPartitionState) |
boolean |
updatePartitionState(JobPartitionState[] oldPartitionStates,
JobPartitionState[] newPartitionStates) |
public JobProcessInformationImpl(int partitionCount, JobSupervisor supervisor)
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 addProcessedRecords(int records)
public void cancelPartitionState()
public boolean updatePartitionState(int partitionId, JobPartitionState oldPartitionState, JobPartitionState newPartitionState)
public boolean updatePartitionState(JobPartitionState[] oldPartitionStates, JobPartitionState[] newPartitionStates)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.