Package org.apache.hadoop.hbase.tool

Class CanaryTool.StdOutSink

java.lang.Object

org.apache.hadoop.hbase.tool.CanaryTool.StdOutSink

All Implemented Interfaces:

CanaryTool.Sink

Direct Known Subclasses:

CanaryTool.RegionServerStdOutSink, CanaryTool.RegionStdOutSink, CanaryTool.ZookeeperStdOutSink

Enclosing class:

CanaryTool

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

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
StdOutSink()

Method Summary

Modifier and Type	Method	Description
long	getReadFailureCount()
Map<String,String>	getReadFailures()
long	getReadSuccessCount()
long	getWriteFailureCount()
Map<String,String>	getWriteFailures()
long	getWriteSuccessCount()
long	incReadFailureCount()
long	incReadSuccessCount()
long	incWriteFailureCount()
long	incWriteSuccessCount()
boolean	isStopped()
void	stop()
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 Details

readFailureCount

private AtomicLong readFailureCount

writeFailureCount

private AtomicLong writeFailureCount

readSuccessCount

private AtomicLong readSuccessCount

writeSuccessCount

private AtomicLong writeSuccessCount

readFailures

private Map<String,String> readFailures

writeFailures

private Map<String,String> writeFailures

stopped

private volatile boolean stopped

Constructor Details

StdOutSink

public StdOutSink()

Method Details

getReadFailureCount

public long getReadFailureCount()

Specified by:

getReadFailureCount in interface CanaryTool.Sink

incReadFailureCount

public long incReadFailureCount()

Specified by:

incReadFailureCount in interface CanaryTool.Sink

getReadFailures

public Map<String,String> getReadFailures()

Specified by:

getReadFailures in interface CanaryTool.Sink

updateReadFailures

public void updateReadFailures(String regionName,
 String serverName)

Specified by:

updateReadFailures in interface CanaryTool.Sink

getWriteFailureCount

public long getWriteFailureCount()

Specified by:

getWriteFailureCount in interface CanaryTool.Sink

incWriteFailureCount

public long incWriteFailureCount()

Specified by:

incWriteFailureCount in interface CanaryTool.Sink

getWriteFailures

public Map<String,String> getWriteFailures()

Specified by:

getWriteFailures in interface CanaryTool.Sink

updateWriteFailures

public void updateWriteFailures(String regionName,
 String serverName)

Specified by:

updateWriteFailures in interface CanaryTool.Sink

getReadSuccessCount

public long getReadSuccessCount()

Specified by:

getReadSuccessCount in interface CanaryTool.Sink

incReadSuccessCount

public long incReadSuccessCount()

Specified by:

incReadSuccessCount in interface CanaryTool.Sink

getWriteSuccessCount

public long getWriteSuccessCount()

Specified by:

getWriteSuccessCount in interface CanaryTool.Sink

incWriteSuccessCount

public long incWriteSuccessCount()

Specified by:

incWriteSuccessCount in interface CanaryTool.Sink

stop

public void stop()

Specified by:

stop in interface CanaryTool.Sink

isStopped

public boolean isStopped()

Specified by:

isStopped in interface CanaryTool.Sink