...
Code Block | ||||
---|---|---|---|---|
| ||||
public interface StoreTypeSpec { KeyValueBytesStoreSupplier keyValueStore(final String name); WindowBytesStoreSupplier windowStore(final String name, final Duration retentionPeriod, final Duration windowSize, final boolean retainDuplicates); SessionBytesStoreSupplier sessionStore(final String name, final Duration retentionPeriod); } |
Info |
---|
Note on Evolving API: a concern raised on KIP-591 about having such an interface is that the increased API surface area would mean introducing new store types (beyond KVS/Window/Session) would cause custom state store implementations to throw compiletime errors. I think it is valid to have new store types have a default implementation that throws |
OOTB Store Type Specs
We will provide default implementations of the above interface in the following classes:
...