Uses of Class
org.apache.flink.streaming.api.operators.StreamOperatorParameters
-
-
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 Description <O extends StreamOperator<OUT>>
OContinuousFileReaderOperatorFactory. 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 Description <T extends StreamOperator<OUT>>
TCoordinatedOperatorFactory. createStreamOperator(StreamOperatorParameters<OUT> parameters)The implementation should return an instance ofOperatorEventHandler.<T extends StreamOperator<OUT>>
TSimpleOperatorFactory. createStreamOperator(StreamOperatorParameters<OUT> parameters)<T extends StreamOperator<OUT>>
TSourceOperatorFactory. createStreamOperator(StreamOperatorParameters<OUT> parameters)<T extends StreamOperator<OUT>>
TStreamOperatorFactory. createStreamOperator(StreamOperatorParameters<OUT> parameters)Create the operator.Constructors in org.apache.flink.streaming.api.operators with parameters of type StreamOperatorParameters Constructor 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 Description <T extends StreamOperator<OUT>>
TAsyncWaitOperatorFactory. 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 Description <T extends StreamOperator<Object>>
TCollectSinkOperatorFactory. 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 Description <T extends StreamOperator<CommittableMessage<CommT>>>
TCommitterOperatorFactory. createStreamOperator(StreamOperatorParameters<CommittableMessage<CommT>> parameters)<T extends StreamOperator<CommittableMessage<CommT>>>
TSinkWriterOperatorFactory. createStreamOperator(StreamOperatorParameters<CommittableMessage<CommT>> parameters)
-