public class DurableExecutorPartitionContainer extends Object
Constructor and Description |
---|
DurableExecutorPartitionContainer(NodeEngineImpl nodeEngine,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
clearRingBuffersHavingLesserBackupCountThan(int thresholdReplicaIndex) |
void |
createExecutorContainer(String name,
TaskRingBuffer ringBuffer) |
void |
executeAll() |
DurableExecutorContainer |
getOrCreateContainer(String name) |
Operation |
prepareReplicationOperation(int replicaIndex) |
void |
removeContainer(String name) |
public DurableExecutorPartitionContainer(NodeEngineImpl nodeEngine, int partitionId)
public DurableExecutorContainer getOrCreateContainer(String name)
public void createExecutorContainer(String name, TaskRingBuffer ringBuffer)
public Operation prepareReplicationOperation(int replicaIndex)
public void clearRingBuffersHavingLesserBackupCountThan(int thresholdReplicaIndex)
public void executeAll()
public void removeContainer(String name)
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.