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.temporal | |
org.apache.flink.table.runtime.operators.sort | |
org.apache.flink.table.runtime.operators.window |
Modifier and Type | Method and Description |
---|---|
void |
CepOperator.onEventTime(InternalTimer<KEY,VoidNamespace> timer) |
void |
CepOperator.onProcessingTime(InternalTimer<KEY,VoidNamespace> timer) |
Modifier and Type | Method and Description |
---|---|
void |
VoidTriggerable.onEventTime(InternalTimer<K,N> timer) |
void |
VoidTriggerable.onProcessingTime(InternalTimer<K,N> timer) |
Modifier and Type | Class and Description |
---|---|
class |
TimerHeapInternalTimer<K,N>
Implementation of
InternalTimer to use with a HeapPriorityQueueSet . |
Modifier and Type | Field and Description |
---|---|
static KeyExtractorFunction<InternalTimer<?,?>> |
InternalTimer.KEY_EXTRACTOR_FUNCTION
Function to extract the key from a
InternalTimer . |
static PriorityComparator<InternalTimer<?,?>> |
InternalTimer.TIMER_COMPARATOR
Function to compare instances of
InternalTimer . |
Modifier and Type | Method and Description |
---|---|
int |
TimerHeapInternalTimer.comparePriorityTo(InternalTimer<?,?> other) |
void |
Triggerable.onEventTime(InternalTimer<K,N> timer)
Invoked when an event-time timer fires.
|
void |
LegacyKeyedProcessOperator.onEventTime(InternalTimer<K,VoidNamespace> timer)
Deprecated.
|
void |
KeyedProcessOperator.onEventTime(InternalTimer<K,VoidNamespace> timer) |
void |
Triggerable.onProcessingTime(InternalTimer<K,N> timer)
Invoked when a processing-time timer fires.
|
void |
LegacyKeyedProcessOperator.onProcessingTime(InternalTimer<K,VoidNamespace> timer)
Deprecated.
|
void |
KeyedProcessOperator.onProcessingTime(InternalTimer<K,VoidNamespace> timer) |
Modifier and Type | Method and Description |
---|---|
void |
IntervalJoinOperator.onEventTime(InternalTimer<K,String> timer) |
void |
CoBroadcastWithKeyedOperator.onEventTime(InternalTimer<KS,VoidNamespace> timer) |
void |
KeyedCoProcessOperator.onEventTime(InternalTimer<K,VoidNamespace> timer) |
void |
LegacyKeyedCoProcessOperator.onEventTime(InternalTimer<K,VoidNamespace> timer)
Deprecated.
|
void |
IntervalJoinOperator.onProcessingTime(InternalTimer<K,String> timer) |
void |
CoBroadcastWithKeyedOperator.onProcessingTime(InternalTimer<KS,VoidNamespace> timer) |
void |
KeyedCoProcessOperator.onProcessingTime(InternalTimer<K,VoidNamespace> timer) |
void |
LegacyKeyedCoProcessOperator.onProcessingTime(InternalTimer<K,VoidNamespace> timer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
WindowOperator.onEventTime(InternalTimer<K,W> timer) |
void |
EvictingWindowOperator.onEventTime(InternalTimer<K,W> timer) |
void |
WindowOperator.onProcessingTime(InternalTimer<K,W> timer) |
void |
EvictingWindowOperator.onProcessingTime(InternalTimer<K,W> timer) |
Modifier and Type | Method and Description |
---|---|
void |
TemporalRowTimeJoinOperator.onEventTime(InternalTimer<Object,VoidNamespace> timer) |
void |
TemporalProcessTimeJoinOperator.onEventTime(InternalTimer<Object,VoidNamespace> timer)
Invoked when an event-time timer fires.
|
void |
BaseTwoInputStreamOperatorWithStateRetention.onProcessingTime(InternalTimer<Object,VoidNamespace> timer)
The users of this class are not allowed to use processing time timers.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcTimeSortOperator.onEventTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
RowTimeSortOperator.onEventTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
ProcTimeSortOperator.onProcessingTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
RowTimeSortOperator.onProcessingTime(InternalTimer<BaseRow,VoidNamespace> timer) |
Modifier and Type | Method and Description |
---|---|
void |
WindowOperator.onEventTime(InternalTimer<K,W> timer) |
void |
WindowOperator.onProcessingTime(InternalTimer<K,W> timer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.