boolean isTimestamped(StateStore stateStore)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. |
| WrappedStateStore | Description |
|---|---|
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
isTimestamped is positive (true) when either of the following holds:
-
The given StateStore is a
TimestampedBytesStore -
The wrapped StateStore is timestamped (recursively)
Otherwise, isTimestamped is negative (false).
|
Note
|
isTimestamped is used exclusively when AbstractStateManager is requested for a RecordConverter (for a StateStore).
|