private static class CanaryTool.RegionServerMonitor extends CanaryTool.Monitor
Modifier and Type | Field and Description |
---|---|
private boolean |
allRegions |
admin, allowedFailures, connection, done, errorCode, executor, initialized, sink, targets, treatFailureAsError, useRegExp
Constructor and Description |
---|
RegionServerMonitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
CanaryTool.Sink sink,
ExecutorService executor,
boolean allRegions,
boolean treatFailureAsError,
long allowedFailures) |
Modifier and Type | Method and Description |
---|---|
private boolean |
checkNoTableNames() |
private Map<String,List<RegionInfo>> |
doFilterRegionServerByName(Map<String,List<RegionInfo>> fullRsAndRMap) |
private Map<String,List<RegionInfo>> |
filterRegionServerByName() |
private Map<String,List<RegionInfo>> |
getAllRegionServerByName() |
private CanaryTool.RegionServerStdOutSink |
getSink() |
private void |
monitorRegionServers(Map<String,List<RegionInfo>> rsAndRMap,
CanaryTool.RegionServerStdOutSink regionServerSink) |
void |
run() |
close, finalCheckForErrors, hasError, initAdmin, isDone
private boolean allRegions
public RegionServerMonitor(Connection connection, String[] monitorTargets, boolean useRegExp, CanaryTool.Sink sink, ExecutorService executor, boolean allRegions, boolean treatFailureAsError, long allowedFailures)
private CanaryTool.RegionServerStdOutSink getSink()
public void run()
run
in interface Runnable
run
in class CanaryTool.Monitor
private boolean checkNoTableNames()
private void monitorRegionServers(Map<String,List<RegionInfo>> rsAndRMap, CanaryTool.RegionServerStdOutSink regionServerSink)
private Map<String,List<RegionInfo>> filterRegionServerByName()
private Map<String,List<RegionInfo>> getAllRegionServerByName()
private Map<String,List<RegionInfo>> doFilterRegionServerByName(Map<String,List<RegionInfo>> fullRsAndRMap)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.