@PublicEvolving public interface OperatorStateStore
Modifier and Type | Method and Description |
---|---|
<S> ListState<S> |
getOperatorState(ListStateDescriptor<S> stateDescriptor)
Creates (or restores) a list state.
|
Set<String> |
getRegisteredStateNames()
Returns a set with the names of all currently registered states.
|
<T extends Serializable> |
getSerializableListState(String stateName)
Creates a state of the given name that uses Java serialization to persist the state.
|
<S> ListState<S> getOperatorState(ListStateDescriptor<S> stateDescriptor) throws Exception
S
- The generic type of the statestateDescriptor
- The descriptor for this state, providing a name and serializer.Exception
<T extends Serializable> ListState<T> getSerializableListState(String stateName) throws Exception
This is a simple convenience method. For more flexibility on how state serialization
should happen, use the getOperatorState(ListStateDescriptor)
method.
stateName
- The name of state to createException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.