Modifier and Type | Class and Description |
---|---|
static class |
TtlStateFactory.TtlSerializer<T>
Serializer for user state value with TTL.
|
Modifier and Type | Method and Description |
---|---|
static <N,SV,S extends State,IS extends S> |
createStateAndWrapWithTtlIfEnabled(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
KeyedStateFactory originalStateFactory,
TtlTimeProvider timeProvider) |
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
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.