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
|
String |
name()
The name of this store.
|
boolean |
persistent()
Return if the storage is persistent or not.
|
String name()
void init(ProcessorContext context, StateStore root)
void flush()
void close()
boolean persistent()
true
if the storage is persistent—false
otherwiseboolean isOpen()
true
if the store is open