protected abstract static class AsyncPbRpcProxy.CallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message> extends Object implements Callable<RESPONSE>
Modifier and Type | Field and Description |
---|---|
protected AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> |
callback |
protected REQUEST |
request |
Modifier | Constructor and Description |
---|---|
protected |
CallableRequest(REQUEST request,
AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> callback) |
Modifier and Type | Method and Description |
---|---|
abstract RESPONSE |
call() |
AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> |
getCallback() |
abstract LlapNodeId |
getNodeId() |
protected final AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE extends com.google.protobuf.Message> callback
protected final REQUEST extends com.google.protobuf.Message request
protected CallableRequest(REQUEST request, AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> callback)
public abstract LlapNodeId getNodeId() throws Exception
Exception
public AsyncPbRpcProxy.ExecuteRequestCallback<RESPONSE> getCallback()
Copyright © 2022 The Apache Software Foundation. All rights reserved.