@InterfaceAudience.Private public class FlushRegionCallable extends RegionAdminServiceCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse>
| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
private byte[] |
regionName |
private boolean |
reload |
private boolean |
writeFlushWalMarker |
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.
|
private org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse |
flushRegion() |
void |
prepare(boolean reload)
Prepare by setting up any connections to servers, etc., ahead of
RetryingCallable.call(int) invocation. |
getConnection, getExceptionMessage, getExceptionMessageAdditionalDetail, getLocation, getRegionLocations, setStub, sleep, throwableprivate static final org.apache.commons.logging.Log LOG
private final byte[] regionName
private final boolean writeFlushWalMarker
private boolean reload
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
RetryingCallablecallTimeout - - the time available for this call. 0 for infinite.Exception - if unable to compute a resultpublic void prepare(boolean reload)
throws IOException
RetryingCallableRetryingCallable.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 - eprivate org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionResponse flushRegion()
throws IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.