org.apache.hadoop.hbase.client

Class FlushRegionCallable

java.lang.Object

org.apache.hadoop.hbase.client.RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse>

org.apache.hadoop.hbase.client.FlushRegionCallable

All Implemented Interfaces:

RetryingCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse>

@InterfaceAudience.Private
public class FlushRegionCallable
extends RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse>

A Callable for flushRegion() RPC.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private byte[]	regionName
private boolean	reload
private boolean	writeFlushWalMarker

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse	call(HBaseRpcController controller) Run RPC call.
void	prepare(boolean reload) Prepare by setting up any connections to servers, etc., ahead of call invocation.

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

call, getConnection, getCurrentPayloadCarryingRpcController, 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

Field Detail

LOG

private static final org.slf4j.Logger LOG

regionName

private final byte[] regionName

writeFlushWalMarker

private final boolean writeFlushWalMarker

reload

private boolean reload

Constructor Detail

FlushRegionCallable

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

FlushRegionCallable

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

Method Detail

prepare

public void prepare(boolean reload)
             throws IOException

Description copied from interface: RetryingCallable

Prepare by setting up any connections to servers, etc., ahead of call invocation. TODO: We call prepare before EVERY call. Seems wrong. FIX!!!!

Specified by:

prepare in interface RetryingCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse>

Overrides:

prepare in class RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse>

Parameters:

reload - Set this to true if need to requery locations

Throws:

IOException - e

call

protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse call(HBaseRpcController controller)
                                                                                          throws Exception

Description copied from class: RegionAdminServiceCallable

Run RPC call.

Specified by:

call in class RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse>

Parameters:

controller - PayloadCarryingRpcController is a mouthful but it at a minimum is a facade on protobuf so we don't have to put protobuf everywhere; we can keep it behind this class.

Throws:

Exception