StoreBuilder<KeyValueStore<K, V>> materialize()KeyValueStoreMaterializer
KeyValueStoreMaterializer can materialize a StoreBuilder (of KeyValueStores) (based on the given MaterializedInternal).
KeyValueStoreMaterializer is created (and immediately requested to materialize a StoreBuilder) when:
-
InternalStreamsBuilderis requested to add a KTable or GlobalKTable to the topology -
KGroupedStreamImplis requested to doAggregate (for aggregate, count, and reduce aggregation operators) -
KGroupedTableImplis requested to doAggregate (for aggregate, count, and reduce aggregation operators) -
KTableKTableJoinNodeand TableProcessorNode are requested towriteToTopology
KeyValueStoreMaterializer takes a single MaterializedInternal (with a KeyValueStore<Bytes, byte[]> state store) when created.
Materializing StoreBuilder (of KeyValueStores) — materialize Method
materialize creates ("materializes") a StoreBuilder (of KeyValueStores) based on the MaterializedInternal.
Internally, materialize requests the MaterializedInternal for the optional StoreSupplier (which is expected a KeyValueBytesStoreSupplier).
If not defined, materialize requests the MaterializedInternal for the store name and uses the Stores factory object for a new persistent KeyValueBytesStoreSupplier.
materialize uses the Stores factory object for a new StoreBuilder<KeyValueStore<K, V>> (for the KeyValueBytesStoreSupplier, the keySerde and the valueSerde of the MaterializedInternal).
materialize enables or disables the logging (of the StoreBuilder) per the loggingEnabled flag of the MaterializedInternal.
materialize enables caching (of the StoreBuilder) if caching is enabled for the MaterializedInternal.
|
Note
|
|