public static class Canary.StdOutSink extends Object implements Canary.Sink
Constructor and Description |
---|
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) |
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–2016 The Apache Software Foundation. All rights reserved.