org.apache.hadoop.hbase.tool

Class CanaryTool.RegionStdOutSink

java.lang.Object

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

org.apache.hadoop.hbase.tool.CanaryTool.RegionStdOutSink

All Implemented Interfaces:

CanaryTool.Sink

Enclosing class:

CanaryTool

public static class CanaryTool.RegionStdOutSink
extends CanaryTool.StdOutSink

By Region, for 'region' mode.

Field Summary

Fields

Modifier and Type	Field and Description
private ConcurrentMap<ServerName,LongAdder>	perServerFailuresCount
private ConcurrentMap<String,LongAdder>	perTableFailuresCount
private Map<String,LongAdder>	perTableReadLatency
private ConcurrentMap<String,List<CanaryTool.RegionTaskResult>>	regionMap
private LongAdder	writeLatency

Constructor Summary

Constructors

Constructor and Description
RegionStdOutSink()

Method Summary

Modifier and Type	Method and Description
ConcurrentMap<ServerName,LongAdder>	getPerServerFailuresCount()
ConcurrentMap<String,LongAdder>	getPerTableFailuresCount()
Map<String,LongAdder>	getReadLatencyMap()
ConcurrentMap<String,List<CanaryTool.RegionTaskResult>>	getRegionMap()
int	getTotalExpectedRegions()
LongAdder	getWriteLatency()
private void	incFailuresCountDetails(ServerName serverName, RegionInfo region)
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)
void	resetFailuresCountDetails()

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

getReadFailureCount, getReadFailures, getReadSuccessCount, getWriteFailureCount, getWriteFailures, getWriteSuccessCount, incReadFailureCount, incReadSuccessCount, incWriteFailureCount, incWriteSuccessCount, 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

regionMap

private final ConcurrentMap<String,List<CanaryTool.RegionTaskResult>> regionMap

perServerFailuresCount

private ConcurrentMap<ServerName,LongAdder> perServerFailuresCount

perTableFailuresCount

private ConcurrentMap<String,LongAdder> perTableFailuresCount

Constructor Detail

RegionStdOutSink

public RegionStdOutSink()

Method Detail

getPerServerFailuresCount

public ConcurrentMap<ServerName,LongAdder> getPerServerFailuresCount()

getPerTableFailuresCount

public ConcurrentMap<String,LongAdder> getPerTableFailuresCount()

resetFailuresCountDetails

public void resetFailuresCountDetails()

incFailuresCountDetails

private void incFailuresCountDetails(ServerName serverName,
                                     RegionInfo region)

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()

getRegionMap

public ConcurrentMap<String,List<CanaryTool.RegionTaskResult>> getRegionMap()

getTotalExpectedRegions

public int getTotalExpectedRegions()