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.

Field Summary

Fields

Modifier and Type	Field and Description
private AtomicLong	readFailureCount
private Map<String,String>	readFailures
private AtomicLong	writeFailureCount
private Map<String,String>	writeFailures

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

Field Detail

readFailureCount

private AtomicLong readFailureCount

writeFailureCount

private AtomicLong writeFailureCount

readFailures

private Map<String,String> readFailures

writeFailures

private Map<String,String> writeFailures

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