Package | Description |
---|---|
org.apache.flink.iteration.operator | |
org.apache.flink.iteration.operator.coordinator |
Modifier and Type | Method and Description |
---|---|
static <V> org.apache.flink.statefun.flink.core.feedback.FeedbackKey<V> |
OperatorUtils.createFeedbackKey(IterationID iterationId,
int feedbackIndex)
Creates
FeedbackKey from the iterationId and feedbackIndex . |
Constructor and Description |
---|
HeadOperator(IterationID iterationId,
int feedbackIndex,
boolean isCriteriaStream,
org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor,
org.apache.flink.runtime.operators.coordination.OperatorEventGateway operatorEventGateway,
org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService) |
HeadOperatorFactory(IterationID iterationId,
int feedbackIndex,
boolean isCriteriaStream,
int totalInitialVariableParallelism) |
TailOperator(IterationID iterationId,
int feedbackIndex) |
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 |
---|
HeadOperatorCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorId,
IterationID iterationId,
int totalHeadParallelism) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.