Uses of Class
org.apache.flink.streaming.api.operators.StreamOperatorParameters

Packages that use StreamOperatorParameters

Package	Description
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.multipleinput
org.apache.flink.table.runtime.operators.wmassigners

Uses of StreamOperatorParameters in org.apache.flink.connector.file.sink.compactor.operator

Methods in org.apache.flink.connector.file.sink.compactor.operator with parameters of type StreamOperatorParameters

Modifier and Type	Method and Description
<T extends StreamOperator<CommittableMessage<FileSinkCommittable>>> T	CompactorOperatorFactory.createStreamOperator(StreamOperatorParameters<CommittableMessage<FileSinkCommittable>> parameters)
<T extends StreamOperator<CommittableMessage<FileSinkCommittable>>> T	CompactorOperatorStateHandlerFactory.createStreamOperator(StreamOperatorParameters<CommittableMessage<FileSinkCommittable>> parameters)
<T extends StreamOperator<CompactorRequest>> T	CompactCoordinatorFactory.createStreamOperator(StreamOperatorParameters<CompactorRequest> parameters)
<T extends StreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>> T	CompactCoordinatorStateHandlerFactory.createStreamOperator(StreamOperatorParameters<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters)

Uses of StreamOperatorParameters in org.apache.flink.streaming.api.functions.source

Methods in org.apache.flink.streaming.api.functions.source with parameters of type StreamOperatorParameters

Modifier and Type	Method and Description
<O extends StreamOperator<OUT>> O	ContinuousFileReaderOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)

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

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

Modifier and Type	Method and Description
<T extends StreamOperator<OUT>> T	CoordinatedOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) The implementation should return an instance of OperatorEventHandler.
<T extends StreamOperator<OUT>> T	SimpleOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)
<T extends StreamOperator<OUT>> T	SourceOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)
<T extends StreamOperator<OUT>> T	StreamOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters) Create the operator.

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

Constructor and Description
AbstractStreamOperatorV2(StreamOperatorParameters<OUT> parameters, int numberOfInputs)

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

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

Modifier and Type	Method and Description
<T extends StreamOperator<OUT>> T	AsyncWaitOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)

Uses of StreamOperatorParameters in org.apache.flink.streaming.api.operators.collect

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

Modifier and Type	Method and Description
<T extends StreamOperator<Object>> T	CollectSinkOperatorFactory.createStreamOperator(StreamOperatorParameters<Object> parameters)

Uses of StreamOperatorParameters in org.apache.flink.streaming.runtime.operators.sink

Methods in org.apache.flink.streaming.runtime.operators.sink with parameters of type StreamOperatorParameters

Modifier and Type	Method and Description
<T extends StreamOperator<CommittableMessage<CommT>>> T	CommitterOperatorFactory.createStreamOperator(StreamOperatorParameters<CommittableMessage<CommT>> parameters)
<T extends StreamOperator<CommittableMessage<CommT>>> T	SinkWriterOperatorFactory.createStreamOperator(StreamOperatorParameters<CommittableMessage<CommT>> parameters)

Uses of StreamOperatorParameters in org.apache.flink.table.runtime.operators

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

Modifier and Type	Method and Description
<T extends StreamOperator<OUT>> T	CodeGenOperatorFactory.createStreamOperator(StreamOperatorParameters<OUT> parameters)

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

Methods in org.apache.flink.table.runtime.operators.multipleinput with parameters of type StreamOperatorParameters

Modifier and Type	Method and Description
void	TableOperatorWrapper.createOperator(StreamOperatorParameters<RowData> parameters)
protected StreamConfig	BatchMultipleInputStreamOperator.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
protected StreamConfig	MultipleInputStreamOperatorBase.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
<T extends StreamOperator<RowData>> T	BatchMultipleInputStreamOperatorFactory.createStreamOperator(StreamOperatorParameters<RowData> parameters)

Constructors in org.apache.flink.table.runtime.operators.multipleinput with parameters of type StreamOperatorParameters

Constructor and Description
BatchMultipleInputStreamOperator(StreamOperatorParameters<RowData> parameters, List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrapper, TableOperatorWrapper<?> tailWrapper)
MultipleInputStreamOperatorBase(StreamOperatorParameters<RowData> parameters, List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrappers, TableOperatorWrapper<?> tailWrapper)

Uses of StreamOperatorParameters in org.apache.flink.table.runtime.operators.wmassigners

Methods in org.apache.flink.table.runtime.operators.wmassigners with parameters of type StreamOperatorParameters

Modifier and Type	Method and Description
StreamOperator	WatermarkAssignerOperatorFactory.createStreamOperator(StreamOperatorParameters initializer)