public class InternalTimersSnapshot<K,N> extends Object
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.
|
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) |
public 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)
public TypeSerializer<K> getKeySerializer()
public void setKeySerializer(TypeSerializer<K> keySerializer)
public TypeSerializerConfigSnapshot getKeySerializerConfigSnapshot()
public void setKeySerializerConfigSnapshot(TypeSerializerConfigSnapshot keySerializerConfigSnapshot)
public TypeSerializer<N> getNamespaceSerializer()
public void setNamespaceSerializer(TypeSerializer<N> namespaceSerializer)
public TypeSerializerConfigSnapshot getNamespaceSerializerConfigSnapshot()
public void setNamespaceSerializerConfigSnapshot(TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot)
public Set<InternalTimer<K,N>> getEventTimeTimers()
public void setEventTimeTimers(Set<InternalTimer<K,N>> eventTimeTimers)
public Set<InternalTimer<K,N>> getProcessingTimeTimers()
public void setProcessingTimeTimers(Set<InternalTimer<K,N>> processingTimeTimers)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.