@ThreadSafe public class DatumStatusCounter extends Object implements DatumStatusCounterMXBean
Modifier and Type | Field and Description |
---|---|
static String |
NAME_TEMPLATE |
Constructor and Description |
---|
DatumStatusCounter(String id) |
DatumStatusCounter(String id,
String streamIdentifier,
long startedAt) |
Modifier and Type | Method and Description |
---|---|
double |
getFailRate()
Get the failure rate.
|
long |
getNumFailed()
Get number of failed datums
|
long |
getNumPassed()
Get number of passed datums
|
void |
incrementFailedCount() |
void |
incrementFailedCount(long delta) |
void |
incrementPassedCount() |
void |
incrementPassedCount(long delta) |
public static final String NAME_TEMPLATE
public DatumStatusCounter(String id)
public void incrementFailedCount()
public void incrementFailedCount(long delta)
public void incrementPassedCount()
public void incrementPassedCount(long delta)
public double getFailRate()
DatumStatusCounterMXBean
getFailRate
in interface DatumStatusCounterMXBean
public long getNumFailed()
DatumStatusCounterMXBean
getNumFailed
in interface DatumStatusCounterMXBean
public long getNumPassed()
DatumStatusCounterMXBean
getNumPassed
in interface DatumStatusCounterMXBean
Copyright © 2017 The Apache Software Foundation. All rights reserved.