Package | Description |
---|---|
org.apache.flink.cep.operator | |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractKeyedCEPPatternOperator.onEventTime(InternalTimer<KEY,VoidNamespace> timer) |
void |
AbstractKeyedCEPPatternOperator.onProcessingTime(InternalTimer<KEY,VoidNamespace> timer) |
Modifier and Type | Method and Description |
---|---|
InternalTimer<K,N> |
InternalTimer.TimerSerializer.copy(InternalTimer<K,N> from) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.copy(InternalTimer<K,N> from,
InternalTimer<K,N> reuse) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.createInstance() |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.deserialize(DataInputView source) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.deserialize(InternalTimer<K,N> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<InternalTimer<K,N>> |
InternalTimer.TimerSerializer.duplicate() |
CompatibilityResult<InternalTimer<K,N>> |
InternalTimer.TimerSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Set<InternalTimer<K,N>> |
InternalTimersSnapshot.getEventTimeTimers() |
Set<InternalTimer<K,N>> |
InternalTimersSnapshot.getProcessingTimeTimers() |
Modifier and Type | Method and Description |
---|---|
int |
InternalTimer.compareTo(InternalTimer<K,N> o) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.copy(InternalTimer<K,N> from) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.copy(InternalTimer<K,N> from,
InternalTimer<K,N> reuse) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.copy(InternalTimer<K,N> from,
InternalTimer<K,N> reuse) |
InternalTimer<K,N> |
InternalTimer.TimerSerializer.deserialize(InternalTimer<K,N> reuse,
DataInputView source) |
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) |
void |
InternalTimer.TimerSerializer.serialize(InternalTimer<K,N> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
InternalTimersSnapshot.setEventTimeTimers(Set<InternalTimer<K,N>> eventTimeTimers) |
void |
InternalTimersSnapshot.setProcessingTimeTimers(Set<InternalTimer<K,N>> processingTimeTimers) |
Constructor and Description |
---|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerConfigSnapshot keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot,
Set<InternalTimer<K,N>> eventTimeTimers,
Set<InternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerConfigSnapshot keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot,
Set<InternalTimer<K,N>> eventTimeTimers,
Set<InternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
Modifier and Type | Method and Description |
---|---|
void |
CoBroadcastWithKeyedOperator.onEventTime(InternalTimer<KS,VoidNamespace> timer) |
void |
KeyedCoProcessOperator.onEventTime(InternalTimer<K,VoidNamespace> timer) |
void |
CoBroadcastWithKeyedOperator.onProcessingTime(InternalTimer<KS,VoidNamespace> timer) |
void |
KeyedCoProcessOperator.onProcessingTime(InternalTimer<K,VoidNamespace> timer) |
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) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.