public class MemberAssigningJobProcessInformationImpl extends JobProcessInformationImpl
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 and Description |
---|
MemberAssigningJobProcessInformationImpl(int partitionCount,
JobSupervisor supervisor) |
Modifier and Type | Method and Description |
---|---|
int |
assignMemberId(Address address,
String memberUuid,
JobTaskConfiguration configuration) |
addProcessedRecords, cancelPartitionState, getPartitionStates, getProcessedRecords, toString, updatePartitionState, updatePartitionState
public MemberAssigningJobProcessInformationImpl(int partitionCount, JobSupervisor supervisor)
public int assignMemberId(Address address, String memberUuid, JobTaskConfiguration configuration)
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.