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.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.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.OpenContext TheOpenContextinterface provides necessary information required by theRichFunctionwhen it is opened.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.OpenContext TheOpenContextinterface provides necessary information required by theRichFunctionwhen it is opened.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 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.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.OpenContext TheOpenContextinterface provides necessary information required by theRichFunctionwhen it is opened.Partitioner Function to implement a custom partition assignment for keys.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 SerializerFactory A factory forTypeSerializerimplementations. -
Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.typeutils Class Description CoGroupFunction The interface for CoGroup functions.CrossFunction Interface for Cross functions.FlatJoinFunction Interface for Join functions.FlatMapFunction Base interface for flatMap 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.