WrappedStateStore

WrappedStateStore is the base implementation of the StateStore and CachedStateStore contracts for state stores that simply delegate all operations to the wrapped state store.

WrappedStateStore allows for composing state stores and building more sophisticated state stores (e.g. MeteredKeyValueStore with CachingKeyValueStore and ChangeLoggingKeyValueBytesStore).

Note
Kafka Streams developers use Stores utility to use the more sophisticated state stores.
Table 1. WrappedStateStores
WrappedStateStore Description

CachingKeyValueStore

CachingSessionStore

CachingWindowStore

ChangeLoggingKeyValueBytesStore

ChangeLoggingSessionBytesStore

ChangeLoggingWindowBytesStore

MeteredKeyValueStore

MeteredSessionStore

MeteredWindowStore

RocksDBSessionStore

RocksDBWindowStore

WrappedStateStore takes a single StateStore (wrapped state store) to be created.

Note
WrappedStateStore is a Java abstract class and cannot be created directly. It is created indirectly for the concrete WrappedStateStores.

isTimestamped Static Method

boolean isTimestamped(StateStore stateStore)

isTimestamped is positive (true) when either of the following holds:

Otherwise, isTimestamped is negative (false).

Note
isTimestamped is used exclusively when AbstractStateManager is requested for a RecordConverter (for a StateStore).

results matching ""

    No results matching ""