Uses of Class
org.apache.flink.runtime.jobgraph.OperatorID

Packages that use OperatorID

Package	Description
org.apache.flink.runtime
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.filemerging
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.metrics.scope
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.rest.messages
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.source.coordinator
org.apache.flink.runtime.state
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskmanager
org.apache.flink.runtime.util
org.apache.flink.runtime.webmonitor

Uses of OperatorID in org.apache.flink.runtime

Methods in org.apache.flink.runtime that return OperatorID

Modifier and Type	Method	Description
OperatorID	OperatorIDPair.getGeneratedOperatorID()

Methods in org.apache.flink.runtime that return types with arguments of type OperatorID

Modifier and Type	Method	Description
Optional<OperatorID>	OperatorIDPair.getUserDefinedOperatorID()

Methods in org.apache.flink.runtime with parameters of type OperatorID

Modifier and Type	Method	Description
static OperatorIDPair	OperatorIDPair.generatedIDOnly(OperatorID generatedOperatorID)
static OperatorIDPair	OperatorIDPair.of(OperatorID generatedOperatorID, OperatorID userDefinedOperatorID)

Uses of OperatorID in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return OperatorID

Modifier and Type	Method	Description
OperatorID	OperatorState.getOperatorID()

Methods in org.apache.flink.runtime.checkpoint that return types with arguments of type OperatorID

Modifier and Type	Method	Description
Map<OperatorID,OperatorState>	CompletedCheckpoint.getOperatorStates()
Map<OperatorID,OperatorState>	PendingCheckpoint.getOperatorStates()
Set<Map.Entry<OperatorID,OperatorSubtaskState>>	TaskStateSnapshot.getSubtaskStateMappings()	Returns the set of all mappings from operator id to the corresponding subtask state.

Methods in org.apache.flink.runtime.checkpoint with parameters of type OperatorID

Modifier and Type	Method	Description
static <T> Map<OperatorInstanceID,List<T>>	StateAssignmentOperation.applyRepartitioner(OperatorID operatorID, OperatorStateRepartitioner<T> opStateRepartitioner, List<List<T>> chainOpParallelStates, int oldParallelism, int newParallelism)
OperatorState	OperatorState.copyWithNewOperatorID(OperatorID newOperatorId)
OperatorSubtaskState	TaskStateSnapshot.getSubtaskStateByOperatorID(OperatorID operatorID)	Returns the subtask state for the given operator id (or null if not contained).
OperatorSubtaskState	TaskStateSnapshot.putSubtaskStateByOperatorID(OperatorID operatorID, OperatorSubtaskState state)	Maps the given operator id to the given subtask state.
void	CheckpointCoordinator.setIsProcessingBacklog(OperatorID operatorID, boolean isProcessingBacklog)	Reports whether a source operator is currently processing backlog.

Method parameters in org.apache.flink.runtime.checkpoint with type arguments of type OperatorID

Modifier and Type	Method	Description
void	DefaultCheckpointPlan.fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)
void	FinishedTaskStateProvider.fulfillFinishedTaskStatus(Map<OperatorID,OperatorState> operatorStates)	Fulfills the state for the finished subtasks and operators to indicate they are finished.
static <T extends StateObject> void	StateAssignmentOperation.reDistributePartitionableStates(Map<OperatorID,OperatorState> oldOperatorStates, int newParallelism, java.util.function.Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle, OperatorStateRepartitioner<T> stateRepartitioner, Map<OperatorInstanceID,List<T>> result)

Constructors in org.apache.flink.runtime.checkpoint with parameters of type OperatorID

Constructor	Description
FullyFinishedOperatorState(OperatorID operatorID, int parallelism, int maxParallelism)
OperatorState(OperatorID operatorID, int parallelism, int maxParallelism)

Constructor parameters in org.apache.flink.runtime.checkpoint with type arguments of type OperatorID

Constructor	Description
CheckpointCoordinator(org.apache.flink.api.common.JobID job, CheckpointCoordinatorConfiguration chkConfig, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, CheckpointStorage checkpointStorage, Executor executor, CheckpointsCleaner checkpointsCleaner, org.apache.flink.util.concurrent.ScheduledExecutor timer, CheckpointFailureManager failureManager, CheckpointPlanCalculator checkpointPlanCalculator, org.apache.flink.util.clock.Clock clock, CheckpointStatsTracker statsTracker, java.util.function.BiFunction<Set<ExecutionJobVertex>,Map<OperatorID,OperatorState>,VertexFinishedStateChecker> vertexFinishedStateCheckerFactory)
CompletedCheckpoint(org.apache.flink.api.common.JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<OperatorID,OperatorState> operatorStates, Collection<MasterState> masterHookStates, CheckpointProperties props, CompletedCheckpointStorageLocation storageLocation, CompletedCheckpointStats completedCheckpointStats)
CompletedCheckpoint(org.apache.flink.api.common.JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<OperatorID,OperatorState> operatorStates, Collection<MasterState> masterHookStates, CheckpointProperties props, CompletedCheckpointStorageLocation storageLocation, CompletedCheckpointStats completedCheckpointStats, CheckpointProperties restoredProps)
PendingCheckpoint(org.apache.flink.api.common.JobID jobId, long checkpointId, long checkpointTimestamp, CheckpointPlan checkpointPlan, Collection<OperatorID> operatorCoordinatorsToConfirm, Collection<String> masterStateIdentifiers, CheckpointProperties props, CompletableFuture<CompletedCheckpoint> onCompletionPromise, PendingCheckpointStats pendingCheckpointStats, CompletableFuture<Void> masterTriggerCompletionPromise)
StateAssignmentOperation(long restoreCheckpointId, Set<ExecutionJobVertex> tasks, Map<OperatorID,OperatorState> operatorStates, boolean allowNonRestoredState)
TaskStateSnapshot(Map<OperatorID,OperatorSubtaskState> subtaskStatesByOperatorID)
VertexFinishedStateChecker(Set<ExecutionJobVertex> vertices, Map<OperatorID,OperatorState> operatorStates)

Uses of OperatorID in org.apache.flink.runtime.checkpoint.filemerging

Constructors in org.apache.flink.runtime.checkpoint.filemerging with parameters of type OperatorID

Constructor	Description
SubtaskKey(OperatorID operatorID, org.apache.flink.api.common.TaskInfo taskInfo)

Uses of OperatorID in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<CoordinationResponse>	Dispatcher.deliverCoordinationRequestToCoordinator(org.apache.flink.api.common.JobID jobId, OperatorID operatorId, org.apache.flink.util.SerializedValue<CoordinationRequest> serializedRequest, org.apache.flink.api.common.time.Time timeout)

Uses of OperatorID in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	Execution.sendOperatorEvent(OperatorID operatorId, org.apache.flink.util.SerializedValue<OperatorEvent> event)	Sends the operator event to the Task on the Task Executor.

Uses of OperatorID in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return OperatorID

Modifier and Type	Method	Description
static OperatorID	OperatorID.fromJobVertexID(JobVertexID id)
OperatorID	OperatorInstanceID.getOperatorId()

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type OperatorID

Modifier and Type	Method	Description
Map<OperatorID,org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.InputFormat<?,?>>>	InputOutputFormatContainer.FormatUserCodeTable.getInputFormats()
Map<OperatorID,org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.InputFormat<?,?>>>	InputOutputFormatContainer.getInputFormats()
Map<OperatorID,org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.OutputFormat<?>>>	InputOutputFormatContainer.FormatUserCodeTable.getOutputFormats()
Map<OperatorID,org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.OutputFormat<?>>>	InputOutputFormatContainer.getOutputFormats()
<OT,T extends org.apache.flink.core.io.InputSplit> org.apache.commons.lang3.tuple.Pair<OperatorID,org.apache.flink.api.common.io.InputFormat<OT,T>>	InputOutputFormatContainer.getUniqueInputFormat()
<IT> org.apache.commons.lang3.tuple.Pair<OperatorID,org.apache.flink.api.common.io.OutputFormat<IT>>	InputOutputFormatContainer.getUniqueOutputFormat()

Methods in org.apache.flink.runtime.jobgraph with parameters of type OperatorID

Modifier and Type	Method	Description
InputOutputFormatContainer	InputOutputFormatContainer.addInputFormat(OperatorID operatorId, org.apache.flink.api.common.io.InputFormat<?,?> inputFormat)
InputOutputFormatContainer	InputOutputFormatContainer.addInputFormat(OperatorID operatorId, org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.InputFormat<?,?>> wrapper)
void	InputOutputFormatContainer.FormatUserCodeTable.addInputFormat(OperatorID operatorId, org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.InputFormat<?,?>> wrapper)
InputOutputFormatContainer	InputOutputFormatContainer.addOutputFormat(OperatorID operatorId, org.apache.flink.api.common.io.OutputFormat<?> outputFormat)
InputOutputFormatContainer	InputOutputFormatContainer.addOutputFormat(OperatorID operatorId, org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.OutputFormat<?>> wrapper)
void	InputOutputFormatContainer.FormatUserCodeTable.addOutputFormat(OperatorID operatorId, org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.OutputFormat<?>> wrapper)
InputOutputFormatContainer	InputOutputFormatContainer.addParameters(OperatorID operatorId, String key, String value)
InputOutputFormatContainer	InputOutputFormatContainer.addParameters(OperatorID operatorId, org.apache.flink.configuration.Configuration parameters)
String	InputOutputFormatVertex.getFormatDescription(OperatorID operatorID)
org.apache.flink.configuration.Configuration	InputOutputFormatContainer.getParameters(OperatorID operatorId)
static OperatorInstanceID	OperatorInstanceID.of(int subtaskId, OperatorID operatorID)
void	InputOutputFormatVertex.setFormatDescription(OperatorID operatorID, String formatDescription)

Constructors in org.apache.flink.runtime.jobgraph with parameters of type OperatorID

Constructor	Description
OperatorInstanceID(int subtaskId, OperatorID operatorId)

Uses of OperatorID in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks with parameters of type OperatorID

Modifier and Type	Method	Description
void	AbstractInvokable.dispatchOperatorEvent(OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> event)
void	CoordinatedTask.dispatchOperatorEvent(OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> event)
void	TaskOperatorEventGateway.sendOperatorEventToCoordinator(OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> event)	Sends an event from the operator (identified by the given operator ID) to the operator coordinator (identified by the same ID).
CompletableFuture<CoordinationResponse>	TaskOperatorEventGateway.sendRequestToCoordinator(OperatorID operator, org.apache.flink.util.SerializedValue<CoordinationRequest> request)	Sends a request from current operator to a specified operator coordinator which is identified by the given operator ID and return the response.

Uses of OperatorID in org.apache.flink.runtime.jobmanager.slots

Methods in org.apache.flink.runtime.jobmanager.slots with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	TaskManagerGateway.sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> evt)

Uses of OperatorID in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<CoordinationResponse>	JobMaster.deliverCoordinationRequestToCoordinator(OperatorID operatorId, org.apache.flink.util.SerializedValue<CoordinationRequest> serializedRequest, org.apache.flink.api.common.time.Time timeout)
CompletableFuture<CoordinationResponse>	JobMasterGateway.deliverCoordinationRequestToCoordinator(OperatorID operatorId, org.apache.flink.util.SerializedValue<CoordinationRequest> serializedRequest, org.apache.flink.api.common.time.Time timeout)	Deliver a coordination request to a specified coordinator and return the response.
CompletableFuture<Acknowledge>	JobMaster.sendOperatorEventToCoordinator(ExecutionAttemptID task, OperatorID operatorID, org.apache.flink.util.SerializedValue<OperatorEvent> serializedEvent)
CompletableFuture<Acknowledge>	JobMasterOperatorEventGateway.sendOperatorEventToCoordinator(ExecutionAttemptID task, OperatorID operatorID, org.apache.flink.util.SerializedValue<OperatorEvent> event)
CompletableFuture<Acknowledge>	RpcTaskManagerGateway.sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> evt)
CompletableFuture<CoordinationResponse>	JobMaster.sendRequestToCoordinator(OperatorID operatorID, org.apache.flink.util.SerializedValue<CoordinationRequest> serializedRequest)
CompletableFuture<CoordinationResponse>	JobMasterOperatorEventGateway.sendRequestToCoordinator(OperatorID operatorID, org.apache.flink.util.SerializedValue<CoordinationRequest> request)

Uses of OperatorID in org.apache.flink.runtime.metrics.groups

Methods in org.apache.flink.runtime.metrics.groups with parameters of type OperatorID

Modifier and Type	Method	Description
JobManagerOperatorMetricGroup	JobManagerJobMetricGroup.getOrAddOperator(org.apache.flink.util.AbstractID vertexId, String taskName, OperatorID operatorID, String operatorName)
InternalOperatorMetricGroup	TaskMetricGroup.getOrAddOperator(OperatorID operatorID, String operatorName)
JobManagerOperatorMetricGroup	UnregisteredMetricGroups.UnregisteredJobManagerJobMetricGroup.getOrAddOperator(org.apache.flink.util.AbstractID vertexId, String taskName, OperatorID operatorID, String operatorName)
InternalOperatorMetricGroup	UnregisteredMetricGroups.UnregisteredTaskMetricGroup.getOrAddOperator(OperatorID operatorID, String name)

Constructors in org.apache.flink.runtime.metrics.groups with parameters of type OperatorID

Constructor	Description
JobManagerOperatorMetricGroup(MetricRegistry registry, JobManagerJobMetricGroup parent, org.apache.flink.util.AbstractID vertexId, String taskName, OperatorID operatorID, String operatorName)

Uses of OperatorID in org.apache.flink.runtime.metrics.scope

Methods in org.apache.flink.runtime.metrics.scope with parameters of type OperatorID

Modifier and Type	Method	Description
String[]	JobManagerOperatorScopeFormat.formatScope(JobManagerJobMetricGroup parent, org.apache.flink.util.AbstractID vertexId, String taskName, OperatorID operatorID, String operatorName)
String[]	OperatorScopeFormat.formatScope(TaskMetricGroup parent, OperatorID operatorID, String operatorName)

Uses of OperatorID in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<CoordinationResponse>	MiniCluster.deliverCoordinationRequestToCoordinator(org.apache.flink.api.common.JobID jobId, OperatorID operatorId, org.apache.flink.util.SerializedValue<CoordinationRequest> serializedRequest)
CompletableFuture<CoordinationResponse>	MiniClusterJobClient.sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request)

Uses of OperatorID in org.apache.flink.runtime.operators.coordination

Methods in org.apache.flink.runtime.operators.coordination that return OperatorID

Modifier and Type	Method	Description
OperatorID	OperatorCoordinator.Context.getOperatorId()	Gets the ID of the operator to which the coordinator belongs.
OperatorID	OperatorCoordinator.Provider.getOperatorId()	Gets the ID of the operator to which the coordinator belongs.
OperatorID	RecreateOnResetOperatorCoordinator.Provider.getOperatorId()
OperatorID	OperatorCoordinatorHolder.operatorId()
OperatorID	OperatorInfo.operatorId()

Methods in org.apache.flink.runtime.operators.coordination that return types with arguments of type OperatorID

Modifier and Type	Method	Description
static Collection<OperatorID>	OperatorInfo.getIds(Collection<? extends OperatorInfo> infos)

Methods in org.apache.flink.runtime.operators.coordination with parameters of type OperatorID

Modifier and Type	Method	Description
OperatorEventGateway	OperatorEventDispatcher.getOperatorEventGateway(OperatorID operatorId)	Gets the gateway through which events can be passed to the OperatorCoordinator for the operator identified by the given OperatorID.
void	OperatorEventDispatcher.registerEventHandler(OperatorID operator, OperatorEventHandler handler)	Register a listener that is notified every time an OperatorEvent is sent from the OperatorCoordinator (of the operator with the given OperatorID) to this subtask.
CompletableFuture<CoordinationResponse>	CoordinationRequestGateway.sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request)	Send out a request to a specified coordinator and return the response.

Constructors in org.apache.flink.runtime.operators.coordination with parameters of type OperatorID

Constructor	Description
Provider(OperatorID operatorID)

Uses of OperatorID in org.apache.flink.runtime.rest.messages

Methods in org.apache.flink.runtime.rest.messages that return OperatorID

Modifier and Type	Method	Description
protected OperatorID	OperatorIDPathParameter.convertFromString(String value)

Methods in org.apache.flink.runtime.rest.messages with parameters of type OperatorID

Modifier and Type	Method	Description
protected String	OperatorIDPathParameter.convertToString(OperatorID value)

Uses of OperatorID in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<CoordinationResponse>	DefaultOperatorCoordinatorHandler.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)
CompletableFuture<CoordinationResponse>	OperatorCoordinatorHandler.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)	Deliver coordination request from the client to the coordinator.
CompletableFuture<CoordinationResponse>	SchedulerBase.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)
CompletableFuture<CoordinationResponse>	SchedulerNG.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)	Delivers a coordination request to the OperatorCoordinator with the given OperatorID and returns the coordinator's response.
void	DefaultOperatorCoordinatorHandler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId, OperatorID operatorId, OperatorEvent evt)
void	OperatorCoordinatorHandler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId, OperatorID operatorId, OperatorEvent event)	Delivers an OperatorEvent to a OperatorCoordinator.
void	SchedulerBase.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecutionId, OperatorID operatorId, OperatorEvent evt)
void	SchedulerNG.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecution, OperatorID operator, OperatorEvent evt)	Delivers the given OperatorEvent to the OperatorCoordinator with the given OperatorID.

Uses of OperatorID in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<CoordinationResponse>	AdaptiveScheduler.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)
void	AdaptiveScheduler.deliverOperatorEventToCoordinator(ExecutionAttemptID taskExecution, OperatorID operator, OperatorEvent evt)

Uses of OperatorID in org.apache.flink.runtime.source.coordinator

Constructors in org.apache.flink.runtime.source.coordinator with parameters of type OperatorID

Constructor	Description
SourceCoordinatorProvider(String operatorName, OperatorID operatorID, org.apache.flink.api.connector.source.Source<?,SplitT,?> source, int numWorkerThreads, org.apache.flink.api.common.eventtime.WatermarkAlignmentParams alignmentParams, String coordinatorListeningID)	Construct the SourceCoordinatorProvider.

Uses of OperatorID in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state with parameters of type OperatorID

Modifier and Type	Method	Description
PrioritizedOperatorSubtaskState	TaskStateManager.prioritizedOperatorState(OperatorID operatorID)	Returns means to restore previously reported state of an operator running in the owning task.
PrioritizedOperatorSubtaskState	TaskStateManagerImpl.prioritizedOperatorState(OperatorID operatorID)

Uses of OperatorID in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor with parameters of type OperatorID

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	TaskExecutor.sendOperatorEventToTask(ExecutionAttemptID executionAttemptID, OperatorID operatorId, org.apache.flink.util.SerializedValue<OperatorEvent> evt)
CompletableFuture<Acknowledge>	TaskExecutorGateway.sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> evt)
CompletableFuture<Acknowledge>	TaskExecutorGatewayDecoratorBase.sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> evt)
CompletableFuture<Acknowledge>	TaskExecutorOperatorEventGateway.sendOperatorEventToTask(ExecutionAttemptID task, OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> evt)	Sends an operator event to an operator in a task executed by the Task Manager (Task Executor).

Uses of OperatorID in org.apache.flink.runtime.taskexecutor.rpc

Methods in org.apache.flink.runtime.taskexecutor.rpc with parameters of type OperatorID

Modifier and Type	Method	Description
void	RpcTaskOperatorEventGateway.sendOperatorEventToCoordinator(OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> event)
CompletableFuture<CoordinationResponse>	RpcTaskOperatorEventGateway.sendRequestToCoordinator(OperatorID operator, org.apache.flink.util.SerializedValue<CoordinationRequest> request)

Uses of OperatorID in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager with parameters of type OperatorID

Modifier and Type	Method	Description
void	Task.deliverOperatorEvent(OperatorID operator, org.apache.flink.util.SerializedValue<OperatorEvent> evt)	Dispatches an operator event to the invokable task.

Uses of OperatorID in org.apache.flink.runtime.util

Constructors in org.apache.flink.runtime.util with parameters of type OperatorID

Constructor	Description
OperatorSubtaskDescriptionText(OperatorID operatorId, String operatorClass, int subtaskIndex, int numberOfTasks)

Uses of OperatorID in org.apache.flink.runtime.webmonitor

Methods in org.apache.flink.runtime.webmonitor with parameters of type OperatorID

Modifier and Type	Method	Description
default CompletableFuture<CoordinationResponse>	RestfulGateway.deliverCoordinationRequestToCoordinator(org.apache.flink.api.common.JobID jobId, OperatorID operatorId, org.apache.flink.util.SerializedValue<CoordinationRequest> serializedRequest, org.apache.flink.api.common.time.Time timeout)	Deliver a coordination request to a specified coordinator and return the response.