org.apache.hadoop.hbase.tool

Class CanaryTool.RegionMonitor

java.lang.Object

org.apache.hadoop.hbase.tool.CanaryTool.Monitor

org.apache.hadoop.hbase.tool.CanaryTool.RegionMonitor

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

Enclosing class:

CanaryTool

private static class CanaryTool.RegionMonitor
extends CanaryTool.Monitor

A monitor for region mode.

Field Summary

Fields

Modifier and Type	Field and Description
private int	checkPeriod
private HashMap<String,Long>	configuredReadTableTimeouts This is a timeout per table.
private long	configuredWriteTableTimeout
private static int	DEFAULT_WRITE_DATA_TTL
private static int	DEFAULT_WRITE_TABLE_CHECK_PERIOD
private long	lastCheckTime
private boolean	rawScanEnabled
private boolean	readAllCF
private float	regionsLowerLimit
private float	regionsUpperLimit
private int	writeDataTTL
private boolean	writeSniffing
private TableName	writeTableName

Fields inherited from class org.apache.hadoop.hbase.tool.CanaryTool.Monitor

admin, allowedFailures, connection, done, errorCode, executor, initialized, sink, targets, treatFailureAsError, useRegExp

Constructor Summary

Constructors

Constructor and Description
RegionMonitor(Connection connection, String[] monitorTargets, boolean useRegExp, CanaryTool.Sink sink, ExecutorService executor, boolean writeSniffing, TableName writeTableName, boolean treatFailureAsError, HashMap<String,Long> configuredReadTableTimeouts, long configuredWriteTableTimeout, long allowedFailures)

Method Summary

Modifier and Type	Method and Description
private void	checkWriteTableDistribution()
private void	createWriteTable(int numberOfServers)
private String[]	generateMonitorTables(String[] monitorTargets)
private CanaryTool.RegionStdOutSink	getSink()
void	run()
private List<Future<Void>>	sniff(CanaryTool.RegionTask.TaskType taskType, CanaryTool.RegionStdOutSink regionSink)

Methods inherited from class org.apache.hadoop.hbase.tool.CanaryTool.Monitor

close, finalCheckForErrors, hasError, initAdmin, isDone

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_WRITE_TABLE_CHECK_PERIOD

private static final int DEFAULT_WRITE_TABLE_CHECK_PERIOD

See Also:

Constant Field Values

DEFAULT_WRITE_DATA_TTL

private static final int DEFAULT_WRITE_DATA_TTL

See Also:

Constant Field Values

lastCheckTime

private long lastCheckTime

writeSniffing

private boolean writeSniffing

writeTableName

private TableName writeTableName

writeDataTTL

private int writeDataTTL

regionsLowerLimit

private float regionsLowerLimit

regionsUpperLimit

private float regionsUpperLimit

checkPeriod

private int checkPeriod

rawScanEnabled

private boolean rawScanEnabled

readAllCF

private boolean readAllCF

configuredReadTableTimeouts

private HashMap<String,Long> configuredReadTableTimeouts

This is a timeout per table. If read of each region in the table aggregated takes longer than what is configured here, we log an ERROR rather than just an INFO.

configuredWriteTableTimeout

private long configuredWriteTableTimeout

Constructor Detail

RegionMonitor

public RegionMonitor(Connection connection,
                     String[] monitorTargets,
                     boolean useRegExp,
                     CanaryTool.Sink sink,
                     ExecutorService executor,
                     boolean writeSniffing,
                     TableName writeTableName,
                     boolean treatFailureAsError,
                     HashMap<String,Long> configuredReadTableTimeouts,
                     long configuredWriteTableTimeout,
                     long allowedFailures)

Method Detail

getSink

private CanaryTool.RegionStdOutSink getSink()

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class CanaryTool.Monitor

generateMonitorTables

private String[] generateMonitorTables(String[] monitorTargets)
                                throws IOException

Returns:

List of tables to use in test.

Throws:

IOException

sniff

private List<Future<Void>> sniff(CanaryTool.RegionTask.TaskType taskType,
                                 CanaryTool.RegionStdOutSink regionSink)
                          throws Exception

Throws:

Exception

checkWriteTableDistribution

private void checkWriteTableDistribution()
                                  throws IOException

Throws:

IOException

createWriteTable

private void createWriteTable(int numberOfServers)
                       throws IOException

Throws:

IOException