@InterfaceAudience.LimitedPrivate(value="Tools") public class CanaryTool extends Object implements org.apache.hadoop.util.Tool, Canary
Modifier and Type | Class and Description |
---|---|
static class |
CanaryTool.Monitor
A Monitor super-class can be extended by users
|
static class |
CanaryTool.RegionServerStdOutSink
By RegionServer, for 'regionserver' mode.
|
static class |
CanaryTool.RegionStdOutSink
By Region, for 'region' mode.
|
static class |
CanaryTool.RegionTaskResult
Canary region mode-specific data structure which stores information about each region
to be scanned
|
static interface |
CanaryTool.Sink
Sink interface used by the canary to output information
|
static class |
CanaryTool.StdOutSink
Simple implementation of canary sink that allows plotting to a file or standard output.
|
static class |
CanaryTool.ZookeeperStdOutSink
Output for 'zookeeper' mode.
|
Canary.Factory
Modifier and Type | Field and Description |
---|---|
static TableName |
DEFAULT_WRITE_TABLE_NAME |
static String |
HBASE_CANARY_FAIL_ON_ERROR |
static String |
HBASE_CANARY_REGION_READ_TABLE_TIMEOUT |
static String |
HBASE_CANARY_REGION_WRITE_SNIFFING |
static String |
HBASE_CANARY_REGION_WRITE_TABLE_NAME |
static String |
HBASE_CANARY_REGION_WRITE_TABLE_TIMEOUT |
static String |
HBASE_CANARY_REGIONSERVER_ALL_REGIONS |
static String |
HBASE_CANARY_TIMEOUT |
static String |
HBASE_CANARY_USE_REGEX |
static String |
HBASE_CANARY_ZOOKEEPER_PERMITTED_FAILURES |
Constructor and Description |
---|
CanaryTool() |
CanaryTool(ExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
int |
checkRegions(String[] targets)
Run Canary in Region mode.
|
int |
checkRegionServers(String[] targets)
Runs Canary in Region server mode.
|
int |
checkZooKeeper()
Runs Canary in Zookeeper mode.
|
org.apache.hadoop.conf.Configuration |
getConf() |
Map<String,String> |
getReadFailures() |
Map<String,String> |
getWriteFailures() |
static void |
main(String[] args) |
int |
run(String[] args) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
public static final TableName DEFAULT_WRITE_TABLE_NAME
public static final String HBASE_CANARY_REGIONSERVER_ALL_REGIONS
public static final String HBASE_CANARY_REGION_WRITE_SNIFFING
public static final String HBASE_CANARY_REGION_WRITE_TABLE_TIMEOUT
public static final String HBASE_CANARY_REGION_WRITE_TABLE_NAME
public static final String HBASE_CANARY_REGION_READ_TABLE_TIMEOUT
public static final String HBASE_CANARY_ZOOKEEPER_PERMITTED_FAILURES
public static final String HBASE_CANARY_USE_REGEX
public static final String HBASE_CANARY_TIMEOUT
public static final String HBASE_CANARY_FAIL_ON_ERROR
public CanaryTool()
public CanaryTool(ExecutorService executor)
public int checkRegions(String[] targets) throws Exception
Canary
checkRegions
in interface Canary
targets
- -- list of monitor tables.Exception
public int checkRegionServers(String[] targets) throws Exception
Canary
checkRegionServers
in interface Canary
targets
- -- list of monitor tables.Exception
public int checkZooKeeper() throws Exception
Canary
checkZooKeeper
in interface Canary
Exception
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
public int run(String[] args) throws Exception
run
in interface org.apache.hadoop.util.Tool
Exception
public Map<String,String> getReadFailures()
getReadFailures
in interface Canary
public Map<String,String> getWriteFailures()
getWriteFailures
in interface Canary
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.