public static class AsyncPbRpcProxy.RequestManager extends Object implements Callable<Void>
Constructor and Description |
---|
RequestManager(int numThreads,
int maxPerNode) |
Modifier and Type | Method and Description |
---|---|
Void |
call() |
void |
queueRequest(AsyncPbRpcProxy.CallableRequest<?,?> request) |
void |
requestFinished(LlapNodeId nodeId) |
void |
shutdown() |
public void queueRequest(AsyncPbRpcProxy.CallableRequest<?,?> request)
public void requestFinished(LlapNodeId nodeId)
public void shutdown()
Copyright © 2022 The Apache Software Foundation. All rights reserved.