public class RocksDbWindowBytesStoreSupplier extends java.lang.Object implements WindowBytesStoreSupplier
Constructor and Description |
---|
RocksDbWindowBytesStoreSupplier(java.lang.String name,
long retentionPeriod,
long segmentInterval,
long windowSize,
boolean retainDuplicates) |
Modifier and Type | Method and Description |
---|---|
WindowStore<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.
|
boolean |
retainDuplicates()
Whether or not this store is retaining duplicate keys.
|
long |
retentionPeriod()
The time period for which the
WindowStore will retain historic data. |
long |
segmentIntervalMs()
The size of the segments (in milliseconds) the store has.
|
int |
segments()
Deprecated.
|
long |
windowSize()
The size of the windows (in milliseconds) any store created from this supplier is creating.
|
public RocksDbWindowBytesStoreSupplier(java.lang.String name, long retentionPeriod, long segmentInterval, long windowSize, boolean retainDuplicates)
public java.lang.String name()
StoreSupplier
name
in interface StoreSupplier<WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>>
public WindowStore<org.apache.kafka.common.utils.Bytes,byte[]> get()
StoreSupplier
StateStore
instance.get
in interface StoreSupplier<WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>>
StateStore
instance of type Tpublic java.lang.String metricsScope()
StoreSupplier
metricsScope
in interface StoreSupplier<WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>>
@Deprecated public int segments()
WindowBytesStoreSupplier
segments
in interface WindowBytesStoreSupplier
public long segmentIntervalMs()
WindowBytesStoreSupplier
segmentIntervalMs
in interface WindowBytesStoreSupplier
public long windowSize()
WindowBytesStoreSupplier
windowSize
in interface WindowBytesStoreSupplier
public boolean retainDuplicates()
WindowBytesStoreSupplier
retainDuplicates
in interface WindowBytesStoreSupplier
public long retentionPeriod()
WindowBytesStoreSupplier
WindowStore
will retain historic data.retentionPeriod
in interface WindowBytesStoreSupplier