Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.state.api.runtime | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.co | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations on data streams.
|
org.apache.flink.table.runtime.operators.join | |
org.apache.flink.table.runtime.operators.join.temporal | |
org.apache.flink.table.runtime.operators.sort | |
org.apache.flink.table.runtime.operators.window |
Modifier and Type | Class and Description |
---|---|
class |
CepOperator<IN,KEY,OUT>
CEP pattern operator for a keyed input stream.
|
Modifier and Type | Class and Description |
---|---|
class |
VoidTriggerable<K,N>
A
Triggerable that does nothing. |
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 |
Modifier and Type | Method and Description |
---|---|
<N> InternalTimerService<N> |
InternalTimeServiceManager.getInternalTimerService(String name,
TimerSerializer<K,N> timerSerializer,
Triggerable<K,N> triggerable) |
<K,N> InternalTimerService<N> |
AbstractStreamOperator.getInternalTimerService(String name,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Returns a
InternalTimerService that can be used to query current processing time and
event time and to set timers. |
<K,N> InternalTimerService<N> |
AbstractStreamOperatorV2.getInternalTimerService(String name,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Returns a
InternalTimerService that can be used to query current processing time and
event time and to set timers. |
<N> InternalTimerService<N> |
InternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable,
KeyedStateBackend<K> keyedStateBackend) |
void |
InternalTimerServiceImpl.startTimerService(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerTarget)
Starts the local
InternalTimerServiceImpl by:
Setting the keySerialized and namespaceSerializer for the timers it
will contain. |
Modifier and Type | Class and Description |
---|---|
class |
CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>
A
TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions . |
class |
IntervalJoinOperator<K,T1,T2,OUT>
An
operator to execute time-bounded stream inner joins. |
class |
KeyedCoProcessOperator<K,IN1,IN2,OUT>
A
StreamOperator for executing keyed KeyedCoProcessFunction . |
class |
LegacyKeyedCoProcessOperator<K,IN1,IN2,OUT>
Deprecated.
Replaced by
KeyedCoProcessOperator which takes KeyedCoProcessFunction |
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 . |
Modifier and Type | Class and Description |
---|---|
class |
KeyedCoProcessOperatorWithWatermarkDelay<K,IN1,IN2,OUT>
A
KeyedCoProcessOperator that supports holding back watermarks with a static delay. |
Modifier and Type | Class and Description |
---|---|
class |
BaseTwoInputStreamOperatorWithStateRetention
An abstract
TwoInputStreamOperator that allows its subclasses to clean up their state
based on a TTL. |
class |
TemporalProcessTimeJoinOperator
The operator to temporal join a stream on processing time.
|
class |
TemporalRowTimeJoinOperator
This operator works by keeping on the state collection of probe and build records to process on
next watermark.
|
Modifier and Type | Class and Description |
---|---|
class |
ProcTimeSortOperator
Sort on proc-time and additional secondary sort attributes.
|
class |
RowTimeSortOperator
Sort based on event-time and possibly additional secondary sort attributes.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateWindowOperator<K,W extends Window>
A
WindowOperator for grouped window aggregates. |
class |
TableAggregateWindowOperator<K,W extends Window>
A
WindowOperator for grouped and windowed table aggregates. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.