public static class Canary.StdOutSink extends Object implements Canary.Sink
| Modifier and Type | Field and Description |
|---|---|
private AtomicLong |
readFailureCount |
private AtomicLong |
writeFailureCount |
| Constructor and Description |
|---|
Canary.StdOutSink() |
| Modifier and Type | Method and Description |
|---|---|
long |
getReadFailureCount() |
long |
getWriteFailureCount() |
long |
incReadFailureCount() |
void |
publishReadFailure(HRegionInfo region,
Exception e) |
void |
publishReadFailure(HRegionInfo region,
HColumnDescriptor column,
Exception e) |
void |
publishReadTiming(HRegionInfo region,
HColumnDescriptor column,
long msTime) |
void |
publishWriteFailure(HRegionInfo region,
Exception e) |
void |
publishWriteFailure(HRegionInfo region,
HColumnDescriptor column,
Exception e) |
void |
publishWriteTiming(HRegionInfo region,
HColumnDescriptor column,
long msTime) |
private AtomicLong readFailureCount
private AtomicLong writeFailureCount
public long getReadFailureCount()
getReadFailureCount in interface Canary.Sinkpublic long incReadFailureCount()
incReadFailureCount in interface Canary.Sinkpublic void publishReadFailure(HRegionInfo region, Exception e)
publishReadFailure in interface Canary.Sinkpublic void publishReadFailure(HRegionInfo region, HColumnDescriptor column, Exception e)
publishReadFailure in interface Canary.Sinkpublic void publishReadTiming(HRegionInfo region, HColumnDescriptor column, long msTime)
publishReadTiming in interface Canary.Sinkpublic long getWriteFailureCount()
getWriteFailureCount in interface Canary.Sinkpublic void publishWriteFailure(HRegionInfo region, Exception e)
publishWriteFailure in interface Canary.Sinkpublic void publishWriteFailure(HRegionInfo region, HColumnDescriptor column, Exception e)
publishWriteFailure in interface Canary.Sinkpublic void publishWriteTiming(HRegionInfo region, HColumnDescriptor column, long msTime)
publishWriteTiming in interface Canary.SinkCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.