org.apache.hadoop.hbase.ipc

Class DelegatingPayloadCarryingRpcController

java.lang.Object

org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

org.apache.hadoop.hbase.ipc.PayloadCarryingRpcController

org.apache.hadoop.hbase.ipc.DelegatingPayloadCarryingRpcController

All Implemented Interfaces:

CellScannable

Direct Known Subclasses:

TestRpcControllerFactory.CountingRpcController

@InterfaceAudience.Private
public class DelegatingPayloadCarryingRpcController
extends PayloadCarryingRpcController

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

Field Summary

Fields inherited from class org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

callTimeout, cancellationCb, cancelled, failureCb

Constructor Summary

Constructors

Constructor and Description
DelegatingPayloadCarryingRpcController(PayloadCarryingRpcController delegate)

Method Summary

Modifier and Type	Method and Description
CellScanner	cellScanner()
int	getPriority()
void	setCellScanner(CellScanner cellScanner)
void	setPriority(int priority)
void	setPriority(TableName tn)

Methods inherited from class org.apache.hadoop.hbase.ipc.PayloadCarryingRpcController

reset

Methods inherited from class org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

errorText, failed, getCallTimeout, hasCallTimeout, isCanceled, notifyOnCancel, notifyOnFail, setCallTimeout, setFailed, setFailed, startCancel

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingPayloadCarryingRpcController

public DelegatingPayloadCarryingRpcController(PayloadCarryingRpcController delegate)

Method Detail

cellScanner

public CellScanner cellScanner()

Specified by:

cellScanner in interface CellScannable

Overrides:

cellScanner in class PayloadCarryingRpcController

Returns:

One-shot cell scanner (you cannot back it up and restart)

setCellScanner

public void setCellScanner(CellScanner cellScanner)

Overrides:

setCellScanner in class PayloadCarryingRpcController

setPriority

public void setPriority(int priority)

Overrides:

setPriority in class PayloadCarryingRpcController

Parameters:

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

setPriority

public void setPriority(TableName tn)

Overrides:

setPriority in class PayloadCarryingRpcController

Parameters:

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

getPriority

public int getPriority()

Overrides:

getPriority in class PayloadCarryingRpcController

Returns:

The priority of this request