Interface OutputTypeConfigurable<OUT>
-
- All Known Implementing Classes:
AbstractUdfStreamOperator,AsyncWaitOperator,BatchCoBroadcastWithKeyedOperator,BatchCoBroadcastWithNonKeyedOperator,BatchGroupedReduceOperator,CoBroadcastWithKeyedOperator,CoBroadcastWithNonKeyedOperator,CollectSinkOperator,ContinuousFileReaderOperator,CoProcessOperator,CoStreamFlatMap,CoStreamMap,EvictingWindowOperator,FromElementsFunction,IntervalJoinOperator,KeyedCoProcessOperator,KeyedProcessOperator,LegacyKeyedCoProcessOperator,LegacyKeyedProcessOperator,ProcessOperator,StreamFilter,StreamFlatMap,StreamGroupedReduceOperator,StreamMap,StreamSink,StreamSource,WindowOperator
@PublicEvolving public interface OutputTypeConfigurable<OUT>Stream operators can implement this interface if they need access to the output type information atStreamGraphgeneration. 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.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsetOutputType(org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo, org.apache.flink.api.common.ExecutionConfig executionConfig)Is called by theorg.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer, String, StreamOperator, TypeInformation, TypeInformation, String)method when theStreamGraphis generated.
-
-
-
Method Detail
-
setOutputType
void setOutputType(org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo, org.apache.flink.api.common.ExecutionConfig executionConfig)
Is called by theorg.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer, String, StreamOperator, TypeInformation, TypeInformation, String)method when theStreamGraphis generated. The method is called with the outputTypeInformationwhich is also used for theStreamTaskoutput serializer.- Parameters:
outTypeInfo- Output type information of theStreamTaskexecutionConfig- Execution configuration
-
-