org.apache.flink.streaming.api.operators

Class InternalTimersSnapshot<K,N>

java.lang.Object

org.apache.flink.streaming.api.operators.InternalTimersSnapshot<K,N>

public class InternalTimersSnapshot<K,N>
extends Object

A snapshot of internal timers, containing event and processing timers and the serializers to use to write / read them.

Constructor Summary

Constructors

Constructor and Description
InternalTimersSnapshot() Empty constructor used when restoring 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.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Set<TimerHeapInternalTimer<K,N>>	getEventTimeTimers()
TypeSerializerSnapshot<K>	getKeySerializerSnapshot()
TypeSerializerSnapshot<N>	getNamespaceSerializerSnapshot()
Set<TimerHeapInternalTimer<K,N>>	getProcessingTimeTimers()
int	hashCode()
void	setEventTimeTimers(Set<TimerHeapInternalTimer<K,N>> eventTimeTimers)
void	setKeySerializerSnapshot(TypeSerializerSnapshot<K> keySerializerConfigSnapshot)
void	setNamespaceSerializerSnapshot(TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot)
void	setProcessingTimeTimers(Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InternalTimersSnapshot

public InternalTimersSnapshot()

Empty constructor used when restoring the timers.

InternalTimersSnapshot

public InternalTimersSnapshot(TypeSerializer<K> keySerializer,
                              TypeSerializer<N> namespaceSerializer,
                              @Nullable
                              Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
                              @Nullable
                              Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)

Constructor to use when snapshotting the timers.

Method Detail

getKeySerializerSnapshot

public TypeSerializerSnapshot<K> getKeySerializerSnapshot()

setKeySerializerSnapshot

public void setKeySerializerSnapshot(TypeSerializerSnapshot<K> keySerializerConfigSnapshot)

getNamespaceSerializerSnapshot

public TypeSerializerSnapshot<N> getNamespaceSerializerSnapshot()

setNamespaceSerializerSnapshot

public void setNamespaceSerializerSnapshot(TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot)

getEventTimeTimers

public Set<TimerHeapInternalTimer<K,N>> getEventTimeTimers()

setEventTimeTimers

public void setEventTimeTimers(Set<TimerHeapInternalTimer<K,N>> eventTimeTimers)

getProcessingTimeTimers

public Set<TimerHeapInternalTimer<K,N>> getProcessingTimeTimers()

setProcessingTimeTimers

public void setProcessingTimeTimers(Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object