Package org.apache.hadoop.hbase.ipc

Class DelegatingHBaseRpcController

java.lang.Object

org.apache.hadoop.hbase.ipc.DelegatingHBaseRpcController

All Implemented Interfaces:

CellScannable, ExtendedCellScannable, HBaseRpcController, org.apache.hbase.thirdparty.com.google.protobuf.RpcController

@Private
public class DelegatingHBaseRpcController
extends Object
implements HBaseRpcController

Simple delegating controller for use with the RpcControllerFactory to help override standard behavior of a HBaseRpcController. Used testing.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.ipc.HBaseRpcController

HBaseRpcController.CancellationCallback

Field Summary

Fields

Modifier and Type	Field	Description
private final HBaseRpcController	delegate

Constructor Summary

Constructors

Constructor	Description
DelegatingHBaseRpcController(HBaseRpcController delegate)

Method Summary

Modifier and Type	Method	Description
ExtendedCellScanner	cellScanner()	Returns A CellScanner over the contained Cells
String	errorText()
boolean	failed()
int	getCallTimeout()
IOException	getFailed()	Return the failed exception, null if not failed.
int	getPriority()	Returns The priority of this request
RegionInfo	getRegionInfo()	Returns Target Region's RegionInfo or null if not available or pertinent.
Map<String,byte[]>	getRequestAttributes()	Get the map of request attributes
TableName	getTableName()	Returns Region's table name or null if not available or pertinent.
boolean	hasCallTimeout()
boolean	hasRegionInfo()	Returns True if this Controller is carrying the RPC target Region's RegionInfo.
boolean	isCanceled()
void	notifyOnCancel(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Object> callback)	A little different from the basic RpcController: You can register multiple callbacks to an HBaseRpcController. The callback will not be called if the rpc call is finished without any cancellation. You can call me at client side also.
void	notifyOnCancel(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Object> callback, HBaseRpcController.CancellationCallback action)	If not cancelled, add the callback to cancellation callback list.
void	reset()
void	setCallTimeout(int callTimeout)
void	setCellScanner(ExtendedCellScanner cellScanner)	Only used to send cells to rpc server, the returned cells should be set by HBaseRpcController.setDone(ExtendedCellScanner).
void	setDone(ExtendedCellScanner cellScanner)	IMPORTANT: always call this method if the call finished without any exception to tell the HBaseRpcController that we are done.
void	setFailed(IOException e)	Set failed with an exception to pass on.
void	setFailed(String reason)
void	setPriority(int priority)	Deprecated.
void	setPriority(int priority, @Nullable TableName tableName)	Set the priority for this rpc request.
void	setPriority(TableName tn)	Deprecated.
void	setRequestAttributes(Map<String,byte[]> requestAttributes)	Set the map of request attributes
void	setTableName(TableName tableName)	Sets Region's table name.
void	startCancel()

Methods inherited from class java.lang.Object

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

Field Details

delegate

private final HBaseRpcController delegate

Constructor Details

DelegatingHBaseRpcController

public DelegatingHBaseRpcController(HBaseRpcController delegate)

Method Details

reset

public void reset()

Specified by:

reset in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

failed

public boolean failed()

Specified by:

failed in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

errorText

public String errorText()

Specified by:

errorText in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

startCancel

public void startCancel()

Specified by:

startCancel in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

setFailed

public void setFailed(String reason)

Specified by:

setFailed in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

notifyOnCancel

public void notifyOnCancel(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Object> callback)

Description copied from interface: HBaseRpcController

A little different from the basic RpcController:

1. You can register multiple callbacks to an HBaseRpcController.
2. The callback will not be called if the rpc call is finished without any cancellation.
3. You can call me at client side also.

Specified by:

notifyOnCancel in interface HBaseRpcController

Specified by:

notifyOnCancel in interface org.apache.hbase.thirdparty.com.google.protobuf.RpcController

cellScanner

public ExtendedCellScanner cellScanner()

Description copied from interface: CellScannable

Returns A CellScanner over the contained Cells

Specified by:

cellScanner in interface CellScannable

Specified by:

cellScanner in interface ExtendedCellScannable

setCellScanner

public void setCellScanner(ExtendedCellScanner cellScanner)

Description copied from interface: HBaseRpcController

Only used to send cells to rpc server, the returned cells should be set by HBaseRpcController.setDone(ExtendedCellScanner).

Specified by:

setCellScanner in interface HBaseRpcController

setPriority

@Deprecated
public void setPriority(int priority)

Deprecated.

Description copied from interface: HBaseRpcController

Set the priority for this operation.

Specified by:

setPriority in interface HBaseRpcController

Parameters:

priority - Priority for this request; should fall roughly in the range HConstants.NORMAL_QOS to HConstants.HIGH_QOS

setPriority

@Deprecated
public void setPriority(TableName tn)

Deprecated.

Description copied from interface: HBaseRpcController

Set the priority for this operation.

Specified by:

setPriority in interface HBaseRpcController

Parameters:

tn - Set priority based off the table we are going against.

setPriority

public void setPriority(int priority,
 @Nullable TableName tableName)

Description copied from interface: HBaseRpcController

Set the priority for this rpc request.

For keep compatibility, here we declare the default method where we call HBaseRpcController.setPriority(int) and then HBaseRpcController.setPriority(TableName).

The default implementation in HBase follow the below rules:

1. If user set a priority explicitly, then just use it.
2. For system table, use HConstants.SYSTEMTABLE_QOS.
3. For other tables, use HConstants.NORMAL_QOS.

Specified by:

setPriority in interface HBaseRpcController

Parameters:

priority - the priority set by user, can be HConstants.PRIORITY_UNSET.

tableName - the table we operate on, can be null.

hasRegionInfo

public boolean hasRegionInfo()

Description copied from interface: HBaseRpcController

Returns True if this Controller is carrying the RPC target Region's RegionInfo.

Specified by:

hasRegionInfo in interface HBaseRpcController

getRegionInfo

public RegionInfo getRegionInfo()

Description copied from interface: HBaseRpcController

Returns Target Region's RegionInfo or null if not available or pertinent.

Specified by:

getRegionInfo in interface HBaseRpcController

getPriority

public int getPriority()

Description copied from interface: HBaseRpcController

Returns The priority of this request

Specified by:

getPriority in interface HBaseRpcController

getCallTimeout

public int getCallTimeout()

Specified by:

getCallTimeout in interface HBaseRpcController

setCallTimeout

public void setCallTimeout(int callTimeout)

Specified by:

setCallTimeout in interface HBaseRpcController

hasCallTimeout

public boolean hasCallTimeout()

Specified by:

hasCallTimeout in interface HBaseRpcController

getRequestAttributes

public Map<String,byte[]> getRequestAttributes()

Description copied from interface: HBaseRpcController

Get the map of request attributes

Specified by:

getRequestAttributes in interface HBaseRpcController

setRequestAttributes

public void setRequestAttributes(Map<String,byte[]> requestAttributes)

Description copied from interface: HBaseRpcController

Set the map of request attributes

Specified by:

setRequestAttributes in interface HBaseRpcController

setFailed

public void setFailed(IOException e)

Description copied from interface: HBaseRpcController

Set failed with an exception to pass on. For use in async rpc clients

Specified by:

setFailed in interface HBaseRpcController

Parameters:

e - exception to set with

getFailed

public IOException getFailed()

Description copied from interface: HBaseRpcController

Return the failed exception, null if not failed.

Specified by:

getFailed in interface HBaseRpcController

setDone

public void setDone(ExtendedCellScanner cellScanner)

Description copied from interface: HBaseRpcController

IMPORTANT: always call this method if the call finished without any exception to tell the HBaseRpcController that we are done.

Specified by:

setDone in interface HBaseRpcController

notifyOnCancel

public void notifyOnCancel(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Object> callback,
 HBaseRpcController.CancellationCallback action)
                    throws IOException

Description copied from interface: HBaseRpcController

If not cancelled, add the callback to cancellation callback list. And then execute the action with the cancellation state as a parameter. The implementation should guarantee that the cancellation state does not change during this call.

Specified by:

notifyOnCancel in interface HBaseRpcController

Throws:

IOException

setTableName

public void setTableName(TableName tableName)

Description copied from interface: HBaseRpcController

Sets Region's table name.

Specified by:

setTableName in interface HBaseRpcController

getTableName

public TableName getTableName()

Description copied from interface: HBaseRpcController

Returns Region's table name or null if not available or pertinent.

Specified by:

getTableName in interface HBaseRpcController