T
- The type of objects to store.public interface StateStore<T extends Serializable>
org.apache.flink.runtime.state.StateBackend
backend object
store interface.
Important: This does not work with user-specified classes.
Modifier and Type | Method and Description |
---|---|
void |
disposeState(String path)
Disposes the state identified by the given (logical) path.
|
T |
getState(String path)
Returns the object identified by the given (logical) path.
|
String |
putState(T state)
Puts an object into the store and returns the (logical) path to it.
|
String putState(T state) throws Exception
The stored state can be retrieved or discarded by specifying the returned path.
state
- The object to store.Exception
T getState(String path) throws Exception
path
- The path of the object to retrieve.IllegalArgumentException
- If the path does not identify a valid object.Exception
void disposeState(String path) throws Exception
path
- The path of the object to discard.IllegalArgumentException
- If the path does not identify a valid object.Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.