org.apache.hadoop.hbase.regionserver

Class RSRpcServices

java.lang.Object

org.apache.hadoop.hbase.regionserver.RSRpcServices

All Implemented Interfaces:

ConfigurationObserver, HBaseRPCErrorHandler, PriorityFunction, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Direct Known Subclasses:

MasterRpcServices

@InterfaceAudience.Private
public class RSRpcServices
extends Object
implements HBaseRPCErrorHandler, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface, PriorityFunction, ConfigurationObserver

Implements the regionserver RPC services.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static interface	RSRpcServices.LogDelegate
private static class	RSRpcServices.RegionScannerCloseCallBack An Rpc callback for closing a RegionScanner.
private static class	RSRpcServices.RegionScannerHolder Holder class which holds the RegionScanner, nextCallSeq and RpcCallbacks together.
(package private) static class	RSRpcServices.RegionScannersCloseCallBack An RpcCallBack that creates a list of scanners that needs to perform callBack operation on completion of multiGets.
private class	RSRpcServices.RegionScannerShippedCallBack An Rpc callback for doing shipped() call on a RegionScanner.
private class	RSRpcServices.ScannerListener Instantiated as a scanner lease.

Field Summary

Fields

Modifier and Type	Field and Description
protected AccessChecker	accessChecker
(package private) static int	BATCH_ROWS_THRESHOLD_DEFAULT Default value of BATCH_ROWS_THRESHOLD_NAME
(package private) static String	BATCH_ROWS_THRESHOLD_NAME Number of rows in a batch operation above which a warning will be logged.
(package private) AtomicBoolean	clearCompactionQueues
private org.apache.hbase.thirdparty.com.google.common.cache.Cache<String,String>	closedScanners
private static RSRpcServices.LogDelegate	DEFAULT_LOG_DELEGATE
private static long	DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA Default value of REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA
(package private) InetSocketAddress	isa
private RSRpcServices.LogDelegate	ld
protected static org.slf4j.Logger	LOG
private long	maxScannerResultSize
private long	minimumScanTimeLimitDelta The minimum allowable delta to use for the scan limit
private PriorityFunction	priority
private static String	REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA Minimum allowable time limit delta (in milliseconds) that can be enforced during scans.
static String	REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS RPC scheduler to use for the region server.
private HRegionServer	regionServer
static String	REGIONSERVER_ADMIN_SERVICE_CONFIG Services launched in RSRpcServices.
static String	REGIONSERVER_CLIENT_SERVICE_CONFIG
(package private) LongAdder	requestCount
protected static String	RESERVOIR_ENABLED_KEY
private int	rowSizeWarnThreshold Row size threshold for multi requests above which a warning is logged
(package private) LongAdder	rpcGetRequestCount
(package private) LongAdder	rpcMultiRequestCount
(package private) LongAdder	rpcMutateRequestCount
(package private) LongAdder	rpcScanRequestCount
(package private) RpcServerInterface	rpcServer
private int	rpcTimeout The RPC timeout period (milliseconds)
private static IOException	SCANNER_ALREADY_CLOSED Deprecated.
private ScannerIdGenerator	scannerIdGenerator
private int	scannerLeaseTimeoutPeriod The lease timeout period for client scanners (milliseconds).
private ConcurrentMap<String,RSRpcServices.RegionScannerHolder>	scanners

Constructor Summary

Constructors

Constructor and Description
RSRpcServices(HRegionServer rs)
RSRpcServices(HRegionServer rs, RSRpcServices.LogDelegate ld)

Method Summary

Modifier and Type	Method and Description
private void	addResult(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse.Builder builder, Result result, HBaseRpcController rpcc, boolean clientCellBlockSupported)
private void	addResults(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder, List<Result> results, HBaseRpcController controller, boolean isDefaultRegion, boolean clientCellBlockSupported)
private RSRpcServices.RegionScannerHolder	addScanner(String scannerName, RegionScanner s, Shipper shipper, HRegion r, boolean needCursor)
private void	addScannerLeaseBack(Leases.Lease lease)
(package private) Object	addSize(RpcCallContext context, Result r, Object lastBlock) Method to account for the size of retained cells and retained data blocks.
private Result	append(HRegion region, OperationQuota quota, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation, CellScanner cellScanner, long nonceGroup, ActivePolicyEnforcement spaceQuota) Execute an append mutation.
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.BulkLoadHFileResponse	bulkLoadHFile(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.BulkLoadHFileRequest request) Atomically bulk load several HFiles into an open region
private boolean	checkAndRowMutate(HRegion region, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions, CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, TimeRange timeRange, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder, ActivePolicyEnforcement spaceQuotaEnforcement) Mutate a list of rows atomically.
private void	checkBatchSizeAndLogLargeSize(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request)
private void	checkCellSizeLimit(HRegion r, Mutation m)
private void	checkLimitOfRows(int numOfCompleteRows, int limitOfRows, boolean moreRows, ScannerContext scannerContext, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder)
boolean	checkOOME(Throwable e) Take actions on the event of an OutOfMemoryError.
protected void	checkOpen() Called to verify that this server is up and running.
private void	checkScanNextCallSeq(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request, RSRpcServices.RegionScannerHolder rsh)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CleanupBulkLoadResponse	cleanupBulkLoad(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CleanupBulkLoadRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse	clearCompactionQueues(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheResponse	clearRegionBlockCache(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheRequest request)
private void	closeAllScanners()
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse	closeRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest request) Close a region on the region server.
private void	closeScanner(HRegion region, RegionScanner scanner, String scannerName, RpcCallContext context)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse	compactRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest request) Compact a region on the region server.
protected PriorityFunction	createPriority()
protected RpcServerInterface	createRpcServer(Server server, org.apache.hadoop.conf.Configuration conf, RpcSchedulerFactory rpcSchedulerFactory, InetSocketAddress bindAddress, String name)
private void	doAtomicBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder, HRegion region, OperationQuota quota, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations, CellScanner cells, ActivePolicyEnforcement spaceQuotaEnforcement)
private void	doBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder, HRegion region, OperationQuota quota, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations, CellScanner cells, ActivePolicyEnforcement spaceQuotaEnforcement, boolean atomic) Execute a list of Put/Delete mutations.
private void	doNonAtomicBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder, HRegion region, OperationQuota quota, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations, CellScanner cells, ActivePolicyEnforcement spaceQuotaEnforcement)
private List<CellScannable>	doNonAtomicRegionMutation(HRegion region, OperationQuota quota, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionAction actions, CellScanner cellScanner, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder, List<CellScannable> cellsToReturn, long nonceGroup, RSRpcServices.RegionScannersCloseCallBack closeCallBack, RpcCallContext context, ActivePolicyEnforcement spaceQuotaEnforcement) Run through the regionMutation rm and per Mutation, do the work, and then when done, add an instance of a ClientProtos.ResultOrException that corresponds to each Mutation.
private OperationStatus[]	doReplayBatchOp(HRegion region, List<WALSplitter.MutationReplay> mutations, long replaySeqId) Execute a list of Put/Delete mutations.
private void	endNonceOperation(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation, long nonceGroup, boolean success) Ends nonce operation for a mutation, if needed.
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse	execRegionServerService(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse	execService(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest request)
private com.google.protobuf.Message	execServiceOnRegion(HRegion region, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceCall serviceCall)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse	executeProcedures(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
static boolean	exitIfOOME(Throwable e)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse	flushRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest request) Flush a region on the region server.
private Result	get(Get get, HRegion region, RSRpcServices.RegionScannersCloseCallBack closeCallBack, RpcCallContext context)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetResponse	get(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetRequest request) Get data from a table.
org.apache.hadoop.conf.Configuration	getConfiguration()
long	getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param) Returns the deadline of the specified request.
static String	getHostname(org.apache.hadoop.conf.Configuration conf, boolean isMaster)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionResponse	getOnlineRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionRequest request)
PriorityFunction	getPriority()
int	getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user) Returns the 'priority type' of the specified request.
HRegion	getRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier regionSpecifier) Find the HRegion based on a region specifier
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse	getRegionInfo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse	getRegionLoad(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request)
private List<HRegion>	getRegions(List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> regionSpecifiers, CacheEvictionStatsBuilder stats) Find the List of HRegions based on a list of region specifiers
private RSRpcServices.RegionScannerHolder	getRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException	getResultOrException(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Result r, int index)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException	getResultOrException(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException.Builder builder, int index)
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException	getResultOrException(Exception e, int index)
private RegionServerRpcQuotaManager	getRpcQuotaManager()
String	getScanDetailsWithId(long scannerId)
RegionScanner	getScanner(long scannerId)
int	getScannersCount()
(package private) long	getScannerVirtualTime(long scannerId) Get the vtime associated with the scanner.
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoResponse	getServerInfo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoRequest request) Get some information of the region server.
protected List<RpcServer.BlockingServiceAndInterface>	getServices() By default, put up an Admin and a Client Service.
InetSocketAddress	getSocketAddress()
private RegionServerSpaceQuotaManager	getSpaceQuotaManager()
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse	getSpaceQuotaSnapshots(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileResponse	getStoreFile(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileRequest request)
private long	getTimeLimit(HBaseRpcController controller, boolean allowHeartbeatMessages)
private Result	increment(HRegion region, OperationQuota quota, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation, CellScanner cells, long nonceGroup, ActivePolicyEnforcement spaceQuota) Execute an increment mutation.
private boolean	isClientCellBlockSupport(RpcCallContext context)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse	multi(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request) Execute multiple actions on a table: get, mutate, and/or execCoprocessor
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse	mutate(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request) Mutate data in a table.
private RSRpcServices.RegionScannerHolder	newRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder)
void	onConfigurationChange(org.apache.hadoop.conf.Configuration newConf) This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse	openRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest request) Open asynchronously a region or a set of regions on the region server.
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.PrepareBulkLoadResponse	prepareBulkLoad(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.PrepareBulkLoadRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse	replay(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request) Replay the given changes when distributedLogReplay WAL edits from a failed RS.
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse	replicateWALEntry(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request) Replicate WAL entries on the region server.
protected void	requirePermission(String request, Permission.Action perm)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterResponse	rollWALWriter(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterRequest request) Roll the WAL writer of the region server.
private void	rpcPreCheck(String requestName) Checks for the following pre-checks in order: RegionServer is running If authorization is enabled, then RPC caller has ADMIN permissions
private void	scan(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request, RSRpcServices.RegionScannerHolder rsh, long maxQuotaResultSize, int maxResults, int limitOfRows, List<Result> results, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder, org.apache.commons.lang3.mutable.MutableObject lastBlock, RpcCallContext context)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse	scan(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request) Scan data in a table.
private void	skipCellsForMutation(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action action, CellScanner cellScanner)
private void	skipCellsForMutations(List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions, CellScanner cellScanner)
(package private) void	start(ZKWatcher zkWatcher)
private boolean	startNonceOperation(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation, long nonceGroup) Starts the nonce operation for a mutation, if needed.
(package private) void	stop()
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerResponse	stopServer(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerRequest request) Stop the region server.
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse	updateConfiguration(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse	updateFavoredNodes(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest request)
private void	updateMutationMetrics(HRegion region, long starttime, boolean batchContainsPuts, boolean batchContainsDelete)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionResponse	warmupRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionRequest request) Wamrmup a region on this server.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS

public static final String REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS

RPC scheduler to use for the region server.

See Also:

Constant Field Values

REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA

private static final String REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA

Minimum allowable time limit delta (in milliseconds) that can be enforced during scans. This configuration exists to prevent the scenario where a time limit is specified to be so restrictive that the time limit is reached immediately (before any cells are scanned).

See Also:

Constant Field Values

DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA

private static final long DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA

Default value of REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA

See Also:

Constant Field Values

BATCH_ROWS_THRESHOLD_NAME

static final String BATCH_ROWS_THRESHOLD_NAME

Number of rows in a batch operation above which a warning will be logged.

See Also:

Constant Field Values

BATCH_ROWS_THRESHOLD_DEFAULT

static final int BATCH_ROWS_THRESHOLD_DEFAULT

Default value of BATCH_ROWS_THRESHOLD_NAME

See Also:

Constant Field Values

RESERVOIR_ENABLED_KEY

protected static final String RESERVOIR_ENABLED_KEY

See Also:

Constant Field Values

requestCount

final LongAdder requestCount

rpcGetRequestCount

final LongAdder rpcGetRequestCount

rpcScanRequestCount

final LongAdder rpcScanRequestCount

rpcMultiRequestCount

final LongAdder rpcMultiRequestCount

rpcMutateRequestCount

final LongAdder rpcMutateRequestCount

rpcServer

final RpcServerInterface rpcServer

isa

final InetSocketAddress isa

regionServer

private final HRegionServer regionServer

maxScannerResultSize

private final long maxScannerResultSize

priority

private final PriorityFunction priority

scannerIdGenerator

private ScannerIdGenerator scannerIdGenerator

scanners

private final ConcurrentMap<String,RSRpcServices.RegionScannerHolder> scanners

closedScanners

private final org.apache.hbase.thirdparty.com.google.common.cache.Cache<String,String> closedScanners

scannerLeaseTimeoutPeriod

private final int scannerLeaseTimeoutPeriod

The lease timeout period for client scanners (milliseconds).

rpcTimeout

private final int rpcTimeout

The RPC timeout period (milliseconds)

minimumScanTimeLimitDelta

private final long minimumScanTimeLimitDelta

The minimum allowable delta to use for the scan limit

rowSizeWarnThreshold

private final int rowSizeWarnThreshold

Row size threshold for multi requests above which a warning is logged

clearCompactionQueues

final AtomicBoolean clearCompactionQueues

accessChecker

protected AccessChecker accessChecker

REGIONSERVER_ADMIN_SERVICE_CONFIG

public static final String REGIONSERVER_ADMIN_SERVICE_CONFIG

Services launched in RSRpcServices. By default they are on but you can use the below booleans to selectively enable/disable either Admin or Client Service (Rare is the case where you would ever turn off one or the other).

See Also:

Constant Field Values

REGIONSERVER_CLIENT_SERVICE_CONFIG

public static final String REGIONSERVER_CLIENT_SERVICE_CONFIG

See Also:

Constant Field Values

DEFAULT_LOG_DELEGATE

private static RSRpcServices.LogDelegate DEFAULT_LOG_DELEGATE

ld

private final RSRpcServices.LogDelegate ld

SCANNER_ALREADY_CLOSED

@Deprecated
private static final IOException SCANNER_ALREADY_CLOSED

Deprecated.

Constructor Detail

RSRpcServices

public RSRpcServices(HRegionServer rs)
              throws IOException

Throws:

IOException

RSRpcServices

RSRpcServices(HRegionServer rs,
              RSRpcServices.LogDelegate ld)
       throws IOException

Throws:

IOException

Method Detail

getResultOrException

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException getResultOrException(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Result r,
                                                                                                                     int index)

getResultOrException

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException getResultOrException(Exception e,
                                                                                                                     int index)

getResultOrException

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException getResultOrException(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ResultOrException.Builder builder,
                                                                                                                     int index)

rpcPreCheck

private void rpcPreCheck(String requestName)
                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Checks for the following pre-checks in order:

1. RegionServer is running
2. If authorization is enabled, then RPC caller has ADMIN permissions

Parameters:

requestName - name of rpc request. Used in reporting failures to provide context.

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException - If any of the above listed pre-check fails.

startNonceOperation

private boolean startNonceOperation(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation,
                                    long nonceGroup)
                             throws IOException

Starts the nonce operation for a mutation, if needed.

Parameters:

mutation - Mutation.

nonceGroup - Nonce group from the request.

Returns:

whether to proceed this mutation.

Throws:

IOException

endNonceOperation

private void endNonceOperation(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation,
                               long nonceGroup,
                               boolean success)

Ends nonce operation for a mutation, if needed.

Parameters:

mutation - Mutation.

nonceGroup - Nonce group from the request. Always 0 in initial implementation.

success - Whether the operation for this nonce has succeeded.

isClientCellBlockSupport

private boolean isClientCellBlockSupport(RpcCallContext context)

addResult

private void addResult(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse.Builder builder,
                       Result result,
                       HBaseRpcController rpcc,
                       boolean clientCellBlockSupported)

addResults

private void addResults(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder,
                        List<Result> results,
                        HBaseRpcController controller,
                        boolean isDefaultRegion,
                        boolean clientCellBlockSupported)

checkAndRowMutate

private boolean checkAndRowMutate(HRegion region,
                                  List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions,
                                  CellScanner cellScanner,
                                  byte[] row,
                                  byte[] family,
                                  byte[] qualifier,
                                  CompareOperator op,
                                  ByteArrayComparable comparator,
                                  TimeRange timeRange,
                                  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
                                  ActivePolicyEnforcement spaceQuotaEnforcement)
                           throws IOException

Mutate a list of rows atomically.

Parameters:

cellScanner - if non-null, the mutation data -- the Cell content.

Throws:

IOException

append

private Result append(HRegion region,
                      OperationQuota quota,
                      org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation,
                      CellScanner cellScanner,
                      long nonceGroup,
                      ActivePolicyEnforcement spaceQuota)
               throws IOException

Execute an append mutation.

Returns:

result to return to client if default operation should be bypassed as indicated by RegionObserver, null otherwise

Throws:

IOException

increment

private Result increment(HRegion region,
                         OperationQuota quota,
                         org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation,
                         CellScanner cells,
                         long nonceGroup,
                         ActivePolicyEnforcement spaceQuota)
                  throws IOException

Execute an increment mutation.

Parameters:

region -

mutation -

Returns:

the Result

Throws:

IOException

doNonAtomicRegionMutation

private List<CellScannable> doNonAtomicRegionMutation(HRegion region,
                                                      OperationQuota quota,
                                                      org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionAction actions,
                                                      CellScanner cellScanner,
                                                      org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
                                                      List<CellScannable> cellsToReturn,
                                                      long nonceGroup,
                                                      RSRpcServices.RegionScannersCloseCallBack closeCallBack,
                                                      RpcCallContext context,
                                                      ActivePolicyEnforcement spaceQuotaEnforcement)

Run through the regionMutation rm and per Mutation, do the work, and then when done, add an instance of a ClientProtos.ResultOrException that corresponds to each Mutation.

Parameters:

cellsToReturn - Could be null. May be allocated in this method. This is what this method returns as a 'result'.

closeCallBack - the callback to be used with multigets

context - the current RpcCallContext

Returns:

Return the cellScanner passed

checkCellSizeLimit

private void checkCellSizeLimit(HRegion r,
                                Mutation m)
                         throws IOException

Throws:

IOException

doAtomicBatchOp

private void doAtomicBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
                             HRegion region,
                             OperationQuota quota,
                             List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations,
                             CellScanner cells,
                             ActivePolicyEnforcement spaceQuotaEnforcement)
                      throws IOException

Throws:

IOException

doNonAtomicBatchOp

private void doNonAtomicBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
                                HRegion region,
                                OperationQuota quota,
                                List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations,
                                CellScanner cells,
                                ActivePolicyEnforcement spaceQuotaEnforcement)

doBatchOp

private void doBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
                       HRegion region,
                       OperationQuota quota,
                       List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations,
                       CellScanner cells,
                       ActivePolicyEnforcement spaceQuotaEnforcement,
                       boolean atomic)
                throws IOException

Execute a list of Put/Delete mutations.

Parameters:

builder -

region -

mutations -

Throws:

IOException

updateMutationMetrics

private void updateMutationMetrics(HRegion region,
                                   long starttime,
                                   boolean batchContainsPuts,
                                   boolean batchContainsDelete)

doReplayBatchOp

private OperationStatus[] doReplayBatchOp(HRegion region,
                                          List<WALSplitter.MutationReplay> mutations,
                                          long replaySeqId)
                                   throws IOException

Execute a list of Put/Delete mutations. The function returns OperationStatus instead of constructing MultiResponse to save a possible loop if caller doesn't need MultiResponse.

Parameters:

region -

mutations -

replaySeqId -

Returns:

an array of OperationStatus which internally contains the OperationStatusCode and the exceptionMessage if any

Throws:

IOException

closeAllScanners

private void closeAllScanners()

createRpcServer

protected RpcServerInterface createRpcServer(Server server,
                                             org.apache.hadoop.conf.Configuration conf,
                                             RpcSchedulerFactory rpcSchedulerFactory,
                                             InetSocketAddress bindAddress,
                                             String name)
                                      throws IOException

Throws:

IOException

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration newConf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver

createPriority

protected PriorityFunction createPriority()

requirePermission

protected void requirePermission(String request,
                                 Permission.Action perm)
                          throws IOException

Throws:

IOException

getHostname

public static String getHostname(org.apache.hadoop.conf.Configuration conf,
                                 boolean isMaster)
                          throws UnknownHostException

Throws:

UnknownHostException

getScannersCount

public int getScannersCount()

getScanner

public RegionScanner getScanner(long scannerId)

getScanDetailsWithId

public String getScanDetailsWithId(long scannerId)

getScannerVirtualTime

long getScannerVirtualTime(long scannerId)

Get the vtime associated with the scanner. Currently the vtime is the number of "next" calls.

addSize

Object addSize(RpcCallContext context,
               Result r,
               Object lastBlock)

Method to account for the size of retained cells and retained data blocks.

Returns:

an object that represents the last referenced block from this response.

addScanner

private RSRpcServices.RegionScannerHolder addScanner(String scannerName,
                                                     RegionScanner s,
                                                     Shipper shipper,
                                                     HRegion r,
                                                     boolean needCursor)
                                              throws Leases.LeaseStillHeldException

Throws:

Leases.LeaseStillHeldException

getRegion

public HRegion getRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier regionSpecifier)
                  throws IOException

Find the HRegion based on a region specifier

Parameters:

regionSpecifier - the region specifier

Returns:

the corresponding region

Throws:

IOException - if the specifier is not null, but failed to find the region

getRegions

private List<HRegion> getRegions(List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> regionSpecifiers,
                                 CacheEvictionStatsBuilder stats)

Find the List of HRegions based on a list of region specifiers

Parameters:

regionSpecifiers - the list of region specifiers

Returns:

the corresponding list of regions

Throws:

IOException - if any of the specifiers is not null, but failed to find the region

getPriority

public PriorityFunction getPriority()

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

getRpcQuotaManager

private RegionServerRpcQuotaManager getRpcQuotaManager()

getSpaceQuotaManager

private RegionServerSpaceQuotaManager getSpaceQuotaManager()

start

void start(ZKWatcher zkWatcher)

stop

void stop()

checkOpen

protected void checkOpen()
                  throws IOException

Called to verify that this server is up and running.

Throws:

IOException

getServices

protected List<RpcServer.BlockingServiceAndInterface> getServices()

By default, put up an Admin and a Client Service. Set booleans hbase.regionserver.admin.executorService and hbase.regionserver.client.executorService if you want to enable/disable services. Default is that both are enabled.

Returns:

immutable list of blocking services and the security info classes that this server supports

getSocketAddress

public InetSocketAddress getSocketAddress()

getPriority

public int getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
                       org.apache.hbase.thirdparty.com.google.protobuf.Message param,
                       User user)

Description copied from interface: PriorityFunction

Returns the 'priority type' of the specified request. The returned value is mainly used to select the dispatch queue.

Specified by:

getPriority in interface PriorityFunction

Returns:

Priority of this request.

getDeadline

public long getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
                        org.apache.hbase.thirdparty.com.google.protobuf.Message param)

Description copied from interface: PriorityFunction

Returns the deadline of the specified request. The returned value is used to sort the dispatch queue.

Specified by:

getDeadline in interface PriorityFunction

Returns:

Deadline of this request. 0 now, otherwise msec of 'delay'

checkOOME

public boolean checkOOME(Throwable e)

Description copied from interface: HBaseRPCErrorHandler

Take actions on the event of an OutOfMemoryError.

Specified by:

checkOOME in interface HBaseRPCErrorHandler

Parameters:

e - the throwable

Returns:

if the server should be shut down

exitIfOOME

public static boolean exitIfOOME(Throwable e)

closeRegion

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse closeRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                     org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest request)
                                                                                              throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Close a region on the region server.

Specified by:

closeRegion in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

compactRegion

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse compactRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest request)
                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Compact a region on the region server.

Specified by:

compactRegion in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

flushRegion

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse flushRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                     org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest request)
                                                                                              throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Flush a region on the region server.

Specified by:

flushRegion in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getOnlineRegion

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionResponse getOnlineRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                             org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionRequest request)
                                                                                                      throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getOnlineRegion in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getRegionInfo

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse getRegionInfo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoRequest request)
                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getRegionInfo in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getRegionLoad

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse getRegionLoad(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request)
                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getRegionLoad in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

clearCompactionQueues

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse clearCompactionQueues(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest request)
                                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

clearCompactionQueues in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getServerInfo

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoResponse getServerInfo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoRequest request)
                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Get some information of the region server.

Specified by:

getServerInfo in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getStoreFile

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileResponse getStoreFile(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                       org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileRequest request)
                                                                                                throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getStoreFile in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

openRegion

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse openRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                   org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest request)
                                                                                            throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Open asynchronously a region or a set of regions on the region server. The opening is coordinated by ZooKeeper, and this method requires the znode to be created before being called. As a consequence, this method should be called only from the master.

Different manages states for the region are:

• region not opened: the region opening will start asynchronously.
• a close is already in progress: this is considered as an error.
• an open is already in progress: this new open request will be ignored. This is important because the Master can do multiple requests if it crashes.
• the region is already opened: this new open request will be ignored.

Bulk assign: If there are more than 1 region to open, it will be considered as a bulk assign. For a single region opening, errors are sent through a ServiceException. For bulk assign, errors are put in the response as FAILED_OPENING.

Specified by:

openRegion in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

warmupRegion

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionResponse warmupRegion(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                       org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionRequest request)
                                                                                                throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Wamrmup a region on this server. This method should only be called by Master. It synchrnously opens the region and closes the region bringing the most important pages in cache.

Specified by:

warmupRegion in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

replay

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse replay(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                      org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request)
                                                                                               throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Replay the given changes when distributedLogReplay WAL edits from a failed RS. The guarantee is that the given mutations will be durable on the receiving RS if this method returns without any exception.

Specified by:

replay in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

replicateWALEntry

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse replicateWALEntry(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                 org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request)
                                                                                                          throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Replicate WAL entries on the region server.

Specified by:

replicateWALEntry in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

rollWALWriter

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterResponse rollWALWriter(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterRequest request)
                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Roll the WAL writer of the region server.

Specified by:

rollWALWriter in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

stopServer

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerResponse stopServer(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                   org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerRequest request)
                                                                                            throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Stop the region server.

Specified by:

stopServer in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Parameters:

controller - the RPC controller

request - the request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

updateFavoredNodes

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse updateFavoredNodes(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                   org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest request)
                                                                                                            throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

updateFavoredNodes in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

bulkLoadHFile

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.BulkLoadHFileResponse bulkLoadHFile(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                          org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.BulkLoadHFileRequest request)
                                                                                                   throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Atomically bulk load several HFiles into an open region

Specified by:

bulkLoadHFile in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Returns:

true if successful, false is failed but recoverably (no action)

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException - if failed unrecoverably

prepareBulkLoad

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.PrepareBulkLoadResponse prepareBulkLoad(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                              org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.PrepareBulkLoadRequest request)
                                                                                                       throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

prepareBulkLoad in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

cleanupBulkLoad

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CleanupBulkLoadResponse cleanupBulkLoad(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                              org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CleanupBulkLoadRequest request)
                                                                                                       throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

cleanupBulkLoad in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

execService

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse execService(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                             org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest request)
                                                                                                      throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

execService in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

execServiceOnRegion

private com.google.protobuf.Message execServiceOnRegion(HRegion region,
                                                        org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceCall serviceCall)
                                                 throws IOException

Throws:

IOException

get

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetResponse get(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                      org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetRequest request)
                                                                               throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Get data from a table.

Specified by:

get in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Parameters:

controller - the RPC controller

request - the get request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

get

private Result get(Get get,
                   HRegion region,
                   RSRpcServices.RegionScannersCloseCallBack closeCallBack,
                   RpcCallContext context)
            throws IOException

Throws:

IOException

checkBatchSizeAndLogLargeSize

private void checkBatchSizeAndLogLargeSize(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request)

multi

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse multi(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc,
                                                                                          org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request)
                                                                                   throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Execute multiple actions on a table: get, mutate, and/or execCoprocessor

Specified by:

multi in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Parameters:

rpcc - the RPC controller

request - the multi request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

skipCellsForMutations

private void skipCellsForMutations(List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions,
                                   CellScanner cellScanner)

skipCellsForMutation

private void skipCellsForMutation(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action action,
                                  CellScanner cellScanner)

mutate

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse mutate(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc,
                                                                                            org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request)
                                                                                     throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Mutate data in a table.

Specified by:

mutate in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Parameters:

rpcc - the RPC controller

request - the mutate request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getRegionScanner

private RSRpcServices.RegionScannerHolder getRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request)
                                                    throws IOException

Throws:

IOException

newRegionScanner

private RSRpcServices.RegionScannerHolder newRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request,
                                                           org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder)
                                                    throws IOException

Throws:

IOException

checkScanNextCallSeq

private void checkScanNextCallSeq(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request,
                                  RSRpcServices.RegionScannerHolder rsh)
                           throws OutOfOrderScannerNextException

Throws:

OutOfOrderScannerNextException

addScannerLeaseBack

private void addScannerLeaseBack(Leases.Lease lease)

getTimeLimit

private long getTimeLimit(HBaseRpcController controller,
                          boolean allowHeartbeatMessages)

checkLimitOfRows

private void checkLimitOfRows(int numOfCompleteRows,
                              int limitOfRows,
                              boolean moreRows,
                              ScannerContext scannerContext,
                              org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder)

scan

private void scan(HBaseRpcController controller,
                  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request,
                  RSRpcServices.RegionScannerHolder rsh,
                  long maxQuotaResultSize,
                  int maxResults,
                  int limitOfRows,
                  List<Result> results,
                  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder,
                  org.apache.commons.lang3.mutable.MutableObject lastBlock,
                  RpcCallContext context)
           throws IOException

Throws:

IOException

scan

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse scan(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                        org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request)
                                                                                 throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Scan data in a table.

Specified by:

scan in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Parameters:

controller - the RPC controller

request - the scan request

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

closeScanner

private void closeScanner(HRegion region,
                          RegionScanner scanner,
                          String scannerName,
                          RpcCallContext context)
                   throws IOException

Throws:

IOException

execRegionServerService

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse execRegionServerService(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest request)
                                                                                                                  throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

execRegionServerService in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

updateConfiguration

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse updateConfiguration(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                     org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request)
                                                                                                              throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

updateConfiguration in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getSpaceQuotaSnapshots

public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse getSpaceQuotaSnapshots(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                           org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request)
                                                                                                                    throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getSpaceQuotaSnapshots in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

executeProcedures

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse executeProcedures(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                 org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
                                                                                                          throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

executeProcedures in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

clearRegionBlockCache

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheResponse clearRegionBlockCache(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheRequest request)

Specified by:

clearRegionBlockCache in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface