| Package | Description | 
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon.drpc | |
| org.apache.storm.drpc | |
| org.apache.storm.generated | 
| Modifier and Type | Method and Description | 
|---|---|
DRPCRequest | 
LocalDRPC.fetchRequest(String functionName)  | 
| Modifier and Type | Method and Description | 
|---|---|
DRPCRequest | 
DRPC.fetchRequest(String functionName)  | 
DRPCRequest | 
DRPCThrift.fetchRequest(String functionName)  | 
DRPCRequest | 
OutstandingRequest.getRequest()  | 
| Modifier and Type | Method and Description | 
|---|---|
T | 
RequestFactory.mkRequest(String function,
         DRPCRequest req)  | 
| Constructor and Description | 
|---|
BlockingOutstandingRequest(String function,
                          DRPCRequest req)  | 
OutstandingRequest(String function,
                  DRPCRequest req)  | 
| Modifier and Type | Method and Description | 
|---|---|
DRPCRequest | 
DRPCInvocationsClient.fetchRequest(String func)  | 
| Modifier and Type | Method and Description | 
|---|---|
DRPCRequest | 
DRPCRequest.deepCopy()  | 
DRPCRequest | 
DistributedRPCInvocations.Iface.fetchRequest(String functionName)  | 
DRPCRequest | 
DistributedRPCInvocations.Client.fetchRequest(String functionName)  | 
DRPCRequest | 
DistributedRPCInvocations.fetchRequest_result.get_success()  | 
DRPCRequest | 
DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult()  | 
DRPCRequest | 
DistributedRPCInvocations.Client.recv_fetchRequest()  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.storm.thrift.async.AsyncMethodCallback<DRPCRequest> | 
DistributedRPCInvocations.AsyncProcessor.fetchRequest.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
                int seqid)  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
DRPCRequest.compareTo(DRPCRequest other)  | 
boolean | 
DRPCRequest.equals(DRPCRequest that)  | 
void | 
DistributedRPCInvocations.fetchRequest_result.set_success(DRPCRequest success)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DistributedRPCInvocations.AsyncIface.fetchRequest(String functionName,
            org.apache.storm.thrift.async.AsyncMethodCallback<DRPCRequest> resultHandler)  | 
void | 
DistributedRPCInvocations.AsyncClient.fetchRequest(String functionName,
            org.apache.storm.thrift.async.AsyncMethodCallback<DRPCRequest> resultHandler)  | 
void | 
DistributedRPCInvocations.AsyncProcessor.fetchRequest.start(I iface,
     DistributedRPCInvocations.fetchRequest_args args,
     org.apache.storm.thrift.async.AsyncMethodCallback<DRPCRequest> resultHandler)  | 
| Constructor and Description | 
|---|
DRPCRequest(DRPCRequest other)
Performs a deep copy on other. 
 | 
fetchRequest_result(DRPCRequest success,
                   AuthorizationException aze)  | 
| Constructor and Description | 
|---|
fetchRequest_call(String functionName,
                 org.apache.storm.thrift.async.AsyncMethodCallback<DRPCRequest> resultHandler,
                 org.apache.storm.thrift.async.TAsyncClient client,
                 org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
                 org.apache.storm.thrift.transport.TNonblockingTransport transport)  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.