Class RocksDbKeyValueBytesStoreSupplier
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.RocksDbKeyValueBytesStoreSupplier
-
- All Implemented Interfaces:
KeyValueBytesStoreSupplier
,StoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>
public class RocksDbKeyValueBytesStoreSupplier extends Object implements KeyValueBytesStoreSupplier
-
-
Constructor Summary
Constructors Constructor Description RocksDbKeyValueBytesStoreSupplier(String name, boolean returnTimestampedStore)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>
get()
Return a newStateStore
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.
-
-
-
Constructor Detail
-
RocksDbKeyValueBytesStoreSupplier
public RocksDbKeyValueBytesStoreSupplier(String name, boolean returnTimestampedStore)
-
-
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 interfaceStoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>
- Returns:
- the name of this state store supplier
-
get
public KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]> get()
Description copied from interface:StoreSupplier
Return a newStateStore
instance.- Specified by:
get
in interfaceStoreSupplier<KeyValueStore<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 interfaceStoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>
- Returns:
- metricsScope
-
-