Uses of Interface
org.apache.flink.api.common.functions.Function
-
Packages that use Function Package Description org.apache.flink.api.common.functions org.apache.flink.api.common.watermark org.apache.flink.api.java.functions -
-
Uses of Function in org.apache.flink.api.common.functions
Subinterfaces of Function in org.apache.flink.api.common.functions Modifier and Type Interface Description interfaceAggregateFunction<IN,ACC,OUT>TheAggregateFunctionis a flexible aggregation function, characterized by the following features: The aggregates may use different types for input values, intermediate aggregates, and result type, to support a wide range of aggregation types.interfaceReduceFunction<T>Base interface for Reduce functions. -
Uses of Function in org.apache.flink.api.common.watermark
Subinterfaces of Function in org.apache.flink.api.common.watermark Modifier and Type Interface Description interfaceWatermarkCombinationFunctionTheWatermarkCombinationFunctiondefines the watermark's comparison/combination semantics among multiple input channels.Classes in org.apache.flink.api.common.watermark that implement Function Modifier and Type Class Description static classWatermarkCombinationFunction.BoolWatermarkCombinationFunctionTheWatermarkCombinationFunction.BoolWatermarkCombinationFunctionenum defines the combination semantics for boolean watermarks.static classWatermarkCombinationFunction.NumericWatermarkCombinationFunctionTheWatermarkCombinationFunction.NumericWatermarkCombinationFunctionenum defines the combination semantics for numeric watermarks. -
Uses of Function in org.apache.flink.api.java.functions
Subinterfaces of Function in org.apache.flink.api.java.functions Modifier and Type Interface Description interfaceKeySelector<IN,KEY>TheKeySelectorallows to use deterministic objects for operations such as reduce, reduceGroup, join, coGroup, etc.
-