org.apache.hadoop.hbase.tool

Class Canary.RegionStdOutSink

java.lang.Object

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

org.apache.hadoop.hbase.tool.Canary.RegionStdOutSink

All Implemented Interfaces:

Canary.Sink

Enclosing class:

Canary

public static class Canary.RegionStdOutSink
extends Canary.StdOutSink

By Region, for 'region' mode.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,LongAdder>	perTableReadLatency
private LongAdder	writeLatency

Constructor Summary

Constructors

Constructor and Description
RegionStdOutSink()

Method Summary

Modifier and Type	Method and Description
Map<String,LongAdder>	getReadLatencyMap()
LongAdder	getWriteLatency()
LongAdder	initializeAndGetReadLatencyForTable(String tableName)
void	initializeWriteLatency()
void	publishReadFailure(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, Exception e)
void	publishReadFailure(ServerName serverName, RegionInfo region, Exception e)
void	publishReadTiming(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, long msTime)
void	publishWriteFailure(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, Exception e)
void	publishWriteFailure(ServerName serverName, RegionInfo region, Exception e)
void	publishWriteTiming(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, long msTime)

Methods inherited from class org.apache.hadoop.hbase.tool.Canary.StdOutSink

getReadFailureCount, getReadFailures, getWriteFailureCount, getWriteFailures, incReadFailureCount, incWriteFailureCount, updateReadFailures, updateWriteFailures

Methods inherited from class java.lang.Object

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

Field Detail

perTableReadLatency

private Map<String,LongAdder> perTableReadLatency

writeLatency

private LongAdder writeLatency

Constructor Detail

RegionStdOutSink

public RegionStdOutSink()

Method Detail

publishReadFailure

public void publishReadFailure(ServerName serverName,
                               RegionInfo region,
                               Exception e)

publishReadFailure

public void publishReadFailure(ServerName serverName,
                               RegionInfo region,
                               ColumnFamilyDescriptor column,
                               Exception e)

publishReadTiming

public void publishReadTiming(ServerName serverName,
                              RegionInfo region,
                              ColumnFamilyDescriptor column,
                              long msTime)

publishWriteFailure

public void publishWriteFailure(ServerName serverName,
                                RegionInfo region,
                                Exception e)

publishWriteFailure

public void publishWriteFailure(ServerName serverName,
                                RegionInfo region,
                                ColumnFamilyDescriptor column,
                                Exception e)

publishWriteTiming

public void publishWriteTiming(ServerName serverName,
                               RegionInfo region,
                               ColumnFamilyDescriptor column,
                               long msTime)

getReadLatencyMap

public Map<String,LongAdder> getReadLatencyMap()

initializeAndGetReadLatencyForTable

public LongAdder initializeAndGetReadLatencyForTable(String tableName)

initializeWriteLatency

public void initializeWriteLatency()

getWriteLatency

public LongAdder getWriteLatency()