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.png
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.

results matching ""

    No results matching ""