Package org.apache.kafka.streams.state
Interface SessionBytesStoreSupplier
- All Superinterfaces:
StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,
byte[]>>
public interface SessionBytesStoreSupplier
extends StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>
A store supplier that can be used to create one or more
SessionStore<Byte, byte[]>
instances.
For any stores implementing the SessionStore<Byte, byte[]>
interface, null
value
bytes are considered as "not exist". This means:
null
value bytes in put operations should be treated as delete.null
value bytes should never be returned in range query results.
-
Method Summary
Modifier and TypeMethodDescriptionlong
The time period for which theSessionStore
will retain historic data.long
The size of a segment, in milliseconds.Methods inherited from interface org.apache.kafka.streams.state.StoreSupplier
get, metricsScope, name
-
Method Details
-
segmentIntervalMs
long segmentIntervalMs()The size of a segment, in milliseconds. Used when caching is enabled to segment the cache and reduce the amount of data that needs to be scanned when performing range queries.- Returns:
- segmentInterval in milliseconds
-
retentionPeriod
long retentionPeriod()The time period for which theSessionStore
will retain historic data.- Returns:
- retentionPeriod
-