public class FireDepartmentMetrics extends Object
Constructor and Description |
---|
FireDepartmentMetrics() |
public void incrementProcessed()
public void incrementThrownAway()
public void incrementUnparseable()
public void incrementRowOutputCount(long numRows)
public void incrementNumPersists()
public void incrementPersistTimeMillis(long millis)
public void incrementPersistBackPressureMillis(long millis)
public void incrementFailedPersists()
public void incrementFailedHandoffs()
public void incrementMergeTimeMillis(long millis)
public void incrementMergeCpuTime(long mergeTime)
public void incrementPersistCpuTime(long persistTime)
public void incrementHandOffCount()
public void setSinkCount(long sinkCount)
public void reportMessageMaxTimestamp(long messageMaxTimestamp)
public long processed()
public long thrownAway()
public long unparseable()
public long rowOutput()
public long numPersists()
public long persistTimeMillis()
public long persistBackPressureMillis()
public long failedPersists()
public long failedHandoffs()
public long mergeTimeMillis()
public long mergeCpuTime()
public long persistCpuTime()
public long handOffCount()
public long sinkCount()
public long messageMaxTimestamp()
public long messageGap()
public FireDepartmentMetrics snapshot()
public FireDepartmentMetrics merge(FireDepartmentMetrics other)
Copyright © 2011–2017. All rights reserved.