Interface UserFunctionProvider<F extends Function>
-
- All Known Implementing Classes:
AbstractAsyncStateUdfStreamOperator
,AbstractUdfStreamOperator
,AsyncWaitOperator
,BatchCoBroadcastWithKeyedOperator
,BatchCoBroadcastWithNonKeyedOperator
,BatchGroupedReduceOperator
,BroadcastStateBootstrapOperator
,CepOperator
,CoBroadcastWithKeyedOperator
,CoBroadcastWithNonKeyedOperator
,CollectSinkOperator
,CoProcessOperator
,CoStreamFlatMap
,CoStreamMap
,EvictingWindowOperator
,GroupReduceOperator
,IntervalJoinOperator
,KeyedCoProcessOperator
,KeyedCoProcessOperatorWithWatermarkDelay
,KeyedProcessOperator
,KeyedProcessOperator
,KeyedStateBootstrapOperator
,KeyedTwoInputBroadcastProcessOperator
,KeyedTwoInputNonBroadcastProcessOperator
,KeyedTwoOutputProcessOperator
,LegacyKeyedCoProcessOperator
,LegacyKeyedProcessOperator
,MapPartitionOperator
,PartitionAggregateOperator
,PartitionReduceOperator
,ProcessOperator
,ProcessOperator
,SinkOperator
,StateBootstrapOperator
,StreamFilter
,StreamFlatMap
,StreamGroupedReduceOperator
,StreamMap
,StreamSink
,StreamSource
,TwoInputBroadcastProcessOperator
,TwoInputNonBroadcastProcessOperator
,TwoOutputProcessOperator
,UnionStreamOperator
,WindowOperator
@Internal public interface UserFunctionProvider<F extends Function>
The interface with user function.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description F
getUserFunction()
-
-
-
Method Detail
-
getUserFunction
F getUserFunction()
-
-