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

Packages that use StreamConfig

Package	Description
org.apache.flink.cep.operator
org.apache.flink.state.api.output
org.apache.flink.state.api.output.operators
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.sortpartition
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.checkpointing
org.apache.flink.streaming.runtime.operators.asyncprocessing
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.multipleinput

Uses of StreamConfig in org.apache.flink.cep.operator

Methods in org.apache.flink.cep.operator with parameters of type StreamConfig

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

Uses of StreamConfig in org.apache.flink.state.api.output

Constructors in org.apache.flink.state.api.output with parameters of type StreamConfig

Constructor and Description
BootstrapStreamTaskRunner(StreamConfig streamConfig, int maxParallelism) Create a new BootstrapStreamTaskRunner.
BoundedOneInputStreamTaskRunner(StreamConfig streamConfig, int maxParallelism, Timestamper<IN> timestamper) Deprecated. Create a new BoundedOneInputStreamTaskRunner.

Uses of StreamConfig in org.apache.flink.state.api.output.operators

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

Modifier and Type	Method and Description
void	StateBootstrapWrapperOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<TaggedOperatorSubtaskState>> 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 and 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 and 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 and Description
protected StreamConfig	AbstractStreamOperatorV2.config
protected StreamConfig	AbstractStreamOperator.config

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

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

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

Modifier and Type	Method and Description
static <OUT,OP extends StreamOperator<OUT>> Tuple2<OP,Optional<ProcessingTimeService>>	StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output, OperatorEventDispatcher operatorEventDispatcher) Creates a new operator using a factory and makes sure that all special factory traits are properly handled.
void	SourceOperator.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	AbstractUdfStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
void	AbstractStreamOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

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

Constructor and Description
StreamOperatorParameters(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output, Supplier<ProcessingTimeService> processingTimeServiceFactory, OperatorEventDispatcher operatorEventDispatcher, MailboxExecutor mailboxExecutor)

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 and Description
void	AsyncWaitOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)

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

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

Modifier and Type	Method and Description
void	SortPartitionOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<INPUT>> output)
void	KeyedSortPartitionOperator.setup(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<INPUT>> 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 and Description
static <IN1,IN2> StreamMultipleInputProcessor	StreamTwoInputProcessorFactory.create(TaskInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, IOManager ioManager, MemoryManager memoryManager, TaskIOMetricGroup taskIOMetricGroup, TwoInputStreamOperator<IN1,IN2,?> streamOperator, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, OperatorChain<?,?> operatorChain, StreamConfig streamConfig, Configuration taskManagerConfig, Configuration jobConfig, ExecutionConfig executionConfig, ClassLoader userClassloader, Counter numRecordsIn, InflightDataRescalingDescriptor inflightDataRescalingDescriptor, Function<Integer,StreamPartitioner<?>> gatePartitioners, TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
static StreamMultipleInputProcessor	StreamMultipleInputProcessorFactory.create(TaskInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, StreamConfig.InputConfig[] configuredInputs, IOManager ioManager, MemoryManager memoryManager, TaskIOMetricGroup ioMetricGroup, Counter mainOperatorRecordsIn, MultipleInputStreamOperator<?> mainOperator, WatermarkGauge[] inputWatermarkGauges, StreamConfig streamConfig, Configuration taskManagerConfig, Configuration jobConfig, ExecutionConfig executionConfig, ClassLoader userClassloader, OperatorChain<?,?> operatorChain, InflightDataRescalingDescriptor inflightDataRescalingDescriptor, Function<Integer,StreamPartitioner<?>> gatePartitioners, 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 and Description
static CheckpointBarrierHandler	InputProcessorUtil.createCheckpointBarrierHandler(CheckpointableTask toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, String taskName, List<IndexedInputGate>[] inputGates, List<StreamTaskSourceInput<?>> sourceInputs, MailboxExecutor mailboxExecutor, TimerService timerService)
static CheckpointedInputGate[]	InputProcessorUtil.createCheckpointedMultipleInputGate(MailboxExecutor mailboxExecutor, List<IndexedInputGate>[] inputGates, TaskIOMetricGroup taskIOMetricGroup, CheckpointBarrierHandler barrierHandler, StreamConfig config)

Uses of StreamConfig in org.apache.flink.streaming.runtime.operators.asyncprocessing

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

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

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 and 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 and Description
StreamConfig	StreamTask.getConfiguration()

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

Modifier and Type	Method and Description
static <OUT> RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>>	StreamTask.createRecordWriterDelegate(StreamConfig configuration, Environment environment)

Uses of StreamConfig in org.apache.flink.table.runtime.operators.join

Methods in org.apache.flink.table.runtime.operators.join with parameters of type StreamConfig

Modifier and Type	Method and Description
void	SortMergeJoinFunction.open(boolean adaptiveHashJoin, StreamTask<?,?> taskContainer, StreamConfig operatorConfig, StreamRecordCollector collector, long totalMemory, RuntimeContext runtimeContext, OperatorMetricGroup operatorMetricGroup)

Uses of StreamConfig in org.apache.flink.table.runtime.operators.multipleinput

Methods in org.apache.flink.table.runtime.operators.multipleinput that return StreamConfig

Modifier and Type	Method and Description
protected StreamConfig	BatchMultipleInputStreamOperator.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
protected StreamConfig	MultipleInputStreamOperatorBase.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)