Package 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	Description
private ConcurrentMap<ServerName,LongAdder>	perServerFailuresCount
private ConcurrentMap<String,LongAdder>	perTableFailuresCount
private Map<String,LongAdder>	perTableReadLatency
private final ConcurrentMap<String,List<CanaryTool.RegionTaskResult>>	regionMap
private LongAdder	writeLatency

Constructor Summary

Constructors

Constructor	Description
RegionStdOutSink()

Method Summary

Modifier and Type	Method	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, Exception e)
void	publishReadFailure(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, Exception e)
void	publishReadTiming(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, long msTime)
void	publishWriteFailure(ServerName serverName, RegionInfo region, Exception e)
void	publishWriteFailure(ServerName serverName, RegionInfo region, ColumnFamilyDescriptor column, 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 Details

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 Details

RegionStdOutSink

public RegionStdOutSink()

Method Details

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