public class SharedProgressAligner extends Object
HeadOperatorCoordinator
. It maintains the
information for each round, once one round is aligned, it would notify all the register
listeners.Modifier and Type | Field and Description |
---|---|
static ConcurrentHashMap<IterationID,SharedProgressAligner> |
instances |
Modifier and Type | Method and Description |
---|---|
static SharedProgressAligner |
getOrCreate(IterationID iterationId,
int totalHeadParallelism,
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context,
java.util.function.Supplier<Executor> executorFactory) |
void |
notifyGloballyTerminating() |
void |
registerAlignedListener(org.apache.flink.runtime.jobgraph.OperatorID operatorID,
SharedProgressAlignerListener alignedConsumer) |
void |
removeProgressInfo(org.apache.flink.runtime.jobgraph.OperatorID operatorId) |
void |
removeProgressInfo(org.apache.flink.runtime.jobgraph.OperatorID operatorId,
int subtaskIndex) |
void |
reportSubtaskProgress(org.apache.flink.runtime.jobgraph.OperatorID operatorId,
int subtaskIndex,
SubtaskAlignedEvent subtaskAlignedEvent) |
void |
requestCheckpoint(long checkpointId,
int operatorParallelism,
CompletableFuture<byte[]> snapshotStateFuture) |
void |
unregisterListener(org.apache.flink.runtime.jobgraph.OperatorID operatorID) |
public static ConcurrentHashMap<IterationID,SharedProgressAligner> instances
public static SharedProgressAligner getOrCreate(IterationID iterationId, int totalHeadParallelism, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, java.util.function.Supplier<Executor> executorFactory)
public void registerAlignedListener(org.apache.flink.runtime.jobgraph.OperatorID operatorID, SharedProgressAlignerListener alignedConsumer)
public void unregisterListener(org.apache.flink.runtime.jobgraph.OperatorID operatorID)
public void reportSubtaskProgress(org.apache.flink.runtime.jobgraph.OperatorID operatorId, int subtaskIndex, SubtaskAlignedEvent subtaskAlignedEvent)
public void requestCheckpoint(long checkpointId, int operatorParallelism, CompletableFuture<byte[]> snapshotStateFuture)
public void notifyGloballyTerminating()
public void removeProgressInfo(org.apache.flink.runtime.jobgraph.OperatorID operatorId)
public void removeProgressInfo(org.apache.flink.runtime.jobgraph.OperatorID operatorId, int subtaskIndex)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.