org.apache.hadoop.hbase.client

Class FlushRegionCallable

java.lang.Object

org.apache.hadoop.hbase.client.RegionAdminServiceCallable<AdminProtos.FlushRegionResponse>

org.apache.hadoop.hbase.client.FlushRegionCallable

All Implemented Interfaces:

RetryingCallable<AdminProtos.FlushRegionResponse>

@InterfaceAudience.Private
public class FlushRegionCallable
extends RegionAdminServiceCallable<AdminProtos.FlushRegionResponse>

A Callable for flushRegion() RPC.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.RegionAdminServiceCallable

connection, location, MIN_WAIT_DEAD_SERVER, replicaId, row, rpcControllerFactory, stub, tableName

Constructor Summary

Constructors

Constructor and Description
FlushRegionCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, HRegionInfo regionInfo, boolean writeFlushWalMarker)
FlushRegionCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, TableName tableName, byte[] regionName, byte[] regionStartKey, boolean writeFlushWalMarker)

Method Summary

Modifier and Type	Method and Description
AdminProtos.FlushRegionResponse	call(int callTimeout) Computes a result, or throws an exception if unable to do so.
void	prepare(boolean reload) Prepare by setting up any connections to servers, etc., ahead of RetryingCallable.call(int) invocation.

Methods inherited from class org.apache.hadoop.hbase.client.RegionAdminServiceCallable

getExceptionMessage, getExceptionMessageAdditionalDetail, getLocation, getRegionLocations, setStub, sleep, throwable

Methods inherited from class java.lang.Object

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

Constructor Detail

FlushRegionCallable

public FlushRegionCallable(ClusterConnection connection,
                           RpcControllerFactory rpcControllerFactory,
                           TableName tableName,
                           byte[] regionName,
                           byte[] regionStartKey,
                           boolean writeFlushWalMarker)

FlushRegionCallable

public FlushRegionCallable(ClusterConnection connection,
                           RpcControllerFactory rpcControllerFactory,
                           HRegionInfo regionInfo,
                           boolean writeFlushWalMarker)

Method Detail

call

public AdminProtos.FlushRegionResponse call(int callTimeout)
                                     throws Exception

Description copied from interface: RetryingCallable

Computes a result, or throws an exception if unable to do so.

Parameters:

callTimeout - - the time available for this call. 0 for infinite.

Returns:

computed result

Throws:

Exception - if unable to compute a result

prepare

public void prepare(boolean reload)
             throws IOException

Description copied from interface: RetryingCallable

Prepare by setting up any connections to servers, etc., ahead of RetryingCallable.call(int) invocation.

Specified by:

prepare in interface RetryingCallable<AdminProtos.FlushRegionResponse>

Overrides:

prepare in class RegionAdminServiceCallable<AdminProtos.FlushRegionResponse>

Parameters:

reload - Set this to true if need to requery locations

Throws:

IOException - e