org.apache.hadoop.hbase.ipc

类 PayloadCarryingRpcController

java.lang.Object

org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

org.apache.hadoop.hbase.ipc.PayloadCarryingRpcController

所有已实现的接口:

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

直接已知子类:

DelegatingPayloadCarryingRpcController

@InterfaceAudience.Private
public class PayloadCarryingRpcController
extends TimeLimitedRpcController
implements org.apache.hadoop.hbase.CellScannable

Optionally carries Cells across the proxy/service interface down into ipc. On its way out it optionally carries a set of result Cell data. We stick the Cells here when we want to avoid having to protobuf them. This class is used ferrying data across the proxy/protobuf service chasm. Used by client and server ipc'ing.

字段概要

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

callTimeout, cancellationCb, cancelled, failureCb

构造器概要

构造器

构造器和说明
PayloadCarryingRpcController()
PayloadCarryingRpcController(org.apache.hadoop.hbase.CellScanner cellScanner)
PayloadCarryingRpcController(List<org.apache.hadoop.hbase.CellScannable> cellIterables)

方法概要

方法

限定符和类型	方法和说明
org.apache.hadoop.hbase.CellScanner	cellScanner()
int	getPriority()
void	reset()
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.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

构造器详细资料

PayloadCarryingRpcController

public PayloadCarryingRpcController()

PayloadCarryingRpcController

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

PayloadCarryingRpcController

public PayloadCarryingRpcController(List<org.apache.hadoop.hbase.CellScannable> cellIterables)

方法详细资料

cellScanner

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

指定者:

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

返回:

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

setCellScanner

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

setPriority

public void setPriority(int priority)

参数:

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)

参数:

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

getPriority

public int getPriority()

返回:

The priority of this request

reset

public void reset()

指定者:

reset 在接口中 com.google.protobuf.RpcController

覆盖:

reset 在类中 TimeLimitedRpcController