public interface StateStore
This interface does not specify any query capabilities, which, of course, would be query engine specific. Instead it just specifies the minimum functionality required to reload a storage engine from its changelog as well as basic lifecycle management.
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the storage engine.
|
void |
flush()
Flush any cached data
|
void |
init(ProcessorContext context,
StateStore root)
Initializes this state store
|
boolean |
isOpen()
Is this store open for reading and writing
|
java.lang.String |
name()
The name of this store.
|
boolean |
persistent()
Return if the storage is persistent or not.
|
java.lang.String name()
void init(ProcessorContext context, StateStore root)
void flush()
void close()
Users only need to implement this function but should NEVER need to call this api explicitly as it will be called by the library automatically when necessary
boolean persistent()
true
if the storage is persistent—false
otherwiseboolean isOpen()
true
if the store is open