Package org.apache.storm.generated
Class DistributedRPCInvocations.Client
java.lang.Object
org.apache.storm.thrift.TServiceClient
org.apache.storm.generated.DistributedRPCInvocations.Client
- All Implemented Interfaces:
DistributedRPCInvocations.Iface
- Enclosing class:
- DistributedRPCInvocations
public static class DistributedRPCInvocations.Client
extends org.apache.storm.thrift.TServiceClient
implements DistributedRPCInvocations.Iface
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.apache.storm.thrift.TServiceClient
iprot_, oprot_, seqid_
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
failRequest
(String id) void
fetchRequest
(String functionName) void
void
void
void
void
void
void
send_fetchRequest
(String functionName) void
send_result
(String id, String result) Methods inherited from class org.apache.storm.thrift.TServiceClient
getInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway
-
Constructor Details
-
Client
public Client(org.apache.storm.thrift.protocol.TProtocol prot) -
Client
public Client(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot)
-
-
Method Details
-
result
public void result(String id, String result) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
result
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
send_result
- Throws:
org.apache.storm.thrift.TException
-
recv_result
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
fetchRequest
public DRPCRequest fetchRequest(String functionName) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
fetchRequest
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
send_fetchRequest
- Throws:
org.apache.storm.thrift.TException
-
recv_fetchRequest
public DRPCRequest recv_fetchRequest() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
failRequest
public void failRequest(String id) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
failRequest
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
send_failRequest
- Throws:
org.apache.storm.thrift.TException
-
recv_failRequest
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
failRequestV2
public void failRequestV2(String id, DRPCExecutionException e) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
failRequestV2
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
send_failRequestV2
public void send_failRequestV2(String id, DRPCExecutionException e) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_failRequestV2
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-