Package org.apache.druid.server.coordinator.stats

Class CoordinatorRunStats

java.lang.Object

org.apache.druid.server.coordinator.stats.CoordinatorRunStats

@ThreadSafe
public class CoordinatorRunStats
extends Object

Contains statistics typically tracked during a single coordinator run or the runtime of a single coordinator duty.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CoordinatorRunStats.StatHandler

Constructor Summary

Constructors

Constructor	Description
CoordinatorRunStats()
CoordinatorRunStats(Map<Dimension,String> debugDimensions)	Creates a new CoordinatorRunStats.

Method Summary

Modifier and Type	Method	Description
void	add(CoordinatorStat stat, long value)
void	add(CoordinatorStat stat, RowKey rowKey, long value)
void	addToSegmentStat(CoordinatorStat stat, String tier, String datasource, long value)
String	buildStatsTable()	Builds a printable table of all the collected error, info and debug level stats (if there are qualifying debugDimensions) with non-zero values.
void	clear()
static CoordinatorRunStats	empty()
void	forEachEntry(CoordinatorStat stat, CoordinatorRunStats.StatHandler handler)	Invokes the CoordinatorRunStats.StatHandler for each value of the specified stat.
void	forEachStat(CoordinatorRunStats.StatHandler handler)
long	get(CoordinatorStat stat)
long	get(CoordinatorStat stat, RowKey rowKey)
long	getSegmentStat(CoordinatorStat stat, String tier, String datasource)
boolean	hasStat(CoordinatorStat stat)
int	rowCount()
void	updateMax(CoordinatorStat stat, RowKey rowKey, long value)	Updates the maximum value of the stat for the given RowKey if applicable.

Methods inherited from class java.lang.Object

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

Constructor Details

CoordinatorRunStats

public CoordinatorRunStats()

CoordinatorRunStats

public CoordinatorRunStats(Map<Dimension,String> debugDimensions)

Creates a new CoordinatorRunStats.

Parameters:

debugDimensions - Dimension values for which all metrics should be collected and logged.

Method Details

empty

public static CoordinatorRunStats empty()

getSegmentStat

public long getSegmentStat(CoordinatorStat stat,
 String tier,
 String datasource)

get

public long get(CoordinatorStat stat)

get

public long get(CoordinatorStat stat,
 RowKey rowKey)

forEachEntry

public void forEachEntry(CoordinatorStat stat,
 CoordinatorRunStats.StatHandler handler)

Invokes the CoordinatorRunStats.StatHandler for each value of the specified stat.

forEachStat

public void forEachStat(CoordinatorRunStats.StatHandler handler)

buildStatsTable

public String buildStatsTable()

Builds a printable table of all the collected error, info and debug level stats (if there are qualifying debugDimensions) with non-zero values.

hasStat

public boolean hasStat(CoordinatorStat stat)

rowCount

public int rowCount()

clear

public void clear()

add

public void add(CoordinatorStat stat,
 long value)

add

public void add(CoordinatorStat stat,
 RowKey rowKey,
 long value)

addToSegmentStat

public void addToSegmentStat(CoordinatorStat stat,
 String tier,
 String datasource,
 long value)

updateMax

public void updateMax(CoordinatorStat stat,
 RowKey rowKey,
 long value)

Updates the maximum value of the stat for the given RowKey if applicable.