Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.async | |
org.apache.flink.streaming.api.operators.co | |
org.apache.flink.streaming.connectors.kafka | |
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 |
AbstractCEPBasePatternOperator<IN,OUT>
Base class for CEP pattern operator.
|
class |
AbstractCEPPatternOperator<IN,OUT>
Abstract CEP pattern operator which is used for non keyed streams.
|
class |
AbstractKeyedCEPPatternOperator<IN,KEY,OUT>
Abstract CEP pattern operator for a keyed input stream.
|
class |
CEPPatternOperator<IN>
CEP pattern operator which only returns fully matched event patterns stored in a
Map . |
class |
KeyedCEPPatternOperator<IN,KEY>
CEP pattern operator which only returns fully matched event patterns stored in a
Map . |
class |
TimeoutCEPPatternOperator<IN>
CEP pattern operator which only returns fully matched event patterns and partially matched event
patterns which have timed out wrapped in
Either . |
class |
TimeoutKeyedCEPPatternOperator<IN,KEY> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractUdfStreamOperator<OUT,F extends Function>
This is used as the base class for operators that have a user-defined
function.
|
class |
ProcessOperator<K,IN,OUT> |
class |
StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>
|
class |
StreamFilter<IN> |
class |
StreamFlatMap<IN,OUT> |
class |
StreamGroupedFold<IN,OUT,KEY> |
class |
StreamGroupedReduce<IN> |
class |
StreamMap<IN,OUT> |
class |
StreamSink<IN> |
class |
StreamSource<OUT,SRC extends SourceFunction<OUT>>
StreamOperator for streaming sources. |
Modifier and Type | Class and Description |
---|---|
class |
AsyncWaitOperator<IN,OUT>
The
AsyncWaitOperator allows to asynchronously process incoming stream records. |
Modifier and Type | Class and Description |
---|---|
class |
CoProcessOperator<K,IN1,IN2,OUT> |
class |
CoStreamFlatMap<IN1,IN2,OUT> |
class |
CoStreamMap<IN1,IN2,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaProducer010<T>
Flink Sink to produce data into a Kafka topic.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtractTimestampsOperator<T>
Deprecated.
|
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 |
AbstractAlignedProcessingTimeWindowOperator<KEY,IN,OUT,STATE,F extends Function>
Deprecated.
|
class |
AccumulatingProcessingTimeWindowOperator<KEY,IN,OUT>
Deprecated.
|
class |
AggregatingProcessingTimeWindowOperator<KEY,IN>
Deprecated.
|
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–2017 The Apache Software Foundation. All rights reserved.