Uses of Class
org.apache.flink.streaming.api.graph.StreamConfig

Packages that use StreamConfig

Package	Description
org.apache.flink.streaming.api.connector.sink2
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.checkpointing
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of StreamConfig in org.apache.flink.streaming.api.connector.sink2

Methods in org.apache.flink.streaming.api.connector.sink2 with parameters of type StreamConfig

Modifier and Type	Method	Description
void	GlobalCommitterOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<Void>> output)

Uses of StreamConfig in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph that return types with arguments of type StreamConfig

Modifier and Type	Method	Description
CompletableFuture<StreamConfig>	StreamConfig.getSerializationFuture()
Map<Integer,StreamConfig>	StreamConfig.getTransitiveChainedTaskConfigs(ClassLoader cl)
Map<Integer,StreamConfig>	StreamConfig.getTransitiveChainedTaskConfigsWithSelf(ClassLoader cl)
CompletableFuture<StreamConfig>	StreamConfig.triggerSerializationAndReturnFuture(Executor ioExecutor)	Trigger the object config serialization and return the completable future.

Method parameters in org.apache.flink.streaming.api.graph with type arguments of type StreamConfig

Modifier and Type	Method	Description
void	StreamConfig.setAndSerializeTransitiveChainedTaskConfigs(Map<Integer,StreamConfig> chainedTaskConfigs)
void	StreamConfig.setTransitiveChainedTaskConfigs(Map<Integer,StreamConfig> chainedTaskConfigs)

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

Fields in org.apache.flink.streaming.api.operators declared as StreamConfig

Modifier and Type	Field	Description
protected StreamConfig	AbstractStreamOperator.config
protected StreamConfig	AbstractStreamOperatorV2.config

Methods in org.apache.flink.streaming.api.operators that return StreamConfig

Modifier and Type	Method	Description
StreamConfig	AbstractStreamOperator.getOperatorConfig()
StreamConfig	AbstractStreamOperatorV2.getOperatorConfig()
StreamConfig	StreamOperatorParameters.getStreamConfig()

Methods in org.apache.flink.streaming.api.operators with parameters of type StreamConfig

Modifier and Type	Method	Description
static <OUT,OP extends StreamOperator<OUT>> org.apache.flink.api.java.tuple.Tuple2<OP,Optional<ProcessingTimeService>>	StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output, org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher operatorEventDispatcher)	Creates a new operator using a factory and makes sure that all special factory traits are properly handled.
void	AbstractStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
void	AbstractUdfStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
void	SetupableStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)	Deprecated. Initializes the operator.
void	SourceOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

Constructors in org.apache.flink.streaming.api.operators with parameters of type StreamConfig

Constructor	Description
StreamOperatorParameters(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output, Supplier<ProcessingTimeService> processingTimeServiceFactory, org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher operatorEventDispatcher)

Uses of StreamConfig in org.apache.flink.streaming.api.operators.async

Methods in org.apache.flink.streaming.api.operators.async with parameters of type StreamConfig

Modifier and Type	Method	Description
void	AsyncWaitOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

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

Methods in org.apache.flink.streaming.runtime.io with parameters of type StreamConfig

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, 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, Function<Integer,StreamPartitioner<?>> gatePartitioners, org.apache.flink.api.common.TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)

Uses of StreamConfig in org.apache.flink.streaming.runtime.io.checkpointing

Methods in org.apache.flink.streaming.runtime.io.checkpointing with parameters of type StreamConfig

Modifier and Type	Method	Description
static CheckpointBarrierHandler	InputProcessorUtil.createCheckpointBarrierHandler(org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, String taskName, List<org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate>[] inputGates, List<StreamTaskSourceInput<?>> sourceInputs, org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor, TimerService timerService)
static CheckpointedInputGate[]	InputProcessorUtil.createCheckpointedMultipleInputGate(org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor, List<org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate>[] inputGates, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup taskIOMetricGroup, CheckpointBarrierHandler barrierHandler, StreamConfig config)

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

Fields in org.apache.flink.streaming.runtime.tasks declared as StreamConfig

Modifier and Type	Field	Description
protected StreamConfig	StreamTask.configuration	The configuration of this streaming task.

Methods in org.apache.flink.streaming.runtime.tasks that return StreamConfig

Modifier and Type	Method	Description
StreamConfig	StreamTask.getConfiguration()

Methods in org.apache.flink.streaming.runtime.tasks with parameters of type StreamConfig

Modifier and Type	Method	Description
static <OUT> org.apache.flink.runtime.io.network.api.writer.RecordWriterDelegate<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>>	StreamTask.createRecordWriterDelegate(StreamConfig configuration, org.apache.flink.runtime.execution.Environment environment)