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.Sink
public long incReadFailureCount()
incReadFailureCount
in interface Canary.Sink
public void publishReadFailure(HRegionInfo region, Exception e)
publishReadFailure
in interface Canary.Sink
public void publishReadFailure(HRegionInfo region, HColumnDescriptor column, Exception e)
publishReadFailure
in interface Canary.Sink
public void publishReadTiming(HRegionInfo region, HColumnDescriptor column, long msTime)
publishReadTiming
in interface Canary.Sink
public long getWriteFailureCount()
getWriteFailureCount
in interface Canary.Sink
public void publishWriteFailure(HRegionInfo region, Exception e)
publishWriteFailure
in interface Canary.Sink
public void publishWriteFailure(HRegionInfo region, HColumnDescriptor column, Exception e)
publishWriteFailure
in interface Canary.Sink
public void publishWriteTiming(HRegionInfo region, HColumnDescriptor column, long msTime)
publishWriteTiming
in interface Canary.Sink
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.