org.apache.kafka.streams.processor

Interface StateStore

All Known Subinterfaces:

KeyValueStore<K,V>, SessionStore<K,AGG>, WindowStore<K,V>

public interface StateStore

A storage engine for managing state maintained by a stream processor.

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.

Method Summary

Methods

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.

Method Detail

name

String name()

The name of this store.

Returns:

the storage name

init

void init(ProcessorContext context,
        StateStore root)

Initializes this state store

flush

void flush()

Flush any cached data

close

void close()

Close the storage engine. Note that this function needs to be idempotent since it may be called several times on the same state store.

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

persistent

boolean persistent()

Return if the storage is persistent or not.

Returns:

true if the storage is persistent—false otherwise

isOpen

boolean isOpen()

Is this store open for reading and writing

Returns:

true if the store is open