Package org.apache.flink.runtime.state.ttl

Class TtlStateContext<T,SV>

java.lang.Object

org.apache.flink.runtime.state.ttl.TtlStateContext<T,SV>

public class TtlStateContext<T,SV>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
Runnable	accessCallback	This registered callback is to be called whenever state is accessed for read or write.
StateTtlConfig	config
T	original	Wrapped original state handler.
TtlTimeProvider	timeProvider
TypeSerializer<SV>	valueSerializer	Serializer of original user stored value without timestamp.

Constructor Summary

Constructors

Constructor	Description
TtlStateContext(T original, StateTtlConfig config, TtlTimeProvider timeProvider, TypeSerializer<SV> valueSerializer, Runnable accessCallback)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

original

public final T original

Wrapped original state handler.

config

public final StateTtlConfig config

timeProvider

public final TtlTimeProvider timeProvider

valueSerializer

public final TypeSerializer<SV> valueSerializer

Serializer of original user stored value without timestamp.

accessCallback

public final Runnable accessCallback

This registered callback is to be called whenever state is accessed for read or write.

Constructor Detail

TtlStateContext

public TtlStateContext(T original,
                       StateTtlConfig config,
                       TtlTimeProvider timeProvider,
                       TypeSerializer<SV> valueSerializer,
                       Runnable accessCallback)