org.apache.hadoop.hbase.tool

Class CanaryTool.RegionTask

java.lang.Object

org.apache.hadoop.hbase.tool.CanaryTool.RegionTask

All Implemented Interfaces:

Callable<Void>

Enclosing class:

CanaryTool

static class CanaryTool.RegionTask
extends Object
implements Callable<Void>

Run a single Region Task and then exit. For each column family of the Region, get one row and output latency or failure.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CanaryTool.RegionTask.TaskType

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	connection
private boolean	rawScanEnabled
private LongAdder	readWriteLatency
private RegionInfo	region
private ServerName	serverName
private CanaryTool.RegionStdOutSink	sink
private CanaryTool.RegionTask.TaskType	taskType

Constructor Summary

Constructors

Constructor and Description
RegionTask(Connection connection, RegionInfo region, ServerName serverName, CanaryTool.RegionStdOutSink sink, CanaryTool.RegionTask.TaskType taskType, boolean rawScanEnabled, LongAdder rwLatency)

Method Summary

Modifier and Type	Method and Description
Void	call()
Void	read()
private Void	write() Check writes for the canary table

Methods inherited from class java.lang.Object

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

Field Detail

connection

private Connection connection

region

private RegionInfo region

sink

private CanaryTool.RegionStdOutSink sink

taskType

private CanaryTool.RegionTask.TaskType taskType

rawScanEnabled

private boolean rawScanEnabled

serverName

private ServerName serverName

readWriteLatency

private LongAdder readWriteLatency

Constructor Detail

RegionTask

RegionTask(Connection connection,
           RegionInfo region,
           ServerName serverName,
           CanaryTool.RegionStdOutSink sink,
           CanaryTool.RegionTask.TaskType taskType,
           boolean rawScanEnabled,
           LongAdder rwLatency)

Method Detail

call

public Void call()

Specified by:

call in interface Callable<Void>

read

public Void read()

write

private Void write()

Check writes for the canary table