org.apache.flink.streaming.api.operators

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

Modifier and Type	Method and Description
F	getUserFunction()

Method Detail

getUserFunction

F getUserFunction()