@Beta public interface JobProcessInformation
Modifier and Type | Method and Description |
---|---|
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). |
JobPartitionState[] getPartitionStates()
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.int getProcessedRecords()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.