Package org.apache.storm.daemon.drpc
Class DRPCThrift
java.lang.Object
org.apache.storm.daemon.drpc.DRPCThrift
- All Implemented Interfaces:
DistributedRPC.Iface,DistributedRPCInvocations.Iface
public class DRPCThrift
extends Object
implements DistributedRPC.Iface, DistributedRPCInvocations.Iface
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidfailRequest(String id) voidfetchRequest(String functionName) void
-
Constructor Details
-
DRPCThrift
-
-
Method Details
-
result
- Specified by:
resultin interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationException
-
fetchRequest
- Specified by:
fetchRequestin interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationException
-
failRequest
- Specified by:
failRequestin interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationException
-
failRequestV2
- Specified by:
failRequestV2in interfaceDistributedRPCInvocations.Iface- Throws:
AuthorizationException
-
execute
public String execute(String functionName, String funcArgs) throws DRPCExecutionException, AuthorizationException - Specified by:
executein interfaceDistributedRPC.Iface- Throws:
DRPCExecutionExceptionAuthorizationException
-