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) |
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()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.