Package com.linkedin.davinci.stats

Class VeniceVersionedStats<STATS,STATS_REPORTER extends AbstractVeniceStatsReporter<STATS>>

java.lang.Object

com.linkedin.davinci.stats.VeniceVersionedStats<STATS,STATS_REPORTER>

public class VeniceVersionedStats<STATS,STATS_REPORTER extends AbstractVeniceStatsReporter<STATS>>
extends Object

Constructor Summary

Constructors

Constructor	Description
VeniceVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository, String storeName, Supplier<STATS> statsInitiator, StatsSupplier<STATS_REPORTER> reporterSupplier)

Method Summary

Modifier and Type	Method	Description
STATS	addVersion(int version)
it.unimi.dsi.fastutil.ints.IntSet	getAllVersionNumbers()	return a deep copy of all version numbers
int	getCurrentVersion()
int	getFutureVersion()
protected STATS	getStats(int version)
protected STATS	getTotalStats()
void	registerConditionalStats()
void	removeVersion(int version)
void	setCurrentVersion(int version)
void	setFutureVersion(int version)
void	unregisterStats()

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceVersionedStats

public VeniceVersionedStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 String storeName,
 Supplier<STATS> statsInitiator,
 StatsSupplier<STATS_REPORTER> reporterSupplier)

Method Details

getTotalStats

protected STATS getTotalStats()

registerConditionalStats

public void registerConditionalStats()

unregisterStats

public void unregisterStats()

getCurrentVersion

public int getCurrentVersion()

getFutureVersion

public int getFutureVersion()

setCurrentVersion

public void setCurrentVersion(int version)

setFutureVersion

public void setFutureVersion(int version)

getAllVersionNumbers

public it.unimi.dsi.fastutil.ints.IntSet getAllVersionNumbers()

return a deep copy of all version numbers

getStats

protected STATS getStats(int version)

addVersion

public STATS addVersion(int version)

removeVersion

public void removeVersion(int version)