...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * Used when materializing a state store, i.e, during an aggregation operation or KTable operations */ public class Materialized<K, V, S extends StateStore> { public static <K, V> Materialized<K, V, KeyValueStore<Bytes, byte[]>> asKeyValueStore(final String storeName) public static <K, V> S extends StateStore> Materialized<K, V, WindowStore<Bytes, byte[]>> asWindowStore(final String storeName) public static <K, V> Materialized<K, V, SessionStore<Bytes, byte[]>> asSessionStoreS> as(final String storeName) public static <K, V> Materialized<K, V, WindowStore<Bytes, byte[]>> as(final WindowBytesStoreSupplier supplier); public static <K, V> Materialized<K, V, SessionStore<Bytes, byte[]>> as(final SessionBytesStoreSupplier supplier); public static <K, V> Materialized<K, V, KeyValueStore<Bytes, byte[]>> as(final KeyValueBytesStoreSupplier supplier) public Materialized<K, V, S> withValueSerde(final Serde<V> valueSerde) public Materialized<K, V, S> withKeySerde(final Serde<K> valueSerde) public Materialized<K, V, S> withLoggingEnabled(final Map<String, String> topicConfig) public Materialized<K, V, S> withLoggingDisabled() public Materialized<K, V, S> withCachingEnabled() public Materialized<K, V, S> withCachingDisabled() public StateStoreBuilder storeBuilder() } |
...