Skip to content

Latest commit

 

History

History
59 lines (42 loc) · 1.81 KB

kafka-streams-WindowBytesStoreSupplier.adoc

File metadata and controls

59 lines (42 loc) · 1.81 KB
Raw

WindowBytesStoreSupplier Contract — StoreSuppliers of WindowStores

WindowBytesStoreSupplier is the extension of the StoreSupplier contract for state store suppliers that supply WindowStores (i.e. WindowStores of type <Bytes, byte[]>).

kafka streams WindowBytesStoreSupplier
Figure 1. WindowBytesStoreSupplier et al.
Note
 RocksDbWindowBytesStoreSupplier is the one and only known implementation of the WindowBytesStoreSupplier Contract.
Table 1. WindowBytesStoreSupplier Contract
Property Description

retainDuplicates

 
boolean retainDuplicates()

Used exclusively when WindowStoreBuilder is requested to maybeWrapLogging.

retentionPeriod

 
long retentionPeriod()

Used exclusively when WindowStoreBuilder is requested for the retentionPeriod.

segmentIntervalMs

 
long segmentIntervalMs()

Used exclusively when WindowStoreBuilder is requested to maybeWrapCaching.

windowSize

 
long windowSize()

Used exclusively when WindowStoreBuilder is requested to maybeWrapCaching.