io.druid.segment.realtime

Class FireDepartmentMetrics

java.lang.Object

io.druid.segment.realtime.FireDepartmentMetrics

public class FireDepartmentMetrics
extends Object

Constructor Summary

Constructors

Constructor and Description
FireDepartmentMetrics()

Method Summary

Methods

Modifier and Type	Method and Description
long	failedHandoffs()
long	failedPersists()
void	incrementFailedHandoffs()
void	incrementFailedPersists()
void	incrementNumPersists()
void	incrementPersistBackPressureMillis(long millis)
void	incrementPersistTimeMillis(long millis)
void	incrementProcessed()
void	incrementRowOutputCount(long numRows)
void	incrementThrownAway()
void	incrementUnparseable()
FireDepartmentMetrics	merge(FireDepartmentMetrics other) merge other FireDepartmentMetrics, will modify this object's data
long	numPersists()
long	persistBackPressureMillis()
long	persistTimeMillis()
long	processed()
long	rowOutput()
FireDepartmentMetrics	snapshot()
long	thrownAway()
long	unparseable()

Methods inherited from class java.lang.Object

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

Constructor Detail

FireDepartmentMetrics

public FireDepartmentMetrics()

Method Detail

incrementProcessed

public void incrementProcessed()

incrementThrownAway

public void incrementThrownAway()

incrementUnparseable

public void incrementUnparseable()

incrementRowOutputCount

public void incrementRowOutputCount(long numRows)

incrementNumPersists

public void incrementNumPersists()

incrementPersistTimeMillis

public void incrementPersistTimeMillis(long millis)

incrementPersistBackPressureMillis

public void incrementPersistBackPressureMillis(long millis)

incrementFailedPersists

public void incrementFailedPersists()

incrementFailedHandoffs

public void incrementFailedHandoffs()

processed

public long processed()

thrownAway

public long thrownAway()

unparseable

public long unparseable()

rowOutput

public long rowOutput()

numPersists

public long numPersists()

persistTimeMillis

public long persistTimeMillis()

persistBackPressureMillis

public long persistBackPressureMillis()

failedPersists

public long failedPersists()

failedHandoffs

public long failedHandoffs()

snapshot

public FireDepartmentMetrics snapshot()

merge

public FireDepartmentMetrics merge(FireDepartmentMetrics other)

merge other FireDepartmentMetrics, will modify this object's data

Returns:

this object