Package org.apache.kafka.streams.state.internals

Class RocksDbSessionBytesStoreSupplier

java.lang.Object

org.apache.kafka.streams.state.internals.RocksDbSessionBytesStoreSupplier

All Implemented Interfaces:

SessionBytesStoreSupplier, StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>

public class RocksDbSessionBytesStoreSupplier
extends Object
implements SessionBytesStoreSupplier

Constructor Summary

Constructors

Constructor	Description
RocksDbSessionBytesStoreSupplier(String name, long retentionPeriod)

Method Summary

Modifier and Type	Method	Description
SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>	get()	Return a new StateStore instance.
String	metricsScope()	Return a String that is used as the scope for metrics recorded by Metered stores.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocksDbSessionBytesStoreSupplier

public RocksDbSessionBytesStoreSupplier(String name,
                                        long retentionPeriod)

Method Detail

name

public String name()

Description copied from interface: StoreSupplier

Return the name of this state store supplier. This must be a valid Kafka topic name; valid characters are ASCII alphanumerics, '.', '_' and '-'.

Specified by:

name in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>

Returns:

the name of this state store supplier

get

public SessionStore<org.apache.kafka.common.utils.Bytes,byte[]> get()

Description copied from interface: StoreSupplier

Return a new StateStore instance.

Specified by:

get in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>

Returns:

a new StateStore instance of type T

metricsScope

public String metricsScope()

Description copied from interface: StoreSupplier

Return a String that is used as the scope for metrics recorded by Metered stores.

Specified by:

metricsScope in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>>

Returns:

metricsScope

segmentIntervalMs

public long segmentIntervalMs()

Description copied from interface: SessionBytesStoreSupplier

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.

Specified by:

segmentIntervalMs in interface SessionBytesStoreSupplier

Returns:

segmentInterval in milliseconds

retentionPeriod

public long retentionPeriod()

Description copied from interface: SessionBytesStoreSupplier

The time period for which the SessionStore will retain historic data.

Specified by:

retentionPeriod in interface SessionBytesStoreSupplier

Returns:

retentionPeriod