org.apache.hadoop.hbase.util

Class RegionMover.RegionMoverBuilder

java.lang.Object

org.apache.hadoop.hbase.util.RegionMover.RegionMoverBuilder

Enclosing class:

RegionMover

public static class RegionMover.RegionMoverBuilder
extends Object

Builder for Region mover. Use the build() method to create RegionMover object. Has filename(String), excludeFile(String), maxthreads(int), ack(boolean), timeout(int) methods to set the corresponding options

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	ack
private org.apache.hadoop.conf.Configuration	conf
private String	defaultDir
private String	excludeFile
private String	filename
private String	hostname
private int	maxthreads
(package private) int	port
private int	timeout

Constructor Summary

Constructors

Constructor and Description
RegionMoverBuilder(String hostname)
RegionMoverBuilder(String hostname, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
RegionMover.RegionMoverBuilder	ack(boolean ack) Set ack/noAck mode.
RegionMover	build() This method builds the appropriate RegionMover object which can then be used to load/unload using load and unload methods
private static org.apache.hadoop.conf.Configuration	createConf() Creates a new configuration and sets region mover specific overrides
RegionMover.RegionMoverBuilder	excludeFile(String excludefile) Path of file containing hostnames to be excluded during region movement.
RegionMover.RegionMoverBuilder	filename(String filename) Path of file where regions will be written to during unloading/read from during loading
RegionMover.RegionMoverBuilder	maxthreads(int threads) Set the max number of threads that will be used to move regions
RegionMover.RegionMoverBuilder	timeout(int timeout) Set the timeout for Load/Unload operation in seconds.This is a global timeout,threadpool for movers also have a separate time which is hbase.move.wait.max * number of regions to load/unload

Methods inherited from class java.lang.Object

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

Field Detail

ack

private boolean ack

maxthreads

private int maxthreads

timeout

private int timeout

hostname

private String hostname

filename

private String filename

excludeFile

private String excludeFile

defaultDir

private String defaultDir

port

final int port

conf

private final org.apache.hadoop.conf.Configuration conf

Constructor Detail

RegionMoverBuilder

public RegionMoverBuilder(String hostname)

RegionMoverBuilder

public RegionMoverBuilder(String hostname,
                          org.apache.hadoop.conf.Configuration conf)

Parameters:

hostname - Hostname to unload regions from or load regions to. Can be either hostname or hostname:port.

conf - Configuration object

Method Detail

createConf

private static org.apache.hadoop.conf.Configuration createConf()

Creates a new configuration and sets region mover specific overrides

filename

public RegionMover.RegionMoverBuilder filename(String filename)

Path of file where regions will be written to during unloading/read from during loading

Parameters:

filename -

Returns:

RegionMoverBuilder object

maxthreads

public RegionMover.RegionMoverBuilder maxthreads(int threads)

Set the max number of threads that will be used to move regions

excludeFile

public RegionMover.RegionMoverBuilder excludeFile(String excludefile)

Path of file containing hostnames to be excluded during region movement. Exclude file should have 'host:port' per line. Port is mandatory here as we can have many RS running on a single host.

ack

public RegionMover.RegionMoverBuilder ack(boolean ack)

Set ack/noAck mode.

In ack mode regions are acknowledged before and after moving and the move is retried hbase.move.retries.max times, if unsuccessful we quit with exit code 1.No Ack mode is a best effort mode,each region movement is tried once.This can be used during graceful shutdown as even if we have a stuck region,upon shutdown it'll be reassigned anyway.

Parameters:

ack -

Returns:

RegionMoverBuilder object

timeout

public RegionMover.RegionMoverBuilder timeout(int timeout)

Set the timeout for Load/Unload operation in seconds.This is a global timeout,threadpool for movers also have a separate time which is hbase.move.wait.max * number of regions to load/unload

Parameters:

timeout - in seconds

Returns:

RegionMoverBuilder object

build

public RegionMover build()
                  throws IOException

This method builds the appropriate RegionMover object which can then be used to load/unload using load and unload methods

Returns:

RegionMover object

Throws:

IOException