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
Nested Classes Modifier and Type Class Description static classDistributedRPCInvocations.Client.Factory
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidfailRequest(String id)voidfailRequestV2(String id, DRPCExecutionException e)DRPCRequestfetchRequest(String functionName)voidrecv_failRequest()voidrecv_failRequestV2()DRPCRequestrecv_fetchRequest()voidrecv_result()voidresult(String id, String result)voidsend_failRequest(String id)voidsend_failRequestV2(String id, DRPCExecutionException e)voidsend_fetchRequest(String functionName)voidsend_result(String id, String result)
-
-
-
Method Detail
-
result
public void result(String id, String result) throws AuthorizationException, org.apache.storm.thrift.TException
- Specified by:
resultin interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_result
public void send_result(String id, String result) throws org.apache.storm.thrift.TException
- Throws:
org.apache.storm.thrift.TException
-
recv_result
public void recv_result() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
fetchRequest
public DRPCRequest fetchRequest(String functionName) throws AuthorizationException, org.apache.storm.thrift.TException
- Specified by:
fetchRequestin interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_fetchRequest
public void send_fetchRequest(String functionName) throws org.apache.storm.thrift.TException
- Throws:
org.apache.storm.thrift.TException
-
recv_fetchRequest
public DRPCRequest recv_fetchRequest() throws AuthorizationException, org.apache.storm.thrift.TException
- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
failRequest
public void failRequest(String id) throws AuthorizationException, org.apache.storm.thrift.TException
- Specified by:
failRequestin interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_failRequest
public void send_failRequest(String id) throws org.apache.storm.thrift.TException
- Throws:
org.apache.storm.thrift.TException
-
recv_failRequest
public void recv_failRequest() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
failRequestV2
public void failRequestV2(String id, DRPCExecutionException e) throws AuthorizationException, org.apache.storm.thrift.TException
- Specified by:
failRequestV2in interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationExceptionorg.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
public void recv_failRequestV2() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
-