Uses of Package
org.apache.flink.api.common.functions
-
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.functions Class Description AbstractRichFunction An abstract stub implementation for rich user-defined functions.AggregateFunction 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.BroadcastVariableInitializer A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.CoGroupFunction The interface for CoGroup functions.CrossFunction Interface for Cross functions.FilterFunction A filter function is a predicate applied individually to each record.FlatJoinFunction Interface for Join functions.FlatMapFunction Base interface for flatMap functions.Function The base interface for all user-defined functions.GroupCombineFunction Generic interface used for combine functions ("combiners").GroupReduceFunction The interface for group reduce functions.IterationRuntimeContext A specialization of theRuntimeContextavailable in iterative computations of the DataSet API.JoinFunction Interface for Join functions.MapFunction Base interface for Map functions.MapPartitionFunction Interface for "mapPartition" functions.ReduceFunction Base interface for Reduce functions.RichFunction An base interface for all rich user-defined functions.RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.functions.util Class Description AbstractRichFunction An abstract stub implementation for rich user-defined functions.BroadcastVariableInitializer A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.Function The base interface for all user-defined functions.RichFunction An base interface for all rich user-defined functions.RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.io Class Description RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.io.ratelimiting Class Description RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.operators Class Description Function The base interface for all user-defined functions.Partitioner Function to implement a custom partition assignment for keys.RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.operators.base Class Description AbstractRichFunction An abstract stub implementation for rich user-defined functions.CoGroupFunction The interface for CoGroup functions.CrossFunction Interface for Cross functions.FlatJoinFunction Interface for Join functions.FlatMapFunction Base interface for flatMap functions.Function The base interface for all user-defined functions.GroupCombineFunction Generic interface used for combine functions ("combiners").GroupReduceFunction The interface for group reduce functions.MapFunction Base interface for Map functions.MapPartitionFunction Interface for "mapPartition" functions.Partitioner Function to implement a custom partition assignment for keys.ReduceFunction Base interface for Reduce functions.RichFunction An base interface for all rich user-defined functions.RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.serialization Class Description RuntimeContext A RuntimeContext contains information about the context in which functions are executed. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.state Class Description AggregateFunction 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.ReduceFunction Base interface for Reduce functions. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.functions Class Description Function The base interface for all user-defined functions. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.typeutils Class Description AggregateFunction 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.CoGroupFunction The interface for CoGroup functions.CrossFunction Interface for Cross functions.FlatJoinFunction Interface for Join functions.FlatMapFunction Base interface for flatMap functions.Function The base interface for all user-defined functions.GroupCombineFunction Generic interface used for combine functions ("combiners").GroupReduceFunction The interface for group reduce functions.InvalidTypesException A special case of theInvalidProgramException, indicating that the types used in an operation are invalid or inconsistent.JoinFunction Interface for Join functions.MapFunction Base interface for Map functions.MapPartitionFunction Interface for "mapPartition" functions.Partitioner Function to implement a custom partition assignment for keys.