public class MaterializedInternal<K,V,S extends StateStore> extends Materialized<K,V,S>
cachingEnabled, keySerde, loggingEnabled, retention, storeName, storeSupplier, topicConfig, valueSerde
Constructor and Description |
---|
MaterializedInternal(Materialized<K,V,S> materialized) |
Modifier and Type | Method and Description |
---|---|
boolean |
cachingEnabled() |
void |
generateStoreNameIfNeeded(InternalNameProvider nameProvider,
java.lang.String generatedStorePrefix) |
boolean |
isQueryable() |
org.apache.kafka.common.serialization.Serde<K> |
keySerde() |
boolean |
loggingEnabled() |
java.lang.String |
storeName() |
StoreSupplier<S> |
storeSupplier() |
org.apache.kafka.common.serialization.Serde<V> |
valueSerde() |
as, as, as, as, with, withCachingDisabled, withCachingEnabled, withKeySerde, withLoggingDisabled, withLoggingEnabled, withRetention, withValueSerde
public MaterializedInternal(Materialized<K,V,S> materialized)
public void generateStoreNameIfNeeded(InternalNameProvider nameProvider, java.lang.String generatedStorePrefix)
public java.lang.String storeName()
public StoreSupplier<S> storeSupplier()
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
public boolean loggingEnabled()
public boolean cachingEnabled()
public boolean isQueryable()