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
An
AbstractRichFunction that does nothing. |
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>
Base class that simplifies reducing all values provided as
Iterable . |
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 |
JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT>
Wrapper around
JoinFunction . |
Modifier and Type | Class and Description |
---|---|
class |
KeyExtractingMapper<T,K>
Mapper that extracts keys.
|
class |
KeyRemovingMapper<T,K>
Mapper that removes keys.
|
static class |
PlanFilterOperator.FlatMapFilter<T> |
class |
RichCombineToGroupCombineWrapper<IN,OUT,F extends RichGroupReduceFunction<IN,OUT> & CombineFunction<IN,IN>>
A wrapper the wraps a function that implements both
CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime. |
class |
TupleLeftUnwrappingJoiner<I1,I2,OUT,K>
Joiner that unwraps values from the left set before applying the join operation.
|
class |
TupleRightUnwrappingJoiner<I1,I2,OUT,K>
Joiner that unwraps values from the right set before applying the join operation.
|
class |
TupleUnwrappingJoiner<I1,I2,OUT,K>
Joiner that unwraps both values before applying the join operation.
|
class |
TwoKeyExtractingMapper<T,K1,K2>
Mapper that extracts two keys of a value.
|
class |
WrappingFunction<T extends Function>
Wrapper around
Function . |
Modifier and Type | Class and Description |
---|---|
class |
BlockingIncrementingMapFunction
A map function that increments values by one.
|
Modifier and Type | Class and Description |
---|---|
class |
RichPatternFlatSelectFunction<IN,OUT>
Rich variant of the
PatternFlatSelectFunction . |
class |
RichPatternSelectFunction<IN,OUT>
Rich variant of the
PatternSelectFunction . |
Modifier and Type | Class and Description |
---|---|
class |
PatternProcessFunction<IN,OUT>
It is called with a map of detected events which are identified by their names.
|
Modifier and Type | Class and Description |
---|---|
class |
PatternFlatSelectAdapter<IN,OUT>
Adapter that expresses
PatternFlatSelectFunction with PatternProcessFunction . |
class |
PatternSelectAdapter<IN,OUT>
Adapter that expresses
PatternSelectFunction with PatternProcessFunction . |
class |
PatternTimeoutFlatSelectAdapter<IN,OUT,T>
Adapter that expresses combination of
PatternFlatSelectFunction and PatternTimeoutFlatSelectAdapter with PatternProcessFunction . |
class |
PatternTimeoutSelectAdapter<IN,OUT,T>
Adapter that expresses combination of
PatternSelectFunction and PatternTimeoutFlatSelectAdapter with PatternProcessFunction . |
Modifier and Type | Class and Description |
---|---|
class |
HBaseSinkFunction<T>
The sink function for HBase.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericJdbcSinkFunction<T>
A generic SinkFunction for JDBC.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveContinuousMonitoringFunction
This is the single (non-parallel) monitoring task which takes a
HiveTableInputFormat , it
is responsible for:
Monitoring partitions of hive meta store. |
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 |
---|---|
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 |
ModelMapperAdapter
A class that adapts a
ModelMapper to a Flink RichMapFunction so the model can be
loaded in a Flink job. |
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 |
BroadcastStateBootstrapFunction<IN>
Interface for writing elements to broadcast state.
|
class |
KeyedStateBootstrapFunction<K,IN>
A function that writes keyed state to a new operator.
|
class |
KeyedStateReaderFunction<K,OUT>
A function that processes keys from a restored operator
|
class |
StateBootstrapFunction<IN>
Interface for writing elements to operator state.
|
Modifier and Type | Class and Description |
---|---|
class |
BoundedOneInputStreamTaskRunner<IN>
A
RichMapPartitionFunction that serves as the runtime for a BoundedStreamTask . |
class |
OperatorSubtaskStateReducer
A reducer that aggregates all
OperatorSubtaskState 's for a particular operator into a
single OperatorState . |
Modifier and Type | Class and Description |
---|---|
class |
KeyedProcessFunction<K,I,O>
A keyed function that processes elements of a stream.
|
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 |
BaseBroadcastProcessFunction
The base class containing the functionality available to all broadcast process function.
|
class |
BroadcastProcessFunction<IN1,IN2,OUT>
A function to be applied to a
BroadcastConnectedStream that
connects BroadcastStream , i.e. |
class |
CoProcessFunction<IN1,IN2,OUT>
A function that processes elements of two streams and produces a single output one.
|
class |
KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>
A function to be applied to a
BroadcastConnectedStream that
connects BroadcastStream , i.e. |
class |
KeyedCoProcessFunction<K,IN1,IN2,OUT>
A function that processes elements of two keyed streams and produces a single output one.
|
class |
ProcessJoinFunction<IN1,IN2,OUT>
A function that processes two joined elements 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>
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
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.
|
class |
TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>
This is a recommended base class for all of the
SinkFunction that intend to implement
exactly-once semantic. |
Modifier and Type | Class and Description |
---|---|
class |
StreamingFileSink<IN>
Sink that emits its input elements to
FileSystem files within buckets. |
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. |
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 |
DataGeneratorSource<T>
A data generator source that abstract data generator.
|
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 |
CollectSinkFunction<IN>
A sink function that collects query results and sends them back to the client.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCassandraTupleSink<IN>
Abstract sink to write tuple-like values into a Cassandra cluster.
|
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 |
CassandraRowSink
A SinkFunction to write Row records into a Cassandra table.
|
class |
CassandraScalaProductSink<IN extends scala.Product>
Sink to write scala tuples and case classes into a Cassandra cluster.
|
class |
CassandraSinkBase<IN,V>
CassandraSinkBase is the common abstract class of
CassandraPojoSink and CassandraTupleSink . |
class |
CassandraTupleSink<IN extends Tuple>
Sink to write Flink
Tuple s into a Cassandra cluster. |
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchSinkBase<T,C extends AutoCloseable>
Base class for all Flink Elasticsearch Sinks.
|
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchSink<T>
Elasticsearch 5.x sink that requests multiple
ActionRequests against a
cluster for each incoming element. |
Modifier and Type | Class and Description |
---|---|
class |
BucketingSink<T>
Deprecated.
Please use the
StreamingFileSink
instead. |
Modifier and Type | Class and Description |
---|---|
class |
PubSubSink<IN>
A sink function that outputs to PubSub.
|
class |
PubSubSource<OUT>
PubSub Source, this Source will consume PubSub messages from a subscription and Acknowledge them
on the next checkpoint.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaConsumer<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache
Kafka.
|
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 |
FlinkKafkaConsumer011<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache
Kafka 0.11.x.
|
class |
FlinkKafkaConsumerBase<T>
Base class of all Flink Kafka Consumer data sources.
|
class |
FlinkKafkaProducer<IN>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducer010<T>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducer011<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 |
FlinkKafkaShuffleConsumer<T>
Flink Kafka Shuffle Consumer Function.
|
class |
FlinkKafkaShuffleProducer<IN,KEY>
Flink Kafka Shuffle Producer Function.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkDynamoDBStreamsConsumer<T>
Consume events from DynamoDB streams.
|
class |
FlinkKinesisConsumer<T>
The Flink Kinesis Consumer is an exactly-once parallel streaming data source that subscribes to
multiple AWS Kinesis streams within the same AWS service region, and can handle resharding of
streams.
|
class |
FlinkKinesisProducer<OUT>
The FlinkKinesisProducer allows to produce from a Flink DataStream into Kinesis.
|
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
This class is a SourceFunction that reads
WikipediaEditEvent instances from the IRC
channel #en.wikipedia . |
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 |
EventsGeneratorSource
A event stream source that generates the events on the fly.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectSink<IN>
A specialized data sink to be used by DataStreamUtils.collect().
|
Modifier and Type | Class and Description |
---|---|
class |
RollingAdditionMapper
A
RichMapFunction that continuously outputs the current total frequency count of a key. |
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 |
---|---|
static class |
BucketingSinkTestProgram.SubtractingMapper
Subtracts the timestamp of the previous element from the current element.
|
class |
FailureMapper<T>
This mapper simulates failure by throwing exceptions.
|
class |
SemanticsCheckMapper
This mapper validates exactly-once and at-least-once semantics in connection with
SequenceGeneratorSource . |
class |
SequenceGeneratorSource
This source function generates a sequence of long values per key.
|
class |
SlidingWindowCheckMapper
This mapper validates sliding event time window.
|
Modifier and Type | Class and Description |
---|---|
class |
ArtificalOperatorStateMapper<IN,OUT>
A self-verifiable
RichMapFunction used to verify checkpointing and restore semantics for
various kinds of operator state. |
class |
ArtificialKeyedStateMapper<IN,OUT>
A generic, stateful
MapFunction that allows specifying what states to maintain based on a
provided list of ArtificialStateBuilder s. |
Modifier and Type | Class and Description |
---|---|
class |
SocketSourceFunction
The
SocketSourceFunction opens a socket and consumes bytes. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractArrowSourceFunction<OUT>
An Arrow
SourceFunction which takes the serialized arrow record batch data as input. |
class |
ArrowSourceFunction
An Arrow
SourceFunction which takes RowData as the type of the produced records. |
class |
RowArrowSourceFunction
An Arrow
SourceFunction which takes Row as the type of the produced records. |
Modifier and Type | Class and Description |
---|---|
class |
TableFunctionCollector<T>
The basic implementation of collector for
TableFunction . |
class |
TableFunctionResultFuture<T>
The basic implementation of collector for
ResultFuture in table joining. |
class |
WrappingCollector<T>
A
Collector that wraps another collector. |
Modifier and Type | Class and Description |
---|---|
class |
KeyedProcessFunctionWithCleanupState<K,IN,OUT>
A function that processes elements of a stream, and could cleanup state.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonScalarFunctionFlatMap
The abstract base
RichFlatMapFunction used to invoke Python ScalarFunction
functions for the old planner. |
class |
AbstractPythonStatelessFunctionFlatMap
Base Python stateless
RichFlatMapFunction used to invoke Python stateless functions for
the old planner. |
class |
PythonScalarFunctionFlatMap
The
RichFlatMapFunction used to invoke Python ScalarFunction functions for the
old planner. |
class |
PythonTableFunctionFlatMap
The
RichFlatMapFunction used to invoke Python TableFunction functions for the old
planner. |
Modifier and Type | Class and Description |
---|---|
class |
ArrowPythonScalarFunctionFlatMap
The
RichFlatMapFunction used to invoke Arrow Python ScalarFunction functions for
the old planner. |
Modifier and Type | Class and Description |
---|---|
class |
WatermarkGenerator
The
WatermarkGenerator is used to generate watermark based the input elements. |
Modifier and Type | Class and Description |
---|---|
class |
GroupAggFunction
Aggregate Function used for the groupby (without window) aggregate.
|
class |
GroupTableAggFunction
Aggregate Function used for the groupby (without window) table aggregate.
|
Modifier and Type | Class and Description |
---|---|
class |
DeduplicateKeepFirstRowFunction
This function is used to deduplicate on keys and keeps only first row.
|
class |
DeduplicateKeepLastRowFunction
This function is used to deduplicate on keys and keeps only last row.
|
Modifier and Type | Class and Description |
---|---|
class |
ProcTimeIntervalJoin
The function to execute processing time interval stream inner-join.
|
class |
RowTimeIntervalJoin
The function to execute row(event) time interval stream inner-join.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncLookupJoinRunner
The async join runner to lookup the dimension table.
|
class |
AsyncLookupJoinWithCalcRunner
The async join runner with an additional calculate function on the dimension table.
|
class |
LookupJoinRunner
The join runner to lookup the dimension table.
|
class |
LookupJoinWithCalcRunner
The join runner with an additional calculate function on the dimension table.
|
Modifier and Type | Class and Description |
---|---|
class |
PatternProcessFunctionRunner
A
PatternProcessFunction wrapper to delegate invocation to the code generated PatternProcessFunction . |
class |
RowtimeProcessFunction
ProcessFunction to copy a timestamp from a
RowData field into the StreamRecord . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRowTimeUnboundedPrecedingOver<K>
A basic implementation to support unbounded event-time over-window.
|
class |
ProcTimeRangeBoundedPrecedingFunction<K>
Process Function used for the aggregate in bounded proc-time OVER window.
|
class |
ProcTimeRowsBoundedPrecedingFunction<K>
Process Function for ROW clause processing-time bounded OVER window.
|
class |
ProcTimeUnboundedPrecedingFunction<K>
Process Function for processing-time unbounded OVER window.
|
class |
RowTimeRangeBoundedPrecedingFunction<K>
Process Function for RANGE clause event-time bounded OVER window.
|
class |
RowTimeRangeUnboundedPrecedingFunction<K>
A ProcessFunction to support unbounded RANGE window.
|
class |
RowTimeRowsBoundedPrecedingFunction<K>
Process Function for ROWS clause event-time bounded OVER window.
|
class |
RowTimeRowsUnboundedPrecedingFunction<K>
A ProcessFunction to support unbounded ROWS window.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractTopNFunction
Base class for TopN Function.
|
class |
AppendOnlyTopNFunction
A TopN function could handle insert-only stream.
|
class |
RetractableTopNFunction
A TopN function could handle updating stream.
|
class |
UpdatableTopNFunction
A TopN function could handle updating stream.
|
Modifier and Type | Class and Description |
---|---|
class |
BoundedOutOfOrderWatermarkGenerator
A watermark generator for rowtime attributes which are out-of-order by a bounded time interval.
|
Modifier and Type | Class and Description |
---|---|
static class |
StatefulStreamingJob.MySource
Stub source that emits one record per second.
|
static class |
StatefulStreamingJob.MyStatefulFunction
A stateful
RichMapFunction that keeps the required types of state. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.