org.apache.hadoop.hive.llap

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

java.lang.Object

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

All Implemented Interfaces:

Callable<RESPONSE>

Direct Known Subclasses:

AsyncPbRpcProxy.NodeCallableRequest

Enclosing class:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE>	callback
protected REQUEST	request

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
abstract RESPONSE	call()
AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE>	getCallback()
abstract LlapNodeId	getNodeId()

Methods inherited from class java.lang.Object

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

Field Detail

callback

protected final AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE extends com.google.protobuf.Message> callback

request

protected final REQUEST extends com.google.protobuf.Message request

Constructor Detail

CallableRequest

protected CallableRequest(REQUEST request,
                          AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> callback)

Method Detail

getNodeId

public abstract LlapNodeId getNodeId()
                              throws Exception

Throws:

Exception

getCallback

public AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> getCallback()

call

public abstract RESPONSE call()
                       throws Exception

Specified by:

call in interface Callable<RESPONSE extends com.google.protobuf.Message>

Throws:

Exception