Package com.linkedin.davinci.stats

Class RocksDBMemoryStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.davinci.stats.RocksDBMemoryStats

public class RocksDBMemoryStats
extends AbstractVeniceStats

Class that exposes RocksDB memory consumption stats based on all properties that are made available in https://github.com/facebook/rocksdb/blob/master/include/rocksdb/db.h#L870 Properties exist on a per RockDB database basis (equivalent to a Venice partition). This class aggregates across the partitions and emits aggregate stats

Field Summary

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats

DELIMITER

Constructor Summary

Constructors

Constructor	Description
RocksDBMemoryStats(io.tehuti.metrics.MetricsRepository metricsRepository, String name, boolean plainTableEnabled)

Method Summary

Modifier and Type	Method	Description
void	deregisterPartition(String partitionName)
void	registerPartition(String partitionName, RocksDBStoragePartition rocksDBPartition)
void	setMemoryLimit(long memoryLimit)
void	setSstFileManager(org.rocksdb.SstFileManager sstFileManager)

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceStats

avgAndMax, avgAndTotal, getMetricFullName, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerOnlyTotalSensor, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors

Methods inherited from class java.lang.Object

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

Constructor Details

RocksDBMemoryStats

public RocksDBMemoryStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String name,
 boolean plainTableEnabled)

Method Details

setMemoryLimit

public void setMemoryLimit(long memoryLimit)

setSstFileManager

public void setSstFileManager(org.rocksdb.SstFileManager sstFileManager)

registerPartition

public void registerPartition(String partitionName,
 RocksDBStoragePartition rocksDBPartition)

deregisterPartition

public void deregisterPartition(String partitionName)