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.RegionStdOutSink, Canary.ZookeeperStdOutSink

Enclosing class:

Canary

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

Simple implementation of canary sink that allows plotting to a file or standard output.

Constructor Summary

Constructors

Constructor and Description
StdOutSink()

Method Summary

Modifier and Type	Method and Description
long	getReadFailureCount()
Map<String,String>	getReadFailures()
long	getWriteFailureCount()
Map<String,String>	getWriteFailures()
long	incReadFailureCount()
long	incWriteFailureCount()
void	updateReadFailures(String regionName, String serverName)
void	updateWriteFailures(String regionName, String serverName)

Methods inherited from class java.lang.Object

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

Constructor Detail

StdOutSink

public 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

getReadFailures

public Map<String,String> getReadFailures()

Specified by:

getReadFailures in interface Canary.Sink

updateReadFailures

public void updateReadFailures(String regionName,
                               String serverName)

Specified by:

updateReadFailures in interface Canary.Sink

getWriteFailureCount

public long getWriteFailureCount()

Specified by:

getWriteFailureCount in interface Canary.Sink

incWriteFailureCount

public long incWriteFailureCount()

Specified by:

incWriteFailureCount in interface Canary.Sink

getWriteFailures

public Map<String,String> getWriteFailures()

Specified by:

getWriteFailures in interface Canary.Sink

updateWriteFailures

public void updateWriteFailures(String regionName,
                                String serverName)

Specified by:

updateWriteFailures in interface Canary.Sink