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

Constructors

Constructor and Description
MemberAssigningJobProcessInformationImpl(int partitionCount, JobSupervisor supervisor)

Method Summary

Methods

Modifier and Type	Method and Description
int	assignMemberId(Address address, String memberUuid, JobTaskConfiguration configuration)

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

addProcessedRecords, cancelPartitionState, getPartitionStates, getProcessedRecords, 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)