Uses of Class org.apache.flink.streaming.runtime.tasks.OperatorChain (Flink : Streaming Java 1.19.3-cp1 API)

Packages that use OperatorChain
Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of OperatorChain in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type OperatorChain
Modifier and Type	Method	Description
`void`	StreamSource.`run(Object lockingObject, Output<StreamRecord<OUT>> collector, OperatorChain<?,?> operatorChain)`	Deprecated.
`void`	StreamSource.`run(Object lockingObject, OperatorChain<?,?> operatorChain)`	Deprecated.

Uses of OperatorChain in org.apache.flink.streaming.runtime.io

Methods in org.apache.flink.streaming.runtime.io with parameters of type OperatorChain
Modifier and Type	Method	Description
`static StreamMultipleInputProcessor`	StreamMultipleInputProcessorFactory.create(org.apache.flink.runtime.jobgraph.tasks.TaskInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, StreamConfig.InputConfig[] configuredInputs, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.runtime.memory.MemoryManager memoryManager, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup ioMetricGroup, org.apache.flink.metrics.Counter mainOperatorRecordsIn, MultipleInputStreamOperator<?> mainOperator, WatermarkGauge[] inputWatermarkGauges, StreamConfig streamConfig, org.apache.flink.configuration.Configuration taskManagerConfig, org.apache.flink.configuration.Configuration jobConfig, org.apache.flink.api.common.ExecutionConfig executionConfig, ClassLoader userClassloader, OperatorChain<?,?> operatorChain, org.apache.flink.runtime.checkpoint.InflightDataRescalingDescriptor inflightDataRescalingDescriptor, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners, org.apache.flink.api.common.TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
`static <IN1,IN2> StreamMultipleInputProcessor`	StreamTwoInputProcessorFactory.create(org.apache.flink.runtime.jobgraph.tasks.TaskInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.runtime.memory.MemoryManager memoryManager, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup taskIOMetricGroup, TwoInputStreamOperator<IN1,IN2,?> streamOperator, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, OperatorChain<?,?> operatorChain, StreamConfig streamConfig, org.apache.flink.configuration.Configuration taskManagerConfig, org.apache.flink.configuration.Configuration jobConfig, org.apache.flink.api.common.ExecutionConfig executionConfig, ClassLoader userClassloader, org.apache.flink.metrics.Counter numRecordsIn, org.apache.flink.runtime.checkpoint.InflightDataRescalingDescriptor inflightDataRescalingDescriptor, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners, org.apache.flink.api.common.TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)

Uses of OperatorChain in org.apache.flink.streaming.runtime.tasks

Subclasses of OperatorChain in org.apache.flink.streaming.runtime.tasks
Modifier and Type	Class	Description
`class`	`FinishedOperatorChain<OUT,OP extends StreamOperator<OUT>>`	The `OperatorChain` that is used for restoring tasks that are `TaskStateManager.isTaskDeployedAsFinished()`.
`class`	`RegularOperatorChain<OUT,OP extends StreamOperator<OUT>>`	A regular non finished on restore `OperatorChain`.

Fields in org.apache.flink.streaming.runtime.tasks declared as OperatorChain
Modifier and Type	Field	Description
`protected OperatorChain<OUT,OP>`	StreamTask.`operatorChain`	The chain of operators executed by this task.

Methods in org.apache.flink.streaming.runtime.tasks with parameters of type OperatorChain
Modifier and Type	Method	Description
`void`	SubtaskCheckpointCoordinator.`abortCheckpointOnBarrier(long checkpointId, org.apache.flink.runtime.checkpoint.CheckpointException cause, OperatorChain<?,?> operatorChain)`
`void`	SubtaskCheckpointCoordinator.`checkpointState(org.apache.flink.runtime.checkpoint.CheckpointMetaData checkpointMetaData, org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions, org.apache.flink.runtime.checkpoint.CheckpointMetricsBuilder checkpointMetrics, OperatorChain<?,?> operatorChain, boolean isTaskFinished, java.util.function.Supplier<Boolean> isRunning)`	Must be called after `SubtaskCheckpointCoordinator.initInputsCheckpoint(long, CheckpointOptions)`.
`void`	SubtaskCheckpointCoordinator.`notifyCheckpointAborted(long checkpointId, OperatorChain<?,?> operatorChain, java.util.function.Supplier<Boolean> isRunning)`	Notified on the task side once a distributed checkpoint has been aborted.
`void`	SubtaskCheckpointCoordinator.`notifyCheckpointComplete(long checkpointId, OperatorChain<?,?> operatorChain, java.util.function.Supplier<Boolean> isRunning)`	Notified on the task side once a distributed checkpoint has been completed.
`void`	SubtaskCheckpointCoordinator.`notifyCheckpointSubsumed(long checkpointId, OperatorChain<?,?> operatorChain, java.util.function.Supplier<Boolean> isRunning)`	Notified on the task side once a distributed checkpoint has been subsumed.