public class RocksDbKeyValueBytesStoreSupplier extends java.lang.Object implements KeyValueBytesStoreSupplier
Constructor and Description |
---|
RocksDbKeyValueBytesStoreSupplier(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
KeyValueStore<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.
|
public RocksDbKeyValueBytesStoreSupplier(java.lang.String name)
public java.lang.String name()
StoreSupplier
name
in interface StoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>
public KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]> get()
StoreSupplier
StateStore
instance.get
in interface StoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>
StateStore
instance of type Tpublic java.lang.String metricsScope()
StoreSupplier
metricsScope
in interface StoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>