Package | Description |
---|---|
org.apache.flink.iteration.operator.coordinator |
Modifier and Type | Field and Description |
---|---|
static ConcurrentHashMap<IterationID,SharedProgressAligner> |
SharedProgressAligner.instances |
Modifier and Type | Method and Description |
---|---|
static SharedProgressAligner |
SharedProgressAligner.getOrCreate(IterationID iterationId,
int totalHeadParallelism,
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context,
java.util.function.Supplier<Executor> executorFactory) |
Constructor and Description |
---|
HeadOperatorCoordinator(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context,
SharedProgressAligner sharedProgressAligner) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.