public static class HeadOperatorCoordinator.HeadOperatorCoordinatorProvider extends Object implements org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider
HeadOperatorCoordinator
.Constructor and Description |
---|
HeadOperatorCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorId,
IterationID iterationId,
int totalHeadParallelism) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.runtime.operators.coordination.OperatorCoordinator |
create(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context) |
org.apache.flink.runtime.jobgraph.OperatorID |
getOperatorId() |
public HeadOperatorCoordinatorProvider(org.apache.flink.runtime.jobgraph.OperatorID operatorId, IterationID iterationId, int totalHeadParallelism)
public org.apache.flink.runtime.jobgraph.OperatorID getOperatorId()
getOperatorId
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider
public org.apache.flink.runtime.operators.coordination.OperatorCoordinator create(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context)
create
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.