Uses of Package
org.apache.flink.api.common.functions

Packages that use org.apache.flink.api.common.functions

Package	Description
<Unnamed>
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.io
org.apache.flink.api.common.io.ratelimiting
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.state
org.apache.flink.api.java
org.apache.flink.api.java.functions
org.apache.flink.api.java.io
org.apache.flink.api.java.operators
org.apache.flink.api.java.operators.join
org.apache.flink.api.java.operators.translation
org.apache.flink.api.java.typeutils
org.apache.flink.api.scala.operators
org.apache.flink.batch.tests
org.apache.flink.cep
org.apache.flink.cep.functions
org.apache.flink.cep.functions.adaptors
org.apache.flink.cep.nfa
org.apache.flink.cep.pattern.conditions
org.apache.flink.connector.hbase.sink
org.apache.flink.connector.jdbc.internal
org.apache.flink.connectors.hive.read
org.apache.flink.examples.java.clustering
org.apache.flink.examples.java.graph
org.apache.flink.examples.java.misc
org.apache.flink.examples.java.ml
org.apache.flink.examples.java.relational
org.apache.flink.examples.java.wordcount
org.apache.flink.graph
org.apache.flink.graph.asm.degree.annotate	The degree annotation package provides a collection of edge-centric graph algorithms for counting the vertex degree of directed and undirected graphs.
org.apache.flink.graph.asm.result
org.apache.flink.graph.asm.translate
org.apache.flink.graph.asm.translate.translators
org.apache.flink.graph.gsa
org.apache.flink.graph.utils
org.apache.flink.hadoopcompatibility.mapred
org.apache.flink.ml.common.mapper
org.apache.flink.ml.common.model
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.operators
org.apache.flink.optimizer.plan
org.apache.flink.optimizer.util
org.apache.flink.runtime.broadcast
org.apache.flink.runtime.iterative.task
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.chaining
org.apache.flink.runtime.operators.hash
org.apache.flink.runtime.operators.shipping
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.operators.udf
org.apache.flink.runtime.operators.util
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.sql.tests
org.apache.flink.state.api.functions
org.apache.flink.state.api.input.operator
org.apache.flink.state.api.output
org.apache.flink.state.api.output.partitioner
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.checkpoint
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions
org.apache.flink.streaming.api.functions.aggregation
org.apache.flink.streaming.api.functions.async
org.apache.flink.streaming.api.functions.co
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.source.datagen
org.apache.flink.streaming.api.functions.timestamps
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.connectors.cassandra
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.elasticsearch5
org.apache.flink.streaming.connectors.fs.bucketing
org.apache.flink.streaming.connectors.gcp.pubsub
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.shuffle
org.apache.flink.streaming.connectors.kinesis
org.apache.flink.streaming.connectors.kinesis.internals
org.apache.flink.streaming.connectors.kinesis.util
org.apache.flink.streaming.connectors.nifi
org.apache.flink.streaming.connectors.rabbitmq
org.apache.flink.streaming.connectors.twitter
org.apache.flink.streaming.connectors.wikiedits
org.apache.flink.streaming.examples.iteration
org.apache.flink.streaming.examples.ml
org.apache.flink.streaming.examples.sideoutput
org.apache.flink.streaming.examples.statemachine.generator
org.apache.flink.streaming.examples.twitter
org.apache.flink.streaming.experimental	This package holds classes that are experimental.
org.apache.flink.streaming.kafka.test.base
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.operators.windowing.functions
org.apache.flink.streaming.runtime.partitioner
org.apache.flink.streaming.tests
org.apache.flink.streaming.tests.artificialstate
org.apache.flink.streaming.tests.artificialstate.builder
org.apache.flink.streaming.util
org.apache.flink.streaming.util.functions
org.apache.flink.streaming.util.keys
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.functions
org.apache.flink.table.runtime.arrow.sources
org.apache.flink.table.runtime.collector
org.apache.flink.table.runtime.context
org.apache.flink.table.runtime.dataview
org.apache.flink.table.runtime.functions
org.apache.flink.table.runtime.functions.python
org.apache.flink.table.runtime.functions.python.arrow
org.apache.flink.table.runtime.generated
org.apache.flink.table.runtime.keyselector
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.bundle
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.join.interval
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.join.stream.state
org.apache.flink.table.runtime.operators.match
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.wmassigners
org.apache.flink.table.sinks
org.apache.flink.test
org.apache.flink.walkthrough.common.sink
org.apache.flink.walkthrough.common.source

Classes in org.apache.flink.api.common.functions used by <Unnamed>

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.common.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
AggregateFunction The AggregateFunction is 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.
FoldFunction Deprecated. use AggregateFunction instead
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 the RuntimeContext available 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 and 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 and 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 and 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 and 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 and 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.state

Class and Description
AggregateFunction The AggregateFunction is 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.
FoldFunction Deprecated. use AggregateFunction instead
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java

Class and Description
FilterFunction A filter function is a predicate applied individually to each record.
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.
Partitioner Function to implement a custom partition assignment for keys.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined 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.
RichFlatMapFunction Rich variant of the FlatMapFunction.
RichFunction An base interface for all rich user-defined functions.
RichGroupReduceFunction Rich variant of the GroupReduceFunction.
RichMapPartitionFunction Rich variant of the MapPartitionFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.io

Class and Description
Function The base interface for all user-defined functions.
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.operators

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.
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.
ReduceFunction Base interface for Reduce functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.operators.join

Class and Description
FlatJoinFunction Interface for Join functions.
JoinFunction Interface for Join functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.java.operators.translation

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
CoGroupFunction The interface for CoGroup functions.
CombineFunction Generic interface used for combine functions ("combiners").
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.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce functions.
RichFunction An base interface for all rich user-defined functions.
RichGroupCombineFunction Rich variant of the GroupCombineFunction.
RichGroupReduceFunction Rich variant of the GroupReduceFunction.
RichMapFunction Rich variant of the MapFunction.
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.java.typeutils

Class and Description
AggregateFunction The AggregateFunction is 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.
FoldFunction Deprecated. use AggregateFunction instead
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 the InvalidProgramException, 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.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.api.scala.operators

Class and Description
GroupReduceFunction The interface for group reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.batch.tests

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.cep

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.cep.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.cep.functions.adaptors

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.cep.nfa

Class and 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.cep.pattern.conditions

Class and Description
FilterFunction A filter function is a predicate applied individually to each record.
Function The base interface for all user-defined functions.
IterationRuntimeContext A specialization of the RuntimeContext available in iterative computations of the DataSet API.
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.connector.hbase.sink

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.connector.jdbc.internal

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.connectors.hive.read

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.examples.java.clustering

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.examples.java.graph

Class and Description
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.
GroupReduceFunction The interface for group reduce functions.
JoinFunction Interface for Join functions.
MapFunction Base interface for Map functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.examples.java.misc

Class and Description
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.examples.java.ml

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.examples.java.relational

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
CoGroupFunction The interface for CoGroup functions.
FilterFunction A filter function is a predicate applied individually to each record.
Function The base interface for all user-defined functions.
RichFilterFunction Rich variant of the FilterFunction.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.examples.java.wordcount

Class and Description
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph

Class and Description
FilterFunction A filter function is a predicate applied individually to each record.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph.asm.degree.annotate

Class and Description
Function The base interface for all user-defined functions.
JoinFunction Interface for Join functions.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph.asm.result

Class and Description
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph.asm.translate

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph.asm.translate.translators

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph.gsa

Class and Description
IterationRuntimeContext A specialization of the RuntimeContext available in iterative computations of the DataSet API.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.graph.utils

Class and Description
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.hadoopcompatibility.mapred

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined 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.
RichFlatMapFunction Rich variant of the FlatMapFunction.
RichFunction An base interface for all rich user-defined functions.
RichGroupReduceFunction Rich variant of the GroupReduceFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.ml.common.mapper

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.ml.common.model

Class and 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.optimizer.dag

Class and Description
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.optimizer.dataproperties

Class and Description
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.optimizer.operators

Class and Description
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.optimizer.plan

Class and Description
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.optimizer.util

Class and 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.runtime.broadcast

Class and Description
BroadcastVariableInitializer A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.iterative.task

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.operators

Class and 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.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.operators.chaining

Class and Description
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.runtime.operators.hash

Class and Description
FlatJoinFunction Interface for Join functions.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.operators.shipping

Class and Description
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.operators.sort

Class and Description
FlatJoinFunction Interface for Join functions.
GroupCombineFunction Generic interface used for combine functions ("combiners").

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.operators.udf

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
MapPartitionFunction Interface for "mapPartition" functions.
RichFunction An base interface for all rich user-defined functions.
RichMapPartitionFunction Rich variant of the MapPartitionFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.operators.util

Class and Description
BroadcastVariableInitializer A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.
FlatJoinFunction Interface for Join functions.
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.runtime.taskexecutor

Class and Description
AggregateFunction The AggregateFunction is 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.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.runtime.taskexecutor.rpc

Class and Description
AggregateFunction The AggregateFunction is 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.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.sql.tests

Class and Description
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.state.api.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.state.api.input.operator

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.state.api.output

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
GroupReduceFunction The interface for group reduce functions.
MapPartitionFunction Interface for "mapPartition" functions.
RichFunction An base interface for all rich user-defined functions.
RichGroupReduceFunction Rich variant of the GroupReduceFunction.
RichMapPartitionFunction Rich variant of the MapPartitionFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.state.api.output.partitioner

Class and Description
Function The base interface for all user-defined functions.
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.state.api.runtime

Class and Description
BroadcastVariableInitializer A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.
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.streaming.api.checkpoint

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.datastream

Class and Description
AggregateFunction The AggregateFunction is 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.
FilterFunction A filter function is a predicate applied individually to each record.
FlatJoinFunction Interface for Join functions.
FlatMapFunction Base interface for flatMap functions.
FoldFunction Deprecated. use AggregateFunction instead
JoinFunction Interface for Join functions.
MapFunction Base interface for Map functions.
Partitioner Function to implement a custom partition assignment for keys.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions.aggregation

Class and Description
Function The base interface for all user-defined functions.
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions.async

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.streaming.api.functions.co

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions.sink

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.streaming.api.functions.sink.filesystem

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions.source

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions.source.datagen

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.streaming.api.functions.timestamps

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.api.functions.windowing

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
AggregateFunction The AggregateFunction is 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.
FoldFunction Deprecated. use AggregateFunction instead
Function The base interface for all user-defined 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.streaming.api.operators

Class and Description
BroadcastVariableInitializer A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.
FilterFunction A filter function is a predicate applied individually to each record.
FlatMapFunction Base interface for flatMap functions.
FoldFunction Deprecated. use AggregateFunction instead
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
ReduceFunction Base interface for Reduce 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.streaming.api.operators.collect

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.cassandra

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.elasticsearch

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.streaming.connectors.elasticsearch5

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.fs.bucketing

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.gcp.pubsub

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.kafka

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.kafka.shuffle

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.kinesis

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.streaming.connectors.kinesis.internals

Class and 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.streaming.connectors.kinesis.util

Class and 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.streaming.connectors.nifi

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
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.streaming.connectors.rabbitmq

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.twitter

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.connectors.wikiedits

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.examples.iteration

Class and Description
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.examples.ml

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.examples.sideoutput

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.examples.statemachine.generator

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.examples.twitter

Class and Description
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.experimental

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.kafka.test.base

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.runtime.operators.windowing

Class and Description
ReduceFunction Base interface for Reduce functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.runtime.operators.windowing.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
AggregateFunction The AggregateFunction is 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.
Function The base interface for all user-defined functions.
IterationRuntimeContext A specialization of the RuntimeContext available in iterative computations of the DataSet API.
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.streaming.runtime.partitioner

Class and Description
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.tests

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
RichFlatMapFunction Rich variant of the FlatMapFunction.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.tests.artificialstate

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.tests.artificialstate.builder

Class and Description
JoinFunction Interface for Join functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.util

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.util.functions

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.streaming.util.keys

Class and Description
Function The base interface for all user-defined functions.
Partitioner Function to implement a custom partition assignment for keys.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.examples.java.connectors

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.functions

Class and 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.table.runtime.arrow.sources

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.collector

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.context

Class and 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.table.runtime.dataview

Class and 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.table.runtime.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.functions.python

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.
RichFlatMapFunction Rich variant of the FlatMapFunction.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.functions.python.arrow

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.
RichFlatMapFunction Rich variant of the FlatMapFunction.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.generated

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.keyselector

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.aggregate

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.bundle

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.deduplicate

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.join.interval

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FlatJoinFunction Interface for Join functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.join.lookup

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FlatMapFunction Base interface for flatMap functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.join.stream.state

Class and 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.table.runtime.operators.match

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.over

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.rank

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.runtime.operators.wmassigners

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
RichFunction An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.table.sinks

Class and Description
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.test

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
MapFunction Base interface for Map functions.
RichFunction An base interface for all rich user-defined functions.
RichMapFunction Rich variant of the MapFunction.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.walkthrough.common.sink

Class and Description
Function The base interface for all user-defined functions.

Classes in org.apache.flink.api.common.functions used by org.apache.flink.walkthrough.common.source

Class and Description
Function The base interface for all user-defined functions.