public static <K, V> BytesStoreSupplier<KeyValueStore<Bytes, byte[]>> persistentKeyValueStore(final String name)
public static <K, V> BytesStoreSupplier<KeyValueStore<Bytes, byte[]>> inMemoryKeyValueStore(final String name)
public static <K, V> BytesStoreSupplier<KeyValueStore<Bytes, byte[]>> lruMap(final String name)
public static <K, V> BytesStoreSupplier<WindowStore<Bytes, byte[]>> persistentWindowStore(final String name, final Windows windows)
public static <K, V> BytesStoreSupplier<SessionStore<Bytes, byte[]>> persistentSessionStore(final String name,
final SessionWindows windows)
/**
* The following methods are for use with the PAPI. They allow building of StateStores that can be wrapped with
* caching, logging, and any other convenient wrappers provided by the KafkaStreams library
*/
public <K, V> StateStoreBuilder<WindowStore<K, V>> windowStoreBuilder(final BytesStoreSupplier<WindowStore<Bytes, byte[]>> supplier,
final Serde<K> keySerde,
final Serde<V> valueSerde,
final String metricsScope)
public <K, V> StateStoreBuilder<KeyValueStore<K, V>> keyValueStoreBuilder(final BytesStoreSupplier<KeyValueStore<Bytes, byte[]>> supplier,
final Serde<K> keySerde,
final Serde<V> valueSerde,
final String metricsScope)
public <K, V> StateStoreBuilder<SessionStore<K, V>> sessionStoreBuilder(final BytesStoreSupplier<SessionStore<Bytes, byte[]>> supplier,
final Serde<K> keySerde,
final Serde<V> valueSerde,
final String metricsScope) |