org.apache.flink.runtime.state.ttl

Class TtlStateFactory<N,SV,S extends State,IS extends S>

java.lang.Object

org.apache.flink.runtime.state.ttl.TtlStateFactory<N,SV,S,IS>

public class TtlStateFactory<N,SV,S extends State,IS extends S>
extends Object

This state factory wraps state objects, produced by backends, with TTL logic.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TtlStateFactory.TtlSerializer<T> Serializer for user state value with TTL.

Method Summary

Modifier and Type	Method and Description
static <N,SV,S extends State,IS extends S> IS	createStateAndWrapWithTtlIfEnabled(TypeSerializer<N> namespaceSerializer, StateDescriptor<S,SV> stateDesc, KeyedStateFactory originalStateFactory, TtlTimeProvider timeProvider)

Methods inherited from class java.lang.Object

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

Method Detail

createStateAndWrapWithTtlIfEnabled

public static <N,SV,S extends State,IS extends S> IS createStateAndWrapWithTtlIfEnabled(TypeSerializer<N> namespaceSerializer,
                                                                                        StateDescriptor<S,SV> stateDesc,
                                                                                        KeyedStateFactory originalStateFactory,
                                                                                        TtlTimeProvider timeProvider)
                                                                                 throws Exception

Throws:

Exception