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(org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K> keySerializerConfigSnapshot, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot, 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()
org.apache.flink.api.common.typeutils.TypeSerializer<K>	getKeySerializer()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K>	getKeySerializerConfigSnapshot()
org.apache.flink.api.common.typeutils.TypeSerializer<N>	getNamespaceSerializer()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<N>	getNamespaceSerializerConfigSnapshot()
Set<TimerHeapInternalTimer<K,N>>	getProcessingTimeTimers()
int	hashCode()
void	setEventTimeTimers(Set<TimerHeapInternalTimer<K,N>> eventTimeTimers)
void	setKeySerializer(org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer)
void	setKeySerializerConfigSnapshot(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K> keySerializerConfigSnapshot)
void	setNamespaceSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer)
void	setNamespaceSerializerConfigSnapshot(org.apache.flink.api.common.typeutils.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(org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                              org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K> keySerializerConfigSnapshot,
                              org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
                              org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot,
                              @Nullable
                              Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
                              @Nullable
                              Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)

Constructor to use when snapshotting the timers.

Method Detail

getKeySerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<K> getKeySerializer()

setKeySerializer

public void setKeySerializer(org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer)

getKeySerializerConfigSnapshot

public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K> getKeySerializerConfigSnapshot()

setKeySerializerConfigSnapshot

public void setKeySerializerConfigSnapshot(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K> keySerializerConfigSnapshot)

getNamespaceSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<N> getNamespaceSerializer()

setNamespaceSerializer

public void setNamespaceSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer)

getNamespaceSerializerConfigSnapshot

public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<N> getNamespaceSerializerConfigSnapshot()

setNamespaceSerializerConfigSnapshot

public void setNamespaceSerializerConfigSnapshot(org.apache.flink.api.common.typeutils.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