DelegatingPayloadCarryingRpcController (Apache HBase 1.2.12 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.ipc.TimeLimitedRpcController
- - org.apache.hadoop.hbase.ipc.PayloadCarryingRpcController
  - - org.apache.hadoop.hbase.ipc.DelegatingPayloadCarryingRpcController

All Implemented Interfaces:

com.google.protobuf.RpcController, CellScannable
```
@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
Modifier and Type Field and Description

private PayloadCarryingRpcController delegate
- 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

Methods
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

- Field Detail
  - delegate
```
private PayloadCarryingRpcController delegate
```
- 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

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.