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 moreSessionStore<Byte, byte[]>
instances. For any stores implementing theSessionStore<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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
retentionPeriod()
The time period for which theSessionStore
will retain historic data.long
segmentIntervalMs()
The size of a segment, in milliseconds.-
Methods inherited from interface org.apache.kafka.streams.state.StoreSupplier
get, metricsScope, name
-
-
-
-
Method Detail
-
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
-
-