Skip to content

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

Back to top