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

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

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.io
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
org.apache.flink.api.scala.operators
org.apache.flink.api.table.codegen
org.apache.flink.api.table.runtime
org.apache.flink.cep
org.apache.flink.cep.nfa
org.apache.flink.cep.pattern
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.examples.scala.graph
org.apache.flink.graph
org.apache.flink.graph.examples
org.apache.flink.graph.gsa
org.apache.flink.graph.library
org.apache.flink.graph.scala
org.apache.flink.graph.utils
org.apache.flink.hadoopcompatibility.mapred
org.apache.flink.ml.common
org.apache.flink.ml.recommendation
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.python.api.functions
org.apache.flink.python.api.functions.util
org.apache.flink.python.api.streaming.data
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.state
org.apache.flink.storm.util
org.apache.flink.storm.wordcount
org.apache.flink.storm.wrappers
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.co
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.scala
org.apache.flink.streaming.api.scala.function
org.apache.flink.streaming.api.scala.function.util
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.flume
org.apache.flink.streaming.connectors.fs
org.apache.flink.streaming.connectors.json
org.apache.flink.streaming.connectors.kafka
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.join
org.apache.flink.streaming.examples.ml
org.apache.flink.streaming.examples.twitter
org.apache.flink.streaming.examples.windowing
org.apache.flink.streaming.examples.wordcount
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.buffers
org.apache.flink.streaming.runtime.operators.windowing.functions
org.apache.flink.streaming.runtime.partitioner
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.util.keys

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.
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 Base interface for Fold 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
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.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
FoldFunction Base interface for Fold functions.
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
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.
RichFlatJoinFunction Rich variant of the FlatJoinFunction.
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.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.
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
CoGroupFunction The interface for CoGroup functions.
CrossFunction Interface for Cross functions.
FlatJoinFunction Interface for Join functions.
FlatMapFunction Base interface for flatMap functions.
FoldFunction Base interface for Fold 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 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

Class and Description
CoGroupFunction The interface for CoGroup functions.
CrossFunction Interface for Cross functions.
FlatJoinFunction Interface for Join functions.
GroupCombineFunction Generic interface used for combine functions ("combiners").
GroupReduceFunction The interface for group reduce functions.
JoinFunction Interface for Join 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.scala.operators

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

Class and Description
FilterFunction A filter function is a predicate applied individually to each record.
FlatJoinFunction Interface for Join functions.
MapFunction Base interface for Map functions.

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

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FilterFunction A filter function is a predicate applied individually to each record.
FlatJoinFunction Interface for Join 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.
RichFilterFunction Rich variant of the FilterFunction.
RichFlatJoinFunction Rich variant of the FlatJoinFunction.
RichFunction An base interface for all rich user-defined functions.
RichGroupReduceFunction Rich variant of the GroupReduceFunction.
RichMapFunction Rich variant of the MapFunction.

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

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.cep.nfa

Class and Description
FilterFunction A filter function is a predicate applied individually to each record.

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

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

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.examples.scala.graph

Class and Description
Function The base interface for all user-defined functions.
GroupReduceFunction The interface for group reduce 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.examples

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

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

Class and Description
IterationRuntimeContext

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

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.graph.scala

Class and Description
MapFunction Base interface for Map functions.

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.

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

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.ml.recommendation

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.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.python.api.functions

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
CoGroupFunction The interface for CoGroup functions.
Function The base interface for all user-defined functions.
MapPartitionFunction Interface for "mapPartition" functions.
RichCoGroupFunction Rich variant of the CoGroupFunction.
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.python.api.functions.util

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

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

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.

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.

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.state

Class and Description
FoldFunction Base interface for Fold functions.
ReduceFunction Base interface for Reduce functions.

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

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.storm.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.storm.wrappers

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.
StoppableFunction Must be implemented by stoppable functions, eg, source functions of streaming jobs.

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

Class and Description
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 Base interface for Fold functions.
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
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.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.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.

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.windowing

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
FoldFunction Base interface for Fold functions.
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.

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 Base interface for Fold functions.
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.
StoppableFunction Must be implemented by stoppable functions, eg, source functions of streaming jobs.

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

Class and Description
CoGroupFunction The interface for CoGroup functions.
FlatJoinFunction Interface for Join functions.
Function The base interface for all user-defined functions.
JoinFunction Interface for Join functions.

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

Class and Description
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.scala.function.util

Class and Description
FoldFunction Base interface for Fold functions.
Function The base interface for all user-defined functions.
IterationRuntimeContext
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.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.flume

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

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.json

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.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.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.
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.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.join

Class and Description
AbstractRichFunction An abstract stub implementation for rich user-defined functions.
Function The base interface for all user-defined functions.
JoinFunction Interface for Join 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.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.twitter

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.streaming.examples.windowing

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.examples.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.streaming.runtime.operators.windowing

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.runtime.operators.windowing.buffers

Class and Description
FoldFunction Base interface for Fold functions.
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
Function The base interface for all user-defined functions.
IterationRuntimeContext
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.runtime.tasks

Class and Description
StoppableFunction Must be implemented by stoppable functions, eg, source functions of streaming jobs.

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.