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
-
Method Summary
Modifier and TypeMethodDescriptionvoid
failRequest
(String id) void
fetchRequest
(String functionName) void
-
Constructor Details
-
DRPCThrift
-
-
Method Details
-
result
- Specified by:
result
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
-
fetchRequest
- Specified by:
fetchRequest
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
-
failRequest
- Specified by:
failRequest
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
-
failRequestV2
- Specified by:
failRequestV2
in interfaceDistributedRPCInvocations.Iface
- Throws:
AuthorizationException
-
execute
public String execute(String functionName, String funcArgs) throws DRPCExecutionException, AuthorizationException - Specified by:
execute
in interfaceDistributedRPC.Iface
- Throws:
DRPCExecutionException
AuthorizationException
-