public class RocksDbSessionBytesStoreSupplier extends java.lang.Object implements SessionBytesStoreSupplier
Constructor and Description |
---|
RocksDbSessionBytesStoreSupplier(java.lang.String name,
long retentionPeriod) |
Modifier and Type | Method and Description |
---|---|
SessionStore<org.apache.kafka.common.utils.Bytes,byte[]> |
get()
Return a new
StateStore instance. |
java.lang.String |
metricsScope()
Return a String that is used as the scope for metrics recorded by Metered stores.
|
java.lang.String |
name()
Return the name of this state store supplier.
|
long |
retentionPeriod()
The time period for which the
SessionStore will retain historic data. |
long |
segmentIntervalMs()
The size of a segment, in milliseconds.
|
public RocksDbSessionBytesStoreSupplier(java.lang.String name, long retentionPeriod)
public java.lang.String name()
StoreSupplier
name
in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>
public SessionStore<org.apache.kafka.common.utils.Bytes,byte[]> get()
StoreSupplier
StateStore
instance.get
in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>
StateStore
instance of type Tpublic java.lang.String metricsScope()
StoreSupplier
metricsScope
in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>
public long segmentIntervalMs()
SessionBytesStoreSupplier
segmentIntervalMs
in interface SessionBytesStoreSupplier
public long retentionPeriod()
SessionBytesStoreSupplier
SessionStore
will retain historic data.retentionPeriod
in interface SessionBytesStoreSupplier