Package | Description |
---|---|
org.apache.flink.streaming.api.operators |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<TimerHeapInternalTimer<K,N>> |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.duplicate() |
Set<TimerHeapInternalTimer<K,N>> |
InternalTimersSnapshot.getEventTimeTimers() |
Set<TimerHeapInternalTimer<K,N>> |
InternalTimersSnapshot.getProcessingTimeTimers() |
TypeSerializerSchemaCompatibility<TimerHeapInternalTimer<K,N>> |
TimerSerializer.TimerSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<TimerHeapInternalTimer<K,N>> newSerializer)
Deprecated.
|
TypeSerializerSnapshot<TimerHeapInternalTimer<K,N>> |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<TimerHeapInternalTimer<K,N>> |
TimerSerializer.TimerSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<TimerHeapInternalTimer<K,N>> newSerializer)
Deprecated.
|
void |
InternalTimersSnapshot.setEventTimeTimers(Set<TimerHeapInternalTimer<K,N>> eventTimeTimers) |
void |
InternalTimersSnapshot.setProcessingTimeTimers(Set<TimerHeapInternalTimer<K,N>> processingTimeTimers) |
Constructor and Description |
---|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.