Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.daemon.drpc | |
org.apache.storm.daemon.drpc.webapp | |
org.apache.storm.drpc | |
org.apache.storm.generated | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
void |
LocalDRPC.failRequestV2(String id,
DRPCExecutionException e) |
Modifier and Type | Method and Description |
---|---|
String |
LocalDRPC.execute(String functionName,
String funcArgs) |
Modifier and Type | Method and Description |
---|---|
void |
BlockingOutstandingRequest.fail(DRPCExecutionException e) |
abstract void |
OutstandingRequest.fail(DRPCExecutionException e) |
void |
DRPC.failRequest(String id,
DRPCExecutionException e) |
void |
DRPCThrift.failRequestV2(String id,
DRPCExecutionException e) |
Modifier and Type | Method and Description |
---|---|
String |
DRPCThrift.execute(String functionName,
String funcArgs) |
String |
DRPC.executeBlocking(String functionName,
String funcArgs) |
String |
BlockingOutstandingRequest.getResult() |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
DRPCExceptionMapper.toResponse(DRPCExecutionException ex) |
Modifier and Type | Method and Description |
---|---|
void |
DRPCInvocationsClient.failRequestV2(String id,
DRPCExecutionException ex) |
Modifier and Type | Method and Description |
---|---|
DRPCExecutionException |
DRPCExecutionException.deepCopy() |
DRPCExecutionException |
DistributedRPC.execute_result.get_e() |
DRPCExecutionException |
DistributedRPCInvocations.failRequestV2_args.get_e() |
Modifier and Type | Method and Description |
---|---|
int |
DRPCExecutionException.compareTo(DRPCExecutionException other) |
boolean |
DRPCExecutionException.equals(DRPCExecutionException that) |
void |
DistributedRPCInvocations.Iface.failRequestV2(String id,
DRPCExecutionException e) |
void |
DistributedRPCInvocations.Client.failRequestV2(String id,
DRPCExecutionException e) |
void |
DistributedRPCInvocations.AsyncIface.failRequestV2(String id,
DRPCExecutionException e,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
DistributedRPCInvocations.AsyncClient.failRequestV2(String id,
DRPCExecutionException e,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
DistributedRPCInvocations.Client.send_failRequestV2(String id,
DRPCExecutionException e) |
void |
DistributedRPC.execute_result.set_e(DRPCExecutionException e) |
void |
DistributedRPCInvocations.failRequestV2_args.set_e(DRPCExecutionException e) |
Modifier and Type | Method and Description |
---|---|
String |
DistributedRPC.Iface.execute(String functionName,
String funcArgs) |
String |
DistributedRPC.Client.execute(String functionName,
String funcArgs) |
String |
DistributedRPC.AsyncClient.execute_call.getResult() |
String |
DistributedRPC.Client.recv_execute() |
Constructor and Description |
---|
DRPCExecutionException(DRPCExecutionException other)
Performs a deep copy on other.
|
execute_result(String success,
DRPCExecutionException e,
AuthorizationException aze) |
failRequestV2_args(String id,
DRPCExecutionException e) |
failRequestV2_call(String id,
DRPCExecutionException e,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
Modifier and Type | Class and Description |
---|---|
class |
WrappedDRPCExecutionException
Wraps the generated TException to allow getMessage() to return a valid string.
|
Modifier and Type | Method and Description |
---|---|
String |
DRPCClient.execute(String func,
String args) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.