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.