com.hazelcast.mapreduce

Interface JobProcessInformation

All Known Implementing Classes:

JobProcessInformationImpl, MemberAssigningJobProcessInformationImpl, TransferableJobProcessInformation

@Beta
public interface JobProcessInformation

This interface holds basic information about a running map reduce job like state of the different partitions and the number of currently processed records.
The number of processed records is not a real time value but updated on regular base (after 1000 processed elements per node).

Since:

3.2

Method Summary

Methods

Modifier and Type	Method and Description
JobPartitionState[]	getPartitionStates() Returns an array of JobPartitionStates 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).

Method Detail

getPartitionStates

JobPartitionState[] getPartitionStates()

Returns an array of JobPartitionStates 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.

Returns:

partition state array with actual state information

getProcessedRecords

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).

Returns:

number of processed records