OUT
- The output type of the operator@Internal public class SimpleOperatorFactory<OUT> extends Object implements StreamOperatorFactory<OUT>
StreamOperator
.Modifier | Constructor and Description |
---|---|
protected |
SimpleOperatorFactory(StreamOperator<OUT> operator) |
protected SimpleOperatorFactory(StreamOperator<OUT> operator)
public static <OUT> SimpleOperatorFactory<OUT> of(StreamOperator<OUT> operator)
public StreamOperator<OUT> getOperator()
public <T extends StreamOperator<OUT>> T createStreamOperator(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<OUT>
public void setChainingStrategy(ChainingStrategy strategy)
StreamOperatorFactory
setChainingStrategy
in interface StreamOperatorFactory<OUT>
public ChainingStrategy getChainingStrategy()
StreamOperatorFactory
getChainingStrategy
in interface StreamOperatorFactory<OUT>
public boolean isStreamSource()
StreamOperatorFactory
StreamSource
.isStreamSource
in interface StreamOperatorFactory<OUT>
public boolean isOperatorSelectiveReading()
StreamOperatorFactory
isOperatorSelectiveReading
in interface StreamOperatorFactory<OUT>
public boolean isOutputTypeConfigurable()
StreamOperatorFactory
StreamGraph
generation. This can be useful for cases where the output type is specified by the returns
method and, thus, after the stream operator has been created.isOutputTypeConfigurable
in interface StreamOperatorFactory<OUT>
public void setOutputType(TypeInformation<OUT> type, ExecutionConfig executionConfig)
StreamOperatorFactory
StreamGraph.addOperator(java.lang.Integer, java.lang.String, java.lang.String, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<IN>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>, java.lang.String)
method when the StreamGraph
is
generated. The method is called with the output TypeInformation
which is also used
for the StreamTask
output serializer.setOutputType
in interface StreamOperatorFactory<OUT>
type
- Output type information of the StreamTask
executionConfig
- Execution configurationpublic boolean isInputTypeConfigurable()
StreamOperatorFactory
isInputTypeConfigurable
in interface StreamOperatorFactory<OUT>
public void setInputType(TypeInformation<?> type, ExecutionConfig executionConfig)
StreamOperatorFactory
StreamGraph.addOperator(java.lang.Integer, java.lang.String, java.lang.String, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<IN>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>, java.lang.String)
method when the StreamGraph
is
generated.setInputType
in interface StreamOperatorFactory<OUT>
type
- The data type of the input.executionConfig
- The execution config for this parallel execution.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.