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

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
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

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

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