Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.storm.wrappers | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.query | |
org.apache.flink.streaming.api.functions.source | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.async | |
org.apache.flink.streaming.api.transformations | |
org.apache.flink.streaming.connectors.cassandra | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyedCEPPatternOperator<IN,KEY,OUT,F extends Function>
Abstract CEP pattern operator for a keyed input stream.
|
class |
FlatSelectCepOperator<IN,KEY,OUT>
Version of
AbstractKeyedCEPPatternOperator that applies given PatternFlatSelectFunction to fully matched event patterns. |
class |
FlatSelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>
Version of
AbstractKeyedCEPPatternOperator that applies given PatternFlatSelectFunction to fully
matched event patterns and PatternFlatTimeoutFunction to timed out ones. |
class |
SelectCepOperator<IN,KEY,OUT>
Version of
AbstractKeyedCEPPatternOperator that applies given PatternSelectFunction to fully matched event patterns. |
class |
SelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>
Version of
AbstractKeyedCEPPatternOperator that applies given PatternSelectFunction to fully
matched event patterns and PatternTimeoutFunction to timed out ones. |
Modifier and Type | Class and Description |
---|---|
class |
BoltWrapper<IN,OUT>
A
BoltWrapper wraps an IRichBolt in order to execute the Storm bolt within a Flink Streaming program. |
class |
MergedInputsBoltWrapper<IN,OUT>
|
Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
DataStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperator<T,R> operator)
Method for passing user defined operators along with the type
information that will transform the DataStream.
|
<R> SingleOutputStreamOperator<R> |
KeyedStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperator<T,R> operator) |
Modifier and Type | Class and Description |
---|---|
class |
QueryableAppendingStateOperator<IN>
Internal operator handling queryable AppendingState instances.
|
class |
QueryableValueStateOperator<IN>
Internal operator handling queryable ValueState instances.
|
Modifier and Type | Class and Description |
---|---|
class |
ContinuousFileReaderOperator<OUT>
The operator that reads the
splits received from the preceding
ContinuousFileMonitoringFunction . |
Modifier and Type | Class and Description |
---|---|
class |
KeyedProcessOperator<K,IN,OUT>
A
StreamOperator for executing KeyedProcessFunctions . |
class |
LegacyKeyedProcessOperator<K,IN,OUT>
Deprecated.
Replaced by
KeyedProcessOperator which takes KeyedProcessFunction |
class |
ProcessOperator<IN,OUT>
A
StreamOperator for executing
ProcessFunctions . |
class |
StreamFilter<IN>
A
StreamOperator for executing FilterFunctions . |
class |
StreamFlatMap<IN,OUT>
A
StreamOperator for executing FlatMapFunctions . |
class |
StreamGroupedFold<IN,OUT,KEY>
Deprecated.
will be removed in a future version
|
class |
StreamGroupedReduce<IN>
|
class |
StreamMap<IN,OUT>
A
StreamOperator for executing MapFunctions . |
class |
StreamProject<IN,OUT extends Tuple>
A
StreamOperator for executing projections on streams. |
class |
StreamSink<IN>
A
StreamOperator for executing SinkFunctions . |
Modifier and Type | Class and Description |
---|---|
class |
AsyncWaitOperator<IN,OUT>
The
AsyncWaitOperator allows to asynchronously process incoming stream records. |
Modifier and Type | Method and Description |
---|---|
OneInputStreamOperator<IN,OUT> |
OneInputTransformation.getOperator()
Returns the
TwoInputStreamOperator of this Transformation. |
Constructor and Description |
---|
OneInputTransformation(StreamTransformation<IN> input,
String name,
OneInputStreamOperator<IN,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
OneInputTransformation from the given input and operator. |
Modifier and Type | Class and Description |
---|---|
class |
CassandraRowWriteAheadSink
Sink that emits its input elements into a Cassandra table.
|
class |
CassandraTupleWriteAheadSink<IN extends Tuple>
Sink that emits its input elements into a Cassandra database.
|
Constructor and Description |
---|
StreamInputProcessor(InputGate[] inputGates,
TypeSerializer<IN> inputSerializer,
StreamTask<?,?> checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
OneInputStreamOperator<IN,?> streamOperator,
TaskIOMetricGroup metrics,
WatermarkGauge watermarkGauge) |
Modifier and Type | Class and Description |
---|---|
class |
ExtractTimestampsOperator<T>
Deprecated.
|
class |
GenericWriteAheadSink<IN>
Generic Sink that emits its input elements into an arbitrary backend.
|
class |
TimestampsAndPeriodicWatermarksOperator<T>
A stream operator that extracts timestamps from stream elements and
generates periodic watermarks.
|
class |
TimestampsAndPunctuatedWatermarksOperator<T>
A stream operator that extracts timestamps from stream elements and
generates watermarks based on punctuation elements.
|
Modifier and Type | Class and Description |
---|---|
class |
EvictingWindowOperator<K,IN,OUT,W extends Window>
A
WindowOperator that also allows an Evictor to be used. |
class |
WindowOperator<K,IN,ACC,OUT,W extends Window>
An operator that implements the logic for windowing based on a
WindowAssigner and
Trigger . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.