org.apache.hadoop.hbase.ipc

类 DelegatingPayloadCarryingRpcController

java.lang.Object

org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

org.apache.hadoop.hbase.ipc.PayloadCarryingRpcController

org.apache.hadoop.hbase.ipc.DelegatingPayloadCarryingRpcController

所有已实现的接口:

com.google.protobuf.RpcController, org.apache.hadoop.hbase.CellScannable

@InterfaceAudience.Private
public class DelegatingPayloadCarryingRpcController
extends PayloadCarryingRpcController

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

字段概要

从类继承的字段 org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

callTimeout, cancellationCb, cancelled, failureCb

构造器概要

构造器

构造器和说明
DelegatingPayloadCarryingRpcController(PayloadCarryingRpcController delegate)

方法概要

方法

限定符和类型	方法和说明
org.apache.hadoop.hbase.CellScanner	cellScanner()
int	getPriority()
void	setCellScanner(org.apache.hadoop.hbase.CellScanner cellScanner)
void	setPriority(int priority)
void	setPriority(org.apache.hadoop.hbase.TableName tn)

从类继承的方法 org.apache.hadoop.hbase.ipc.PayloadCarryingRpcController

reset

从类继承的方法 org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

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

从类继承的方法 java.lang.Object

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

构造器详细资料

DelegatingPayloadCarryingRpcController

public DelegatingPayloadCarryingRpcController(PayloadCarryingRpcController delegate)

方法详细资料

cellScanner

public org.apache.hadoop.hbase.CellScanner cellScanner()

指定者:

cellScanner 在接口中 org.apache.hadoop.hbase.CellScannable

覆盖:

cellScanner 在类中 PayloadCarryingRpcController

返回:

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

setCellScanner

public void setCellScanner(org.apache.hadoop.hbase.CellScanner cellScanner)

覆盖:

setCellScanner 在类中 PayloadCarryingRpcController

setPriority

public void setPriority(int priority)

覆盖:

setPriority 在类中 PayloadCarryingRpcController

参数:

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

setPriority

public void setPriority(org.apache.hadoop.hbase.TableName tn)

覆盖:

setPriority 在类中 PayloadCarryingRpcController

参数:

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

getPriority

public int getPriority()

覆盖:

getPriority 在类中 PayloadCarryingRpcController

返回:

The priority of this request