org.apache.hadoop.hbase.tool
Class Canary.StdOutSink

java.lang.Object
  org.apache.hadoop.hbase.tool.Canary.StdOutSink

All Implemented Interfaces:

Canary.Sink

Direct Known Subclasses:

Canary.RegionServerStdOutSink, Canary.ZookeeperStdOutSink

Enclosing class:

Canary

public static class Canary.StdOutSink
extends Object
implements Canary.Sink

Constructor Summary

Canary.StdOutSink()

Method Summary

long	getReadFailureCount()
Map<String,String>	getReadFailures()
long	getWriteFailureCount()
Map<String,String>	getWriteFailures()
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)
void	updateReadFailedHostList(HRegionInfo region, String serverName)
void	updateWriteFailedHostList(HRegionInfo region, String serverName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Canary.StdOutSink

public Canary.StdOutSink()

Method Detail

getReadFailureCount

public long getReadFailureCount()

Specified by:

getReadFailureCount in interface Canary.Sink

incReadFailureCount

public long incReadFailureCount()

Specified by:

incReadFailureCount in interface Canary.Sink

publishReadFailure

public void publishReadFailure(HRegionInfo region,
                               Exception e)

Specified by:

publishReadFailure in interface Canary.Sink

publishReadFailure

public void publishReadFailure(HRegionInfo region,
                               HColumnDescriptor column,
                               Exception e)

Specified by:

publishReadFailure in interface Canary.Sink

updateReadFailedHostList

public void updateReadFailedHostList(HRegionInfo region,
                                     String serverName)

Specified by:

updateReadFailedHostList in interface Canary.Sink

publishReadTiming

public void publishReadTiming(HRegionInfo region,
                              HColumnDescriptor column,
                              long msTime)

Specified by:

publishReadTiming in interface Canary.Sink

getReadFailures

public Map<String,String> getReadFailures()

Specified by:

getReadFailures in interface Canary.Sink

getWriteFailures

public Map<String,String> getWriteFailures()

Specified by:

getWriteFailures in interface Canary.Sink

getWriteFailureCount

public long getWriteFailureCount()

Specified by:

getWriteFailureCount in interface Canary.Sink

publishWriteFailure

public void publishWriteFailure(HRegionInfo region,
                                Exception e)

Specified by:

publishWriteFailure in interface Canary.Sink

publishWriteFailure

public void publishWriteFailure(HRegionInfo region,
                                HColumnDescriptor column,
                                Exception e)

Specified by:

publishWriteFailure in interface Canary.Sink

publishWriteTiming

public void publishWriteTiming(HRegionInfo region,
                               HColumnDescriptor column,
                               long msTime)

Specified by:

publishWriteTiming in interface Canary.Sink

updateWriteFailedHostList

public void updateWriteFailedHostList(HRegionInfo region,
                                      String serverName)

Specified by:

updateWriteFailedHostList in interface Canary.Sink