|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use JobPartitionState | |
|---|---|
| com.hazelcast.mapreduce | This package contains the MapReduce API definition for Hazelcast. All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
| com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework internals. |
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. |
| Uses of JobPartitionState in com.hazelcast.mapreduce |
|---|
| Methods in com.hazelcast.mapreduce that return JobPartitionState | |
|---|---|
JobPartitionState[] |
JobProcessInformation.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. |
| Uses of JobPartitionState in com.hazelcast.mapreduce.impl |
|---|
| Methods in com.hazelcast.mapreduce.impl with parameters of type JobPartitionState | |
|---|---|
static String |
MapReduceUtil.printPartitionStates(JobPartitionState[] partitionStates)
|
| Uses of JobPartitionState in com.hazelcast.mapreduce.impl.task |
|---|
| Classes in com.hazelcast.mapreduce.impl.task that implement JobPartitionState | |
|---|---|
class |
JobPartitionStateImpl
This class holds information about the current processing state and the owner of a partition |
| Methods in com.hazelcast.mapreduce.impl.task that return JobPartitionState | |
|---|---|
JobPartitionState[] |
JobProcessInformationImpl.getPartitionStates()
|
JobPartitionState[] |
TransferableJobProcessInformation.getPartitionStates()
|
| Methods in com.hazelcast.mapreduce.impl.task with parameters of type JobPartitionState | |
|---|---|
boolean |
JobProcessInformationImpl.updatePartitionState(int partitionId,
JobPartitionState oldPartitionState,
JobPartitionState newPartitionState)
|
boolean |
JobProcessInformationImpl.updatePartitionState(JobPartitionState[] oldPartitionStates,
JobPartitionState[] newPartitionStates)
|
boolean |
JobProcessInformationImpl.updatePartitionState(JobPartitionState[] oldPartitionStates,
JobPartitionState[] newPartitionStates)
|
| Constructors in com.hazelcast.mapreduce.impl.task with parameters of type JobPartitionState | |
|---|---|
TransferableJobProcessInformation(JobPartitionState[] partitionStates,
int processedRecords)
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||