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
By Region, for 'region' mode.
-
Field Summary
Modifier and TypeFieldDescriptionprivate ConcurrentMap<ServerName,
LongAdder> private ConcurrentMap<String,
LongAdder> private final ConcurrentMap<String,
List<CanaryTool.RegionTaskResult>> private LongAdder
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
private void
incFailuresCountDetails
(ServerName serverName, RegionInfo region) initializeAndGetReadLatencyForTable
(String tableName) void
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
Methods inherited from class org.apache.hadoop.hbase.tool.CanaryTool.StdOutSink
getReadFailureCount, getReadFailures, getReadSuccessCount, getWriteFailureCount, getWriteFailures, getWriteSuccessCount, incReadFailureCount, incReadSuccessCount, incWriteFailureCount, incWriteSuccessCount, isStopped, stop, updateReadFailures, updateWriteFailures
-
Field Details
-
perTableReadLatency
-
writeLatency
-
regionMap
-
perServerFailuresCount
-
perTableFailuresCount
-
-
Constructor Details
-
RegionStdOutSink
public RegionStdOutSink()
-
-
Method Details
-
getPerServerFailuresCount
-
getPerTableFailuresCount
-
resetFailuresCountDetails
-
incFailuresCountDetails
-
publishReadFailure
-
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
-
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
-
initializeAndGetReadLatencyForTable
-
initializeWriteLatency
-
getWriteLatency
-
getRegionMap
-
getTotalExpectedRegions
-