void generateStoreNameIfNeeded(
final InternalNameProvider nameProvider,
final String generatedStorePrefix)
MaterializedInternal
MaterializedInternal
is a Materialized that…FIXME
MaterializedInternal
can be queriable which is…FIXME
MaterializedInternal
uses the loggingEnabled
flag for…FIXME
MaterializedInternal
uses the cachingEnabled
flag for…FIXME
MaterializedInternal
uses the topicConfig
registry with mappings for…FIXME
MaterializedInternal
allows accessing the optional StoreSupplier.
MaterializedInternal
uses the store name for…FIXME
generateStoreNameIfNeeded
Method
generateStoreNameIfNeeded
…FIXME
Note
|
generateStoreNameIfNeeded is used when…FIXME
|
withLoggingDisabled
Method
Materialized<K, V, S> withLoggingDisabled()
withLoggingDisabled
turns the loggingEnabled flag off and removes all of the mappings from the topicConfig.
In the end, withLoggingDisabled
returns the current Materialized
instance.
Note
|
withLoggingDisabled is used exclusively when InternalStreamsBuilder is requested to add a GlobalKTable to the topology.
|
Accessing Optional StoreSupplier — storeSupplier
Method
StoreSupplier<S> storeSupplier()
storeSupplier
simply returns the StoreSupplier.
Note
|
storeSupplier is used when KeyValueStoreMaterializer, SessionWindowedKStreamImpl, and TimeWindowedKStreamImpl are requested to materialize a StoreBuilder.
|