...
Code Block | ||||
---|---|---|---|---|
| ||||
/**
* Implementations of this will provide the ability to wrap a given StateStore
* with or without caching/loggging etc.
*/
public interface StateStoreBuilder<T extends StateStore> {
StateStoreBuilder<T> withCachingEnabled();
StateStoreBuilder<T> withLoggingEnabled(Map<String, String> config);
T build();
Map<String, String> logConfig();
boolean loggingEnabled();
} |
Code Block | ||||
---|---|---|---|---|
| ||||
public interface BytesStoreSupplier<T extends StateStore> { /** * Return the name of this state store supplier. * This must be a valid Kafka topic name; valid characters are ASCII alphanumerics, '.', '_' and '-' * * @return the name of this state store supplier */ String name(); /** * Return a new {@link StateStore} instance. * * @return a new {@link StateStore} instance of type T */ T get(); } |
...