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 boolean	readAllCF
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, boolean readAllCF)

Method Summary

Modifier and Type	Method and Description
Void	call()
private ColumnFamilyDescriptor	randomPickOneColumnFamily(ColumnFamilyDescriptor[] cfs)
Void	read()
private Void	readColumnFamily(Table table, ColumnFamilyDescriptor column)
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

readAllCF

private boolean readAllCF

Constructor Detail

RegionTask

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

Method Detail

call

public Void call()

Specified by:

call in interface Callable<Void>

readColumnFamily

private Void readColumnFamily(Table table,
                              ColumnFamilyDescriptor column)

randomPickOneColumnFamily

private ColumnFamilyDescriptor randomPickOneColumnFamily(ColumnFamilyDescriptor[] cfs)

read

public Void read()

write

private Void write()

Check writes for the canary table