public interface WindowBytesStoreSupplier extends StoreSupplier<WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>>
WindowStore<Byte, byte[]>
instances of type <Byte, byte[]>.
For any stores implementing the WindowStore<Byte, byte[]>
interface, null value bytes are considered as "not exist". This means:
1. Null value bytes in put operations should be treated as delete.
2. Null value bytes should never be returned in range query results.Modifier and Type | Method and Description |
---|---|
boolean |
retainDuplicates()
Whether or not this store is retaining duplicate keys.
|
long |
retentionPeriod()
The time period for which the
WindowStore will retain historic data. |
long |
segmentIntervalMs()
The size of the segments (in milliseconds) the store has.
|
long |
windowSize()
The size of the windows (in milliseconds) any store created from this supplier is creating.
|
get, metricsScope, name
long segmentIntervalMs()
long windowSize()
boolean retainDuplicates()
long retentionPeriod()
WindowStore
will retain historic data.