org.apache.hadoop.hive.llap

Class AsyncPbRpcProxy.NodeCallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>

java.lang.Object

org.apache.hadoop.hive.llap.AsyncPbRpcProxy.CallableRequest<REQUEST,RESPONSE>

org.apache.hadoop.hive.llap.AsyncPbRpcProxy.NodeCallableRequest<REQUEST,RESPONSE>

All Implemented Interfaces:

Callable<RESPONSE>

Enclosing class:

AsyncPbRpcProxy<ProtocolType,TokenType extends org.apache.hadoop.security.token.TokenIdentifier>

protected abstract static class AsyncPbRpcProxy.NodeCallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>
extends AsyncPbRpcProxy.CallableRequest<REQUEST,RESPONSE>

Field Summary

Fields

Modifier and Type	Field and Description
protected LlapNodeId	nodeId

Fields inherited from class org.apache.hadoop.hive.llap.AsyncPbRpcProxy.CallableRequest

callback, request

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NodeCallableRequest(LlapNodeId nodeId, REQUEST request, AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> callback)

Method Summary

Modifier and Type	Method and Description
LlapNodeId	getNodeId()

Methods inherited from class org.apache.hadoop.hive.llap.AsyncPbRpcProxy.CallableRequest

call, getCallback

Methods inherited from class java.lang.Object

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

Field Detail

nodeId

protected final LlapNodeId nodeId

Constructor Detail

NodeCallableRequest

protected NodeCallableRequest(LlapNodeId nodeId,
                              REQUEST request,
                              AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> callback)

Method Detail

getNodeId

public LlapNodeId getNodeId()

Specified by:

getNodeId in class AsyncPbRpcProxy.CallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>