/**
* 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 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 String storeName();
public StoreSupplier<S> storeSupplier()
public Serde<K> keySerde()
public StateStoreBuilder storeBuilder Serde<V> valueSerde()
public boolean loggingEnabled()
public Map<String, String> logConfig()
public boolean cachingEnabled()
} |