Modifier and Type | Class and Description |
---|---|
class |
RichAggregateFunction<IN,ACC,OUT>
Rich variant of the
AggregateFunction . |
class |
RichCoGroupFunction<IN1,IN2,OUT>
Rich variant of the
CoGroupFunction . |
class |
RichCrossFunction<IN1,IN2,OUT>
Rich variant of the
CrossFunction . |
class |
RichFilterFunction<T>
Rich variant of the
FilterFunction . |
class |
RichFlatJoinFunction<IN1,IN2,OUT>
Rich variant of the
FlatJoinFunction . |
class |
RichFlatMapFunction<IN,OUT>
Rich variant of the
FlatMapFunction . |
class |
RichFoldFunction<O,T>
Deprecated.
use
RichAggregateFunction instead |
class |
RichGroupCombineFunction<IN,OUT>
Rich variant of the
GroupCombineFunction . |
class |
RichGroupReduceFunction<IN,OUT>
Rich variant of the
GroupReduceFunction . |
class |
RichJoinFunction<IN1,IN2,OUT>
Rich variant of the
JoinFunction . |
class |
RichMapFunction<IN,OUT>
Rich variant of the
MapFunction . |
class |
RichMapPartitionFunction<I,O>
Rich variant of the
MapPartitionFunction . |
class |
RichReduceFunction<T>
Rich variant of the
ReduceFunction . |
Modifier and Type | Class and Description |
---|---|
class |
NoOpFunction |
Modifier and Type | Class and Description |
---|---|
static class |
BulkIterationBase.TerminationCriterionMapper<X>
Special Mapper that is added before a termination criterion and is only a container for an special aggregator
|
Modifier and Type | Class and Description |
---|---|
class |
FlatMapIterator<IN,OUT>
A convenience variant of the
RichFlatMapFunction that returns elements through an iterator, rather then
through a collector. |
class |
GroupReduceIterator<IN,OUT> |
class |
SampleInPartition<T>
SampleInPartition wraps the sample logic on the partition side (the first phase of distributed
sample algorithm).
|
class |
SampleWithFraction<T>
A map partition function wrapper for sampling algorithms with fraction, the sample algorithm
takes the partition iterator as input.
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregateOperator.AggregatingUdf<T extends Tuple> |
static class |
JoinOperator.DefaultFlatJoinFunction<T1,T2> |
static class |
JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT> |
static class |
JoinOperator.ProjectFlatJoinFunction<T1,T2,R extends Tuple> |
Modifier and Type | Class and Description |
---|---|
static class |
ScalaAggregateOperator.AggregatingUdf<T extends scala.Product> |
Modifier and Type | Class and Description |
---|---|
static class |
KMeans.SelectNearestCenter
Determines the closest cluster center for a data point.
|
Modifier and Type | Class and Description |
---|---|
static class |
LinearRegression.SubUpdate
Compute a single BGD type update for every parameters.
|
Modifier and Type | Class and Description |
---|---|
static class |
EmptyFieldsCountAccumulator.EmptyFieldFilter
This function filters all incoming tuples that have one or more empty fields.
|
Modifier and Type | Class and Description |
---|---|
class |
RichTranslateFunction<IN,OUT>
Rich variant of the
TranslateFunction . |
Modifier and Type | Class and Description |
---|---|
static class |
VertexCentricIteration.MessageCombinerUdf<K,Message> |
Modifier and Type | Class and Description |
---|---|
class |
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
class |
HadoopReduceCombineFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Reducer and Combiner (mapred API) to a combinable Flink GroupReduceFunction.
|
class |
HadoopReduceFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Reducer (mapred API) to a non-combinable Flink GroupReduceFunction.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonCoGroup<IN1,IN2,OUT>
CoGroupFunction that uses a python script.
|
class |
PythonMapPartition<IN,OUT>
Multi-purpose class, usable by all operations using a python script with one input source and possibly differing
in-/output types.
|
Modifier and Type | Field and Description |
---|---|
protected AbstractRichFunction |
PythonStreamer.function |
Constructor and Description |
---|
PythonDualInputStreamer(AbstractRichFunction function,
Configuration config,
int envID,
int setID,
boolean usesByteArray) |
PythonSingleInputStreamer(AbstractRichFunction function,
Configuration config,
int envID,
int setID,
boolean usesByteArray) |
PythonStreamer(AbstractRichFunction function,
Configuration config,
int envID,
int setID,
boolean usesByteArray,
S sender) |
Modifier and Type | Method and Description |
---|---|
Class<AbstractRichFunction> |
NoOpDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
NoOpDriver.setup(TaskContext<AbstractRichFunction,T> context) |
Modifier and Type | Class and Description |
---|---|
class |
AssignRangeIndex<IN>
This mapPartition function require a DataSet with RangeBoundaries as broadcast input, it
generate Tuple2 which includes range index and record itself as output.
|
class |
RangeBoundaryBuilder<T>
Build RangeBoundaries with input records.
|
Modifier and Type | Class and Description |
---|---|
class |
SpoutWrapper<OUT>
A
SpoutWrapper wraps an IRichSpout in order to execute it within a Flink Streaming program. |
Modifier and Type | Class and Description |
---|---|
class |
ProcessFunction<I,O>
A function that processes elements of a stream.
|
Modifier and Type | Class and Description |
---|---|
class |
RichAsyncFunction<IN,OUT>
Rich variant of the
AsyncFunction . |
Modifier and Type | Class and Description |
---|---|
class |
CoProcessFunction<IN1,IN2,OUT>
A function that processes elements of two streams and produces a single output one.
|
class |
RichCoFlatMapFunction<IN1,IN2,OUT>
A RichCoFlatMapFunction represents a FlatMap transformation with two different input
types.
|
class |
RichCoMapFunction<IN1,IN2,OUT>
A RichCoMapFunction represents a Map transformation with two different input
types.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputFormatSinkFunction<IN>
Simple implementation of the SinkFunction writing tuples in the specified
OutputFormat format.
|
class |
PrintSinkFunction<IN>
Implementation of the SinkFunction writing every tuple to the standard
output or standard error stream.
|
class |
RichSinkFunction<IN>
A
RichFunction version of SinkFunction . |
class |
SocketClientSink<IN>
Socket client that acts as a streaming sink.
|
Modifier and Type | Class and Description |
---|---|
class |
ContinuousFileMonitoringFunction<OUT>
This is the single (non-parallel) monitoring task which takes a
FileInputFormat
and, depending on the FileProcessingMode and the FilePathFilter , it is responsible for:
Monitoring a user-provided path.
Deciding which files should be further read and processed.
Creating the splits corresponding to those files.
Assigning them to downstream tasks for further processing.
|
class |
FromSplittableIteratorFunction<T>
A
SourceFunction that reads elements from an SplittableIterator and emits them. |
class |
InputFormatSourceFunction<OUT>
A
SourceFunction that reads data using an InputFormat . |
class |
MessageAcknowledgingSourceBase<Type,UId>
Abstract base class for data sources that receive elements from a message queue and
acknowledge them back by IDs.
|
class |
MultipleIdsMessageAcknowledgingSourceBase<Type,UId,SessionId>
Abstract base class for data sources that receive elements from a message queue and
acknowledge them back by IDs.
|
class |
RichParallelSourceFunction<OUT>
Base class for implementing a parallel data source.
|
class |
RichSourceFunction<OUT>
Base class for implementing a parallel data source that has access to context information
(via
getRuntimeContext() ) and additional life-cycle methods
(open(org.apache.flink.configuration.Configuration) and close() . |
class |
StatefulSequenceSource
A stateful streaming source that emits each number from a given interval exactly once,
possibly in parallel.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R>
|
class |
AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R>
|
class |
FoldApplyAllWindowFunction<W extends Window,T,ACC,R>
Deprecated.
will be removed in a future version
|
class |
FoldApplyProcessAllWindowFunction<W extends Window,T,ACC,R>
Deprecated.
will be removed in a future version
|
class |
FoldApplyProcessWindowFunction<K,W extends Window,T,ACC,R>
Deprecated.
will be removed in a future version
|
class |
FoldApplyWindowFunction<K,W extends Window,T,ACC,R>
Deprecated.
will be removed in a future version
|
class |
ProcessAllWindowFunction<IN,OUT,W extends Window>
Base abstract class for functions that are evaluated over non-keyed windows using a context
for retrieving extra information.
|
class |
ProcessWindowFunction<IN,OUT,KEY,W extends Window>
Base abstract class for functions that are evaluated over keyed (grouped) windows using a context
for retrieving extra information.
|
class |
ReduceApplyAllWindowFunction<W extends Window,T,R>
Internal
AllWindowFunction that is used for implementing a fold on a window configuration
that only allows AllWindowFunction and cannot directly execute a ReduceFunction . |
class |
ReduceApplyProcessAllWindowFunction<W extends Window,T,R>
Internal
ProcessAllWindowFunction that is used for implementing a fold on a window
configuration that only allows AllWindowFunction and cannot directly execute a
ReduceFunction . |
class |
ReduceApplyProcessWindowFunction<K,W extends Window,T,R>
Internal
ProcessWindowFunction that is used for implementing a fold on a window
configuration that only allows AllWindowFunction and cannot directly execute a
ReduceFunction . |
class |
ReduceApplyWindowFunction<K,W extends Window,T,R>
Internal
WindowFunction that is used for implementing a fold on a window configuration
that only allows WindowFunction and cannot directly execute a ReduceFunction . |
class |
RichAllWindowFunction<IN,OUT,W extends Window>
A
RichFunction version of
AllWindowFunction . |
class |
RichProcessAllWindowFunction<IN,OUT,W extends Window>
Deprecated.
use
ProcessAllWindowFunction instead |
class |
RichProcessWindowFunction<IN,OUT,KEY,W extends Window>
Deprecated.
use
ProcessWindowFunction instead |
class |
RichWindowFunction<IN,OUT,KEY,W extends Window>
Rich variant of the
WindowFunction . |
Modifier and Type | Class and Description |
---|---|
class |
ScalaAllWindowFunctionWrapper<IN,OUT,W extends Window>
A wrapper function that exposes a Scala WindowFunction as a JavaWindow function.
|
class |
ScalaProcessAllWindowFunctionWrapper<IN,OUT,W extends Window>
A wrapper function that exposes a Scala ProcessWindowFunction
as a ProcessWindowFunction function.
|
class |
ScalaProcessWindowFunctionWrapper<IN,OUT,KEY,W extends Window>
A wrapper function that exposes a Scala ProcessWindowFunction
as a ProcessWindowFunction function.
|
class |
ScalaWindowFunctionWrapper<IN,OUT,KEY,W extends Window>
A wrapper function that exposes a Scala WindowFunction as a JavaWindow function.
|
Modifier and Type | Class and Description |
---|---|
class |
CassandraPojoSink<IN>
Flink Sink to save data into a Cassandra cluster using
Mapper,
which it uses annotations from
com.datastax.driver.mapping.annotations.
|
class |
CassandraSinkBase<IN,V>
CassandraSinkBase is the common abstract class of
CassandraPojoSink and CassandraTupleSink . |
class |
CassandraTupleSink<IN extends Tuple>
Flink Sink to save data into a Cassandra cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchSink<T>
Elasticsearch 1.x sink that requests multiple
ActionRequests
against a cluster for each incoming element. |
class |
ElasticsearchSinkBase<T>
Base class for all Flink Elasticsearch Sinks.
|
Modifier and Type | Class and Description |
---|---|
class |
RollingSink<T>
Deprecated.
use
BucketingSink instead. |
Modifier and Type | Class and Description |
---|---|
class |
BucketingSink<T>
Sink that emits its input elements to
FileSystem files within
buckets. |
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaConsumer010<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.10.x.
|
class |
FlinkKafkaConsumer08<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.8.x.
|
class |
FlinkKafkaConsumer081<T>
Deprecated.
|
class |
FlinkKafkaConsumer082<T>
Deprecated.
|
class |
FlinkKafkaConsumer09<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.9.x.
|
class |
FlinkKafkaConsumerBase<T>
Base class of all Flink Kafka Consumer data sources.
|
class |
FlinkKafkaProducer<IN>
Deprecated.
Use
FlinkKafkaProducer08 . |
class |
FlinkKafkaProducer08<IN>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducer09<IN>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducerBase<IN>
Flink Sink to produce data into a Kafka topic.
|
Modifier and Type | Class and Description |
---|---|
class |
NiFiSink<T>
A sink that delivers data to Apache NiFi using the NiFi Site-to-Site client.
|
class |
NiFiSource
A source that pulls data from Apache NiFi using the NiFi Site-to-Site client.
|
Modifier and Type | Class and Description |
---|---|
class |
RMQSink<IN>
A Sink for publishing data into RabbitMQ
|
class |
RMQSource<OUT>
RabbitMQ source (consumer) which reads from a queue and acknowledges messages on checkpoints.
|
Modifier and Type | Class and Description |
---|---|
class |
TwitterSource
Implementation of
SourceFunction specialized to emit tweets from
Twitter. |
Modifier and Type | Class and Description |
---|---|
class |
WikipediaEditsSource |
Modifier and Type | Class and Description |
---|---|
static class |
SideOutputExample.Tokenizer
Implements the string tokenizer that splits sentences into words as a
user-defined FlatMapFunction.
|
Modifier and Type | Class and Description |
---|---|
class |
InternalAggregateProcessAllWindowFunction<T,ACC,V,R,W extends Window>
Internal window function for wrapping a
ProcessAllWindowFunction that takes an
Iterable and an AggregateFunction . |
class |
InternalAggregateProcessWindowFunction<T,ACC,V,R,K,W extends Window>
Internal window function for wrapping a
ProcessWindowFunction that takes an
Iterable and an AggregateFunction . |
class |
InternalIterableAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping an
AllWindowFunction that takes an Iterable
when the window state also is an Iterable . |
class |
InternalIterableProcessAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable
when the window state also is an Iterable . |
class |
InternalIterableProcessWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable
when the window state also is an Iterable . |
class |
InternalIterableWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
WindowFunction that takes an Iterable
when the window state also is an Iterable . |
class |
InternalSingleValueAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping an
AllWindowFunction that takes an Iterable
when the window state is a single value. |
class |
InternalSingleValueProcessAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable
when the window state is a single value. |
class |
InternalSingleValueProcessWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable
when the window state is a single value. |
class |
InternalSingleValueWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
WindowFunction that takes an Iterable
when the window state is a single value. |
Modifier and Type | Class and Description |
---|---|
class |
CorrelateFlatMapRunner<IN,OUT> |
class |
CountPartitionFunction<IN> |
class |
CRowCorrelateProcessRunner
A CorrelateProcessRunner with
CRow input and CRow output. |
class |
CRowInputJavaTupleOutputMapRunner
Convert
CRow to a JTuple2 |
class |
CRowInputMapRunner<OUT>
MapRunner with
CRow input. |
class |
CRowInputScalaTupleOutputMapRunner
Convert
CRow to a Tuple2 |
class |
CRowOutputMapRunner
MapRunner with
CRow output. |
class |
CRowProcessRunner
ProcessRunner with
CRow input and CRow output. |
class |
FlatJoinRunner<IN1,IN2,OUT> |
class |
FlatMapRunner |
class |
LimitFilterFunction<T> |
class |
MapJoinLeftRunner<IN1,IN2,OUT> |
class |
MapJoinRightRunner<IN1,IN2,OUT> |
class |
MapRunner<IN,OUT> |
class |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
DataSetAggFunction
RichGroupReduceFunction to compute aggregates that do not support pre-aggregation for batch
(DataSet) queries. |
class |
DataSetFinalAggFunction
RichGroupReduceFunction to compute the final result of a pre-aggregated aggregation
for batch (DataSet) queries. |
class |
DataSetPreAggFunction
GroupCombineFunction and MapPartitionFunction to compute pre-aggregates for batch
(DataSet) queries. |
class |
DataSetSessionWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetSessionWindowAggregatePreProcessor
This wraps the aggregate logic inside of
GroupCombineOperator . |
class |
DataSetSlideTimeWindowAggFlatMapFunction
It is used for sliding windows on batch for time-windows.
|
class |
DataSetSlideTimeWindowAggReduceGroupFunction
It is used for sliding windows on batch for time-windows.
|
class |
DataSetSlideWindowAggReduceCombineFunction
Wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . |
class |
DataSetSlideWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetTumbleCountWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetTumbleTimeWindowAggReduceCombineFunction
It wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . |
class |
DataSetTumbleTimeWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetWindowAggMapFunction
This map function only works for windows on batch tables.
|
class |
GroupAggProcessFunction
Aggregate Function used for the groupby (without window) aggregate
|
class |
IncrementalAggregateAllTimeWindowFunction
Computes the final aggregate value from incrementally computed aggregates.
|
class |
IncrementalAggregateAllWindowFunction<W extends Window>
Computes the final aggregate value from incrementally computed aggregates.
|
class |
IncrementalAggregateTimeWindowFunction
Computes the final aggregate value from incrementally computed aggreagtes.
|
class |
IncrementalAggregateWindowFunction<W extends Window>
Computes the final aggregate value from incrementally computed aggreagtes.
|
class |
ProcessFunctionWithCleanupState<IN,OUT> |
class |
ProcTimeBoundedRangeOver
Process Function used for the aggregate in bounded proc-time OVER window
DataStream |
class |
ProcTimeBoundedRowsOver
Process Function for ROW clause processing-time bounded OVER window
|
class |
ProcTimeUnboundedOver
Process Function for processing-time unbounded OVER window
|
class |
RowTimeBoundedRangeOver
Process Function for RANGE clause event-time bounded OVER window
|
class |
RowTimeBoundedRowsOver
Process Function for ROWS clause event-time bounded OVER window
|
class |
RowTimeUnboundedOver
A ProcessFunction to support unbounded event-time over-window
|
class |
RowTimeUnboundedRangeOver
A ProcessFunction to support unbounded RANGE window.
|
class |
RowTimeUnboundedRowsOver
A ProcessFunction to support unbounded ROWS window.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.