THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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, S extends StateStore> Materialized<K, V, S> as(final String storeName) public static <K, V> Materialized<K, V, WindowStore<Bytes, byte[]>> as(final WindowStateStoreSupplierWindowBytesStoreSupplier supplier); public static <K, V> Materialized<K, V, SessionStore<Bytes, byte[]>> as(final SessionStateStoreSupplierSessionBytesStoreSupplier supplier); public static <K, V> Materialized<K, V, KeyValueStore<Bytes, byte[]>> as(final KeyValueStateStoreSupplierKeyValueBytesStoreSupplier 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() } |
...