org.apache.hadoop.hbase.util

Class MoveWithAck

java.lang.Object

org.apache.hadoop.hbase.util.MoveWithAck

All Implemented Interfaces:

Callable<Boolean>

@InterfaceAudience.Private
class MoveWithAck
extends Object
implements Callable<Boolean>

Move Regions and make sure that they are up on the target server.If a region movement fails we exit as failure

Field Summary

Fields

Modifier and Type	Field and Description
private Admin	admin
private Connection	conn
private static org.slf4j.Logger	LOG
private List<RegionInfo>	movedRegions
private RegionInfo	region
private ServerName	sourceServer
private ServerName	targetServer

Constructor Summary

Constructors

Constructor and Description
MoveWithAck(Connection conn, RegionInfo regionInfo, ServerName sourceServer, ServerName targetServer, List<RegionInfo> movedRegions)

Method Summary

Modifier and Type	Method and Description
Boolean	call()
(package private) static ServerName	getServerNameForRegion(RegionInfo region, Admin admin, Connection conn) Get servername that is up in hbase:meta hosting the given region.
private static String	getTimeDiffInSec(long startTime)
private boolean	isSameServer(RegionInfo region, ServerName serverName) Returns true if passed region is still on serverName when we look at hbase:meta.
private void	isSuccessfulScan(RegionInfo region) Tries to scan a row from passed region

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

region

private final RegionInfo region

targetServer

private final ServerName targetServer

movedRegions

private final List<RegionInfo> movedRegions

sourceServer

private final ServerName sourceServer

conn

private final Connection conn

admin

private final Admin admin

Constructor Detail

MoveWithAck

MoveWithAck(Connection conn,
            RegionInfo regionInfo,
            ServerName sourceServer,
            ServerName targetServer,
            List<RegionInfo> movedRegions)
     throws IOException

Throws:

IOException

Method Detail

call

public Boolean call()
             throws IOException,
                    InterruptedException

Specified by:

call in interface Callable<Boolean>

Throws:

IOException

InterruptedException

getTimeDiffInSec

private static String getTimeDiffInSec(long startTime)

isSuccessfulScan

private void isSuccessfulScan(RegionInfo region)
                       throws IOException

Tries to scan a row from passed region

Throws:

IOException

isSameServer

private boolean isSameServer(RegionInfo region,
                             ServerName serverName)
                      throws IOException

Returns true if passed region is still on serverName when we look at hbase:meta.

Returns:

true if region is hosted on serverName otherwise false

Throws:

IOException

getServerNameForRegion

static ServerName getServerNameForRegion(RegionInfo region,
                                         Admin admin,
                                         Connection conn)
                                  throws IOException

Get servername that is up in hbase:meta hosting the given region. this is hostname + port + startcode comma-delimited. Can return null

Returns:

regionServer hosting the given region

Throws:

IOException