com.hazelcast.mapreduce.impl.task
Class MemberAssigningJobProcessInformationImpl

java.lang.Object
  com.hazelcast.mapreduce.impl.task.JobProcessInformationImpl
      com.hazelcast.mapreduce.impl.task.MemberAssigningJobProcessInformationImpl

All Implemented Interfaces:

JobProcessInformation

public class MemberAssigningJobProcessInformationImpl
extends JobProcessInformationImpl

This JobProcessInformationImpl extending class is used in non partitionId based map reduce tasks where partitions are kind of simulated using a unique id per member.

Constructor Summary

MemberAssigningJobProcessInformationImpl(int partitionCount, JobSupervisor supervisor)

Method Summary

int	assignMemberId(Address address, String memberUuid, JobTaskConfiguration configuration)

Methods inherited from class com.hazelcast.mapreduce.impl.task.JobProcessInformationImpl

addProcessedRecords, cancelPartitionState, getPartitionStates, getProcessedRecords, resetPartitionState, toString, updatePartitionState, updatePartitionState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MemberAssigningJobProcessInformationImpl

public MemberAssigningJobProcessInformationImpl(int partitionCount,
                                                JobSupervisor supervisor)

Method Detail

assignMemberId

public int assignMemberId(Address address,
                          String memberUuid,
                          JobTaskConfiguration configuration)