public static class CanaryTool.RegionStdOutSink extends CanaryTool.StdOutSink
| Constructor and Description |
|---|
CanaryTool.RegionStdOutSink() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,AtomicLong> |
getReadLatencyMap() |
Map<String,CanaryTool.RegionTaskResult> |
getRegionMap() |
int |
getTotalExpectedRegions() |
AtomicLong |
getWriteLatency() |
AtomicLong |
initializeAndGetReadLatencyForTable(String tableName) |
void |
initializeWriteLatency() |
void |
publishReadFailure(ServerName serverName,
HRegionInfo region,
Exception e) |
void |
publishReadFailure(ServerName serverName,
HRegionInfo region,
HColumnDescriptor column,
Exception e) |
void |
publishReadTiming(ServerName serverName,
HRegionInfo region,
HColumnDescriptor column,
long msTime) |
void |
publishWriteFailure(ServerName serverName,
HRegionInfo region,
Exception e) |
void |
publishWriteFailure(ServerName serverName,
HRegionInfo region,
HColumnDescriptor column,
Exception e) |
void |
publishWriteTiming(ServerName serverName,
HRegionInfo region,
HColumnDescriptor column,
long msTime) |
getReadFailureCount, getReadFailures, getReadSuccessCount, getWriteFailureCount, getWriteFailures, getWriteSuccessCount, incReadFailureCount, incReadSuccessCount, incWriteFailureCount, incWriteSuccessCount, updateReadFailures, updateWriteFailurespublic void publishReadFailure(ServerName serverName, HRegionInfo region, Exception e)
public void publishReadFailure(ServerName serverName, HRegionInfo region, HColumnDescriptor column, Exception e)
public void publishReadTiming(ServerName serverName, HRegionInfo region, HColumnDescriptor column, long msTime)
public void publishWriteFailure(ServerName serverName, HRegionInfo region, Exception e)
public void publishWriteFailure(ServerName serverName, HRegionInfo region, HColumnDescriptor column, Exception e)
public void publishWriteTiming(ServerName serverName, HRegionInfo region, HColumnDescriptor column, long msTime)
public Map<String,AtomicLong> getReadLatencyMap()
public AtomicLong initializeAndGetReadLatencyForTable(String tableName)
public void initializeWriteLatency()
public AtomicLong getWriteLatency()
public Map<String,CanaryTool.RegionTaskResult> getRegionMap()
public int getTotalExpectedRegions()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.