Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> |
callback |
(package private) MetricsConnection.CallStats |
callStats |
(package private) CellScanner |
cells
Optionally has cells when making call.
|
private boolean |
done |
(package private) IOException |
error |
(package private) int |
id |
(package private) org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor |
md |
(package private) org.apache.hbase.thirdparty.com.google.protobuf.Message |
param |
(package private) int |
priority |
(package private) org.apache.hbase.thirdparty.com.google.protobuf.Message |
response |
(package private) org.apache.hbase.thirdparty.com.google.protobuf.Message |
responseDefaultType |
(package private) io.opentelemetry.api.trace.Span |
span |
(package private) int |
timeout |
(package private) org.apache.hbase.thirdparty.io.netty.util.Timeout |
timeoutTask |
Constructor and Description |
---|
Call(int id,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cells,
org.apache.hbase.thirdparty.com.google.protobuf.Message responseDefaultType,
int timeout,
int priority,
org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback,
MetricsConnection.CallStats callStats) |
Modifier and Type | Method and Description |
---|---|
private void |
callComplete() |
long |
getStartTime() |
boolean |
isDone() |
void |
setException(IOException error)
Set the exception when there is an error.
|
void |
setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message response,
CellScanner cells)
Set the return value when there is no error.
|
void |
setTimeout(IOException error)
called from timeoutTask, prevent self cancel
|
String |
toShortString()
Builds a simplified
toString() that includes just the id and method name. |
String |
toString() |
final int id
final org.apache.hbase.thirdparty.com.google.protobuf.Message param
CellScanner cells
org.apache.hbase.thirdparty.com.google.protobuf.Message response
org.apache.hbase.thirdparty.com.google.protobuf.Message responseDefaultType
IOException error
private boolean done
final org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md
final int timeout
final int priority
final MetricsConnection.CallStats callStats
final io.opentelemetry.api.trace.Span span
org.apache.hbase.thirdparty.io.netty.util.Timeout timeoutTask
Call(int id, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner cells, org.apache.hbase.thirdparty.com.google.protobuf.Message responseDefaultType, int timeout, int priority, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback, MetricsConnection.CallStats callStats)
public String toShortString()
toString()
that includes just the id and method name.public void setTimeout(IOException error)
private void callComplete()
public void setException(IOException error)
error
- exception thrown by the call; either local or remotepublic void setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message response, CellScanner cells)
response
- return value of the call.cells
- Can be nullpublic boolean isDone()
public long getStartTime()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.