@InterfaceAudience.Private public class FlushRegionCallable extends RegionAdminServiceCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse>
connection, location, replicaId, row, rpcControllerFactory, stub, tableName
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) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.protobuf.generated.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. |
getExceptionMessage, getExceptionMessageAdditionalDetail, getLocation, getRegionLocations, setStub, sleep, throwable
public FlushRegionCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, TableName tableName, byte[] regionName, byte[] regionStartKey, boolean writeFlushWalMarker)
public FlushRegionCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, HRegionInfo regionInfo, boolean writeFlushWalMarker)
public org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse call(int callTimeout) throws Exception
RetryingCallable
callTimeout
- - the time available for this call. 0 for infinite.Exception
- if unable to compute a resultpublic void prepare(boolean reload) throws IOException
RetryingCallable
RetryingCallable.call(int)
invocation.prepare
in interface RetryingCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse>
prepare
in class RegionAdminServiceCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse>
reload
- Set this to true if need to requery locationsIOException
- eCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.