Skip to content

StateStore

StateStore is an abstraction of storage engines (for the state of a stream processor).

Contract

Closing

void close()

Flushing Cached Data

void flush()

Flushing cached data of this StateStore

Used when:

Initializing

void init(
  StateStoreContext context,
  StateStore root)

isOpen

boolean isOpen()

Name

String name()

persistent

boolean persistent()

Used when:

Implementations

Back to top