Skip to content

Stores

Stores is a factory for creating state stores in Kafka Streams.

inMemoryWindowStore

WindowBytesStoreSupplier inMemoryWindowStore(
  String name,
  Duration retentionPeriod,
  Duration windowSize,
  boolean retainDuplicates)

inMemoryWindowStore...FIXME

inMemoryWindowStore is used when:

  • KStreamImplJoin is requested to sharedOuterJoinWindowStoreBuilder (for left outer join)
Back to top