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, TypeSerializerConfigSnapshot keySerializerConfigSnapshot, TypeSerializer<N> namespaceSerializer, TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot, Set<InternalTimer<K,N>> eventTimeTimers, Set<InternalTimer<K,N>> processingTimeTimers) Constructor to use when snapshotting the timers.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Set<InternalTimer<K,N>>	getEventTimeTimers()
TypeSerializer<K>	getKeySerializer()
TypeSerializerConfigSnapshot	getKeySerializerConfigSnapshot()
TypeSerializer<N>	getNamespaceSerializer()
TypeSerializerConfigSnapshot	getNamespaceSerializerConfigSnapshot()
Set<InternalTimer<K,N>>	getProcessingTimeTimers()
int	hashCode()
void	setEventTimeTimers(Set<InternalTimer<K,N>> eventTimeTimers)
void	setKeySerializer(TypeSerializer<K> keySerializer)
void	setKeySerializerConfigSnapshot(TypeSerializerConfigSnapshot keySerializerConfigSnapshot)
void	setNamespaceSerializer(TypeSerializer<N> namespaceSerializer)
void	setNamespaceSerializerConfigSnapshot(TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot)
void	setProcessingTimeTimers(Set<InternalTimer<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,
                              TypeSerializerConfigSnapshot keySerializerConfigSnapshot,
                              TypeSerializer<N> namespaceSerializer,
                              TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot,
                              @Nullable
                              Set<InternalTimer<K,N>> eventTimeTimers,
                              @Nullable
                              Set<InternalTimer<K,N>> processingTimeTimers)

Constructor to use when snapshotting the timers.

Method Detail

getKeySerializer

public TypeSerializer<K> getKeySerializer()

setKeySerializer

public void setKeySerializer(TypeSerializer<K> keySerializer)

getKeySerializerConfigSnapshot

public TypeSerializerConfigSnapshot getKeySerializerConfigSnapshot()

setKeySerializerConfigSnapshot

public void setKeySerializerConfigSnapshot(TypeSerializerConfigSnapshot keySerializerConfigSnapshot)

getNamespaceSerializer

public TypeSerializer<N> getNamespaceSerializer()

setNamespaceSerializer

public void setNamespaceSerializer(TypeSerializer<N> namespaceSerializer)

getNamespaceSerializerConfigSnapshot

public TypeSerializerConfigSnapshot getNamespaceSerializerConfigSnapshot()

setNamespaceSerializerConfigSnapshot

public void setNamespaceSerializerConfigSnapshot(TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot)

getEventTimeTimers

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

setEventTimeTimers

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

getProcessingTimeTimers

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

setProcessingTimeTimers

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

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object