org.apache.flink.api.common.functions

Interface Function

All Superinterfaces:

Serializable

All Known Subinterfaces:

AllWindowFunction<IN,OUT,W>, AllWindowFunction<IN,OUT,W>, AssignerWithPeriodicWatermarks<T>, AssignerWithPunctuatedWatermarks<T>, CoFlatMapFunction<IN1,IN2,OUT>, CoGroupFunction<IN1,IN2,O>, CoMapFunction<IN1,IN2,OUT>, CombineFunction<IN,OUT>, CrossFunction<IN1,IN2,OUT>, EdgeJoinFunction<EV,T>, EdgesFunction<K,EV,O>, EdgesFunctionWithVertexValue<K,VV,EV,O>, FilterFunction<T>, FlatJoinFunction<IN1,IN2,OUT>, FlatMapFunction<T,O>, FoldFunction<O,T>, GroupCombineFunction<IN,OUT>, GroupReduceFunction<T,O>, IndexRequestBuilder<T>, JoinFunction<IN1,IN2,OUT>, KeySelector<IN,KEY>, MapFunction<T,O>, MapPartitionFunction<T,O>, NeighborsFunction<K,VV,EV,O>, NeighborsFunctionWithVertexValue<K,VV,EV,O>, NiFiDataPacketBuilder<T>, ParallelSourceFunction<OUT>, PatternFlatSelectFunction<IN,OUT>, PatternSelectFunction<IN,OUT>, ReduceEdgesFunction<EV>, ReduceFunction<T>, ReduceNeighborsFunction<VV>, RichFunction, SinkFunction<IN>, SourceFunction<T>, StatefulFunction<I,O,S>, TimestampAssigner<T>, TimestampExtractor<T>, VertexJoinFunction<VV,T>, WindowFunction<IN,OUT,KEY,W>, WindowFunction<IN,OUT,KEY,W>

All Known Implementing Classes:

AbstractRichFunction, AggregateOperator.AggregatingUdf, AggregationFunction, AndFilterFunction, AscendingTimestampExtractor, AssignRangeIndex, BulkIterationBase.TerminationCriterionMapper, CombineToGroupCombineWrapper, CommunityDetection.AddScoreToVertexValuesMapper, CommunityDetection.RemoveScoreFromVertexValuesMapper, ComparableAggregator, ConnectedComponents.ComponentIdFilter, ConnectedComponents.DuplicateValue, ConnectedComponents.NeighborWithComponentIDJoin, ConnectedComponents.UndirectEdge, ConnectorSource, CrossOperator.DefaultCrossFunction, CrossOperator.ProjectCrossFunction, DiscardingSink, DistinctOperator.DistinctFunction, EdgesFunction, EdgesFunctionWithVertexValue, EdgeToTuple3Map, EdgeToTuple3Map, ElasticsearchSink, EmptyFieldsCountAccumulator.EmptyFieldFilter, EnumTriangles.TriadBuilder, EnumTriangles.TupleEdgeConverter, ExpressionAggregateFunction, ExpressionFilterFunction, ExpressionJoinFunction, ExpressionSelectFunction, FileMonitoringFunction, FileReadFunction, FileSourceFunction, FirstReducer, FlatMapIterator, FlinkKafkaConsumer08, FlinkKafkaConsumer081, FlinkKafkaConsumer082, FlinkKafkaConsumer09, FlinkKafkaConsumerBase, FlinkKafkaProducer, FlinkKafkaProducer08, FlinkKafkaProducer09, FlinkKafkaProducerBase, FlumeSink, FoldApplyAllWindowFunction, FoldApplyWindowFunction, FormattingMapper, FromElementsFunction, FromIteratorFunction, FromSplittableIteratorFunction, GroupedProcessingTimeWindowExample.FirstFieldKeyExtractor, GroupedProcessingTimeWindowExample.SummingReducer, GroupedProcessingTimeWindowExample.SummingWindowFunction, GroupReduceIterator, GSASingleSourceShortestPaths.InitVerticesMapper, HadoopMapFunction, HadoopReduceCombineFunction, HadoopReduceFunction, IdentityGroupReduce, IncrementalLearningSkeleton.FiniteNewDataSource, IncrementalLearningSkeleton.FiniteTrainingDataSource, IncrementalLearningSkeleton.LinearTimestamp, IncrementalLearningSkeleton.PartialModelBuilder, IncrementalLearningSkeleton.Predictor, IngestionTimeExtractor, InternalIterableWindowFunction, InternalSingleValueWindowFunction, InternalWindowFunction, IterateExample.InputMap, IterateExample.OutputMap, IterateExample.Step, JoinOperator.DefaultFlatJoinFunction, JoinOperator.DefaultJoin.WrappingFlatJoinFunction, JoinOperator.ProjectFlatJoinFunction, JSONParseFlatMap, KeyDiscarder, KeyExtractingMapper, KeyRemovingMapper, KeySelectorUtil.ArrayKeySelector, KeySelectorUtil.ComparableKeySelector, KeySelectorUtil.OneKeySelector, KeySelectorWithType, KMeans.CentroidAccumulator, KMeans.CentroidAverager, KMeans.CountAppender, KMeans.SelectNearestCenter, KMeans.SelectNearestCenter, LinearRegression.SubUpdate, LinearRegression.SubUpdate, LinearRegression.Update, LinearRegression.UpdateAccumulator, MessageAcknowledgingSourceBase, MultipleIdsMessageAcknowledgingSourceBase, MusicProfiles.CreateSimilarUserEdges, MusicProfiles.ExtractMismatchSongIds, MusicProfiles.FilterOutMismatches, MusicProfiles.FilterSongNodes, MusicProfiles.GetTopSongPerUser, NeighborsFunction, NeighborsFunctionWithVertexValue, NestedKeyDiscarder, NiFiSink, NiFiSource, NoExpressionAggregateFunction, NoOpFunction, NullValueEdgeMapper, OutputFormatSinkFunction, PageRank.BuildOutgoingEdgeList, PageRank.Dampener, PageRank.EpsilonFilter, PageRank.JoinVertexWithEdgesMatch, PageRank.RankAssigner, PassThroughAllWindowFunction, PassThroughWindowFunction, PiEstimation.Sampler, PiEstimation.SumReducer, PlanBothUnwrappingCoGroupOperator.TupleBothUnwrappingCoGrouper, PlanFilterOperator.FlatMapFilter, PlanLeftUnwrappingCoGroupOperator.TupleLeftUnwrappingCoGrouper, PlanProjectOperator.MapProjector, PlanRightUnwrappingCoGroupOperator.TupleRightUnwrappingCoGrouper, PlanUnwrappingGroupCombineOperator.TupleUnwrappingGroupCombiner, PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer, PlanUnwrappingReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer, PlanUnwrappingReduceOperator.ReduceWrapper, PlanUnwrappingSortedGroupCombineOperator.TupleUnwrappingGroupReducer, PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer, PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer, PojoExample.Tokenizer, PrintSinkFunction, PythonCoGroup, PythonMapPartition, RangeBoundaryBuilder, ReduceApplyAllWindowFunction, ReduceApplyWindowFunction, ReduceIterableAllWindowFunction, ReduceIterableWindowFunction, RemoveRangeIndex, RichAllWindowFunction, RichAllWindowFunction, RichCoFlatMapFunction, RichCoGroupFunction, RichCoMapFunction, RichCrossFunction, RichFilterFunction, RichFlatJoinFunction, RichFlatMapFunction, RichFoldFunction, RichGroupCombineFunction, RichGroupReduceFunction, RichJoinFunction, RichMapFunction, RichMapPartitionFunction, RichParallelSourceFunction, RichReduceFunction, RichSinkFunction, RichSourceFunction, RichWindowFunction, RichWindowFunction, RMQSink, RMQSource, RollingSink, SampleInCoordinator, SampleInPartition, SampleWithFraction, ScalaAggregateOperator.AggregatingUdf, ScalaAllWindowFunction, ScalaAllWindowFunctionWrapper, ScalaFoldFunction, ScalaReduceFunction, ScalaWindowFunction, ScalaWindowFunctionWrapper, SelectByMaxFunction, SelectByMinFunction, SerializerMap, SingleSourceShortestPaths.InitVerticesMapper, SocketClientSink, SocketTextStreamFunction, SplitStreamMapper, SpoutSourceWordCount.Tokenizer, SpoutWrapper, StatefulSequenceSource, StringDeserializerMap, StringTupleDeserializerMap, SubtypeFilterFunction, SumAggregator, Tuple2ToVertexMap, Tuple2ToVertexMap, Tuple3ToEdgeMap, Tuple3ToEdgeMap, TupleLeftUnwrappingJoiner, TupleRightUnwrappingJoiner, TupleUnwrappingJoiner, TwitterFilterSource, TwitterSource, TwitterStream.SelectEnglishAndTokenizeFlatMap, TwitterStreaming.SelectDataFlatMap, TwitterStreaming.TwitterSink, TwitterTopology.SelectLanguageFlatMap, TwoKeyExtractingMapper, VertexToTuple2Map, VertexToTuple2Map, WebLogAnalysis.AntiJoinVisits, WebLogAnalysis.FilterByRank, WebLogAnalysis.FilterDocByKeyWords, WebLogAnalysis.FilterVisitsByDate, WikipediaEditsSource, WindowJoin.GradeSource, WindowJoin.MyJoinFunction, WindowJoin.MySourceMap, WindowJoin.SalarySource, WordCount.Tokenizer, WordCount.Tokenizer, WordCountPojo.Tokenizer, WrappingFunction, WriteSinkFunction, WriteSinkFunctionByMillis

@Public
public interface Function
extends Serializable

The base interface for all user-defined functions.

This interface is empty in order to allow extending interfaces to be SAM (single abstract method) interfaces that can be implemented via Java 8 lambdas.