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