Package org.apache.kafka.streams.kstream.internals

Class MaterializedInternal<K,V,S extends StateStore>

java.lang.Object

org.apache.kafka.streams.kstream.Materialized<K,V,S>

org.apache.kafka.streams.kstream.internals.MaterializedInternal<K,V,S>

public class MaterializedInternal<K,V,S extends StateStore>
extends Materialized<K,V,S>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.Materialized

cachingEnabled, keySerde, loggingEnabled, retention, storeName, storeSupplier, topicConfig, valueSerde

Constructor Summary

Constructors

Constructor	Description
MaterializedInternal(Materialized<K,V,S> materialized)
MaterializedInternal(Materialized<K,V,S> materialized, InternalNameProvider nameProvider, String generatedStorePrefix)

Method Summary

Modifier and Type	Method	Description
boolean	cachingEnabled()
Serde<K>	keySerde()
boolean	loggingEnabled()
String	queryableStoreName()
String	storeName()
StoreSupplier<S>	storeSupplier()
Serde<V>	valueSerde()

Methods inherited from class org.apache.kafka.streams.kstream.Materialized

as, as, as, as, with, withCachingDisabled, withCachingEnabled, withKeySerde, withLoggingDisabled, withLoggingEnabled, withRetention, withValueSerde

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MaterializedInternal

public MaterializedInternal(Materialized<K,V,S> materialized)

MaterializedInternal

public MaterializedInternal(Materialized<K,V,S> materialized,
                            InternalNameProvider nameProvider,
                            String generatedStorePrefix)

Method Detail

queryableStoreName

public String queryableStoreName()

storeName

public String storeName()

storeSupplier

public StoreSupplier<S> storeSupplier()

keySerde

public Serde<K> keySerde()

valueSerde

public Serde<V> valueSerde()

loggingEnabled

public boolean loggingEnabled()

cachingEnabled

public boolean cachingEnabled()