StoreSupplier¶

StoreSupplier is an abstraction of suppliers of StateStores.

Contract¶

Creating StateStore¶

T get()

Used when:

• KStreamImplJoin is requested to sharedOuterJoinWindowStoreBuilder
• KeyValueStoreBuilder is requested to build
• SessionStoreBuilder is requested to build
• TimeOrderedWindowStoreBuilder is requested to build
• TimestampedKeyValueStoreBuilder is requested to build
• TimestampedWindowStoreBuilder is requested to build
• WindowStoreBuilder is requested to build

metricsScope¶

String metricsScope()

name¶

String name()

Implementations¶

• KeyValueBytesStoreSupplier
• SessionBytesStoreSupplier
• WindowBytesStoreSupplier