You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/11/05 21:41:15 UTC
[36/60] [abbrv] [partial] storm git commit: Release 2.0.4-SNAPSHOT
http://git-wip-us.apache.org/repos/asf/storm/blob/e935da91/jstorm-client/src/main/java/backtype/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/jstorm-client/src/main/java/backtype/storm/generated/Nimbus.java b/jstorm-client/src/main/java/backtype/storm/generated/Nimbus.java
deleted file mode 100644
index 6f63240..0000000
--- a/jstorm-client/src/main/java/backtype/storm/generated/Nimbus.java
+++ /dev/null
@@ -1,18351 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.7.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- */
-package backtype.storm.generated;
-
-import org.apache.commons.lang.builder.HashCodeBuilder;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class Nimbus {
-
- public interface Iface {
-
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException;
-
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException;
-
- public void killTopology(String name) throws NotAliveException, org.apache.thrift7.TException;
-
- public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift7.TException;
-
- public void activate(String name) throws NotAliveException, org.apache.thrift7.TException;
-
- public void deactivate(String name) throws NotAliveException, org.apache.thrift7.TException;
-
- public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift7.TException;
-
- public void metricMonitor(String name, MonitorOptions options) throws NotAliveException, org.apache.thrift7.TException;
-
- public void restart(String name, String jsonConf) throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException;
-
- public void beginLibUpload(String libName) throws org.apache.thrift7.TException;
-
- public String beginFileUpload() throws org.apache.thrift7.TException;
-
- public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift7.TException;
-
- public void finishFileUpload(String location) throws org.apache.thrift7.TException;
-
- public String beginFileDownload(String file) throws org.apache.thrift7.TException;
-
- public ByteBuffer downloadChunk(String id) throws org.apache.thrift7.TException;
-
- public String getNimbusConf() throws org.apache.thrift7.TException;
-
- public ClusterSummary getClusterInfo() throws org.apache.thrift7.TException;
-
- public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift7.TException;
-
- public TopologyInfo getTopologyInfoByName(String topologyName) throws NotAliveException, org.apache.thrift7.TException;
-
- public SupervisorWorkers getSupervisorWorkers(String host) throws NotAliveException, org.apache.thrift7.TException;
-
- public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift7.TException;
-
- public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift7.TException;
-
- public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift7.TException;
-
- public TopologyMetricInfo getTopologyMetric(String id) throws NotAliveException, org.apache.thrift7.TException;
-
- }
-
- public interface AsyncIface {
-
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.submitTopology_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.submitTopologyWithOpts_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void killTopology(String name, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.killTopology_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.killTopologyWithOpts_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void activate(String name, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.activate_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void deactivate(String name, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.deactivate_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void rebalance(String name, RebalanceOptions options, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.rebalance_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void metricMonitor(String name, MonitorOptions options, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.metricMonitor_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void restart(String name, String jsonConf, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.restart_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void beginLibUpload(String libName, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.beginLibUpload_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void beginFileUpload(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.beginFileUpload_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.uploadChunk_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void finishFileUpload(String location, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.finishFileUpload_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void beginFileDownload(String file, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.beginFileDownload_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void downloadChunk(String id, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.downloadChunk_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getNimbusConf(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getNimbusConf_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getClusterInfo(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getClusterInfo_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getTopologyInfo(String id, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getTopologyInfo_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getTopologyInfoByName(String topologyName, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getTopologyInfoByName_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getSupervisorWorkers(String host, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getSupervisorWorkers_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getTopologyConf(String id, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getTopologyConf_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getTopology(String id, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getTopology_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getUserTopology(String id, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getUserTopology_call> resultHandler) throws org.apache.thrift7.TException;
-
- public void getTopologyMetric(String id, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getTopologyMetric_call> resultHandler) throws org.apache.thrift7.TException;
-
- }
-
- public static class Client extends org.apache.thrift7.TServiceClient implements Iface {
- public static class Factory implements org.apache.thrift7.TServiceClientFactory<Client> {
- public Factory() {}
- public Client getClient(org.apache.thrift7.protocol.TProtocol prot) {
- return new Client(prot);
- }
- public Client getClient(org.apache.thrift7.protocol.TProtocol iprot, org.apache.thrift7.protocol.TProtocol oprot) {
- return new Client(iprot, oprot);
- }
- }
-
- public Client(org.apache.thrift7.protocol.TProtocol prot)
- {
- super(prot, prot);
- }
-
- public Client(org.apache.thrift7.protocol.TProtocol iprot, org.apache.thrift7.protocol.TProtocol oprot) {
- super(iprot, oprot);
- }
-
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException
- {
- send_submitTopology(name, uploadedJarLocation, jsonConf, topology);
- recv_submitTopology();
- }
-
- public void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.thrift7.TException
- {
- submitTopology_args args = new submitTopology_args();
- args.set_name(name);
- args.set_uploadedJarLocation(uploadedJarLocation);
- args.set_jsonConf(jsonConf);
- args.set_topology(topology);
- sendBase("submitTopology", args);
- }
-
- public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException
- {
- submitTopology_result result = new submitTopology_result();
- receiveBase(result, "submitTopology");
- if (result.e != null) {
- throw result.e;
- }
- if (result.ite != null) {
- throw result.ite;
- }
- if (result.tae != null) {
- throw result.tae;
- }
- return;
- }
-
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException
- {
- send_submitTopologyWithOpts(name, uploadedJarLocation, jsonConf, topology, options);
- recv_submitTopologyWithOpts();
- }
-
- public void send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.thrift7.TException
- {
- submitTopologyWithOpts_args args = new submitTopologyWithOpts_args();
- args.set_name(name);
- args.set_uploadedJarLocation(uploadedJarLocation);
- args.set_jsonConf(jsonConf);
- args.set_topology(topology);
- args.set_options(options);
- sendBase("submitTopologyWithOpts", args);
- }
-
- public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException
- {
- submitTopologyWithOpts_result result = new submitTopologyWithOpts_result();
- receiveBase(result, "submitTopologyWithOpts");
- if (result.e != null) {
- throw result.e;
- }
- if (result.ite != null) {
- throw result.ite;
- }
- if (result.tae != null) {
- throw result.tae;
- }
- return;
- }
-
- public void killTopology(String name) throws NotAliveException, org.apache.thrift7.TException
- {
- send_killTopology(name);
- recv_killTopology();
- }
-
- public void send_killTopology(String name) throws org.apache.thrift7.TException
- {
- killTopology_args args = new killTopology_args();
- args.set_name(name);
- sendBase("killTopology", args);
- }
-
- public void recv_killTopology() throws NotAliveException, org.apache.thrift7.TException
- {
- killTopology_result result = new killTopology_result();
- receiveBase(result, "killTopology");
- if (result.e != null) {
- throw result.e;
- }
- return;
- }
-
- public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift7.TException
- {
- send_killTopologyWithOpts(name, options);
- recv_killTopologyWithOpts();
- }
-
- public void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.thrift7.TException
- {
- killTopologyWithOpts_args args = new killTopologyWithOpts_args();
- args.set_name(name);
- args.set_options(options);
- sendBase("killTopologyWithOpts", args);
- }
-
- public void recv_killTopologyWithOpts() throws NotAliveException, org.apache.thrift7.TException
- {
- killTopologyWithOpts_result result = new killTopologyWithOpts_result();
- receiveBase(result, "killTopologyWithOpts");
- if (result.e != null) {
- throw result.e;
- }
- return;
- }
-
- public void activate(String name) throws NotAliveException, org.apache.thrift7.TException
- {
- send_activate(name);
- recv_activate();
- }
-
- public void send_activate(String name) throws org.apache.thrift7.TException
- {
- activate_args args = new activate_args();
- args.set_name(name);
- sendBase("activate", args);
- }
-
- public void recv_activate() throws NotAliveException, org.apache.thrift7.TException
- {
- activate_result result = new activate_result();
- receiveBase(result, "activate");
- if (result.e != null) {
- throw result.e;
- }
- return;
- }
-
- public void deactivate(String name) throws NotAliveException, org.apache.thrift7.TException
- {
- send_deactivate(name);
- recv_deactivate();
- }
-
- public void send_deactivate(String name) throws org.apache.thrift7.TException
- {
- deactivate_args args = new deactivate_args();
- args.set_name(name);
- sendBase("deactivate", args);
- }
-
- public void recv_deactivate() throws NotAliveException, org.apache.thrift7.TException
- {
- deactivate_result result = new deactivate_result();
- receiveBase(result, "deactivate");
- if (result.e != null) {
- throw result.e;
- }
- return;
- }
-
- public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift7.TException
- {
- send_rebalance(name, options);
- recv_rebalance();
- }
-
- public void send_rebalance(String name, RebalanceOptions options) throws org.apache.thrift7.TException
- {
- rebalance_args args = new rebalance_args();
- args.set_name(name);
- args.set_options(options);
- sendBase("rebalance", args);
- }
-
- public void recv_rebalance() throws NotAliveException, InvalidTopologyException, org.apache.thrift7.TException
- {
- rebalance_result result = new rebalance_result();
- receiveBase(result, "rebalance");
- if (result.e != null) {
- throw result.e;
- }
- if (result.ite != null) {
- throw result.ite;
- }
- return;
- }
-
- public void metricMonitor(String name, MonitorOptions options) throws NotAliveException, org.apache.thrift7.TException
- {
- send_metricMonitor(name, options);
- recv_metricMonitor();
- }
-
- public void send_metricMonitor(String name, MonitorOptions options) throws org.apache.thrift7.TException
- {
- metricMonitor_args args = new metricMonitor_args();
- args.set_name(name);
- args.set_options(options);
- sendBase("metricMonitor", args);
- }
-
- public void recv_metricMonitor() throws NotAliveException, org.apache.thrift7.TException
- {
- metricMonitor_result result = new metricMonitor_result();
- receiveBase(result, "metricMonitor");
- if (result.e != null) {
- throw result.e;
- }
- return;
- }
-
- public void restart(String name, String jsonConf) throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException
- {
- send_restart(name, jsonConf);
- recv_restart();
- }
-
- public void send_restart(String name, String jsonConf) throws org.apache.thrift7.TException
- {
- restart_args args = new restart_args();
- args.set_name(name);
- args.set_jsonConf(jsonConf);
- sendBase("restart", args);
- }
-
- public void recv_restart() throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException
- {
- restart_result result = new restart_result();
- receiveBase(result, "restart");
- if (result.e != null) {
- throw result.e;
- }
- if (result.ite != null) {
- throw result.ite;
- }
- if (result.tae != null) {
- throw result.tae;
- }
- return;
- }
-
- public void beginLibUpload(String libName) throws org.apache.thrift7.TException
- {
- send_beginLibUpload(libName);
- recv_beginLibUpload();
- }
-
- public void send_beginLibUpload(String libName) throws org.apache.thrift7.TException
- {
- beginLibUpload_args args = new beginLibUpload_args();
- args.set_libName(libName);
- sendBase("beginLibUpload", args);
- }
-
- public void recv_beginLibUpload() throws org.apache.thrift7.TException
- {
- beginLibUpload_result result = new beginLibUpload_result();
- receiveBase(result, "beginLibUpload");
- return;
- }
-
- public String beginFileUpload() throws org.apache.thrift7.TException
- {
- send_beginFileUpload();
- return recv_beginFileUpload();
- }
-
- public void send_beginFileUpload() throws org.apache.thrift7.TException
- {
- beginFileUpload_args args = new beginFileUpload_args();
- sendBase("beginFileUpload", args);
- }
-
- public String recv_beginFileUpload() throws org.apache.thrift7.TException
- {
- beginFileUpload_result result = new beginFileUpload_result();
- receiveBase(result, "beginFileUpload");
- if (result.is_set_success()) {
- return result.success;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result");
- }
-
- public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift7.TException
- {
- send_uploadChunk(location, chunk);
- recv_uploadChunk();
- }
-
- public void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift7.TException
- {
- uploadChunk_args args = new uploadChunk_args();
- args.set_location(location);
- args.set_chunk(chunk);
- sendBase("uploadChunk", args);
- }
-
- public void recv_uploadChunk() throws org.apache.thrift7.TException
- {
- uploadChunk_result result = new uploadChunk_result();
- receiveBase(result, "uploadChunk");
- return;
- }
-
- public void finishFileUpload(String location) throws org.apache.thrift7.TException
- {
- send_finishFileUpload(location);
- recv_finishFileUpload();
- }
-
- public void send_finishFileUpload(String location) throws org.apache.thrift7.TException
- {
- finishFileUpload_args args = new finishFileUpload_args();
- args.set_location(location);
- sendBase("finishFileUpload", args);
- }
-
- public void recv_finishFileUpload() throws org.apache.thrift7.TException
- {
- finishFileUpload_result result = new finishFileUpload_result();
- receiveBase(result, "finishFileUpload");
- return;
- }
-
- public String beginFileDownload(String file) throws org.apache.thrift7.TException
- {
- send_beginFileDownload(file);
- return recv_beginFileDownload();
- }
-
- public void send_beginFileDownload(String file) throws org.apache.thrift7.TException
- {
- beginFileDownload_args args = new beginFileDownload_args();
- args.set_file(file);
- sendBase("beginFileDownload", args);
- }
-
- public String recv_beginFileDownload() throws org.apache.thrift7.TException
- {
- beginFileDownload_result result = new beginFileDownload_result();
- receiveBase(result, "beginFileDownload");
- if (result.is_set_success()) {
- return result.success;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
- }
-
- public ByteBuffer downloadChunk(String id) throws org.apache.thrift7.TException
- {
- send_downloadChunk(id);
- return recv_downloadChunk();
- }
-
- public void send_downloadChunk(String id) throws org.apache.thrift7.TException
- {
- downloadChunk_args args = new downloadChunk_args();
- args.set_id(id);
- sendBase("downloadChunk", args);
- }
-
- public ByteBuffer recv_downloadChunk() throws org.apache.thrift7.TException
- {
- downloadChunk_result result = new downloadChunk_result();
- receiveBase(result, "downloadChunk");
- if (result.is_set_success()) {
- return result.success;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result");
- }
-
- public String getNimbusConf() throws org.apache.thrift7.TException
- {
- send_getNimbusConf();
- return recv_getNimbusConf();
- }
-
- public void send_getNimbusConf() throws org.apache.thrift7.TException
- {
- getNimbusConf_args args = new getNimbusConf_args();
- sendBase("getNimbusConf", args);
- }
-
- public String recv_getNimbusConf() throws org.apache.thrift7.TException
- {
- getNimbusConf_result result = new getNimbusConf_result();
- receiveBase(result, "getNimbusConf");
- if (result.is_set_success()) {
- return result.success;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result");
- }
-
- public ClusterSummary getClusterInfo() throws org.apache.thrift7.TException
- {
- send_getClusterInfo();
- return recv_getClusterInfo();
- }
-
- public void send_getClusterInfo() throws org.apache.thrift7.TException
- {
- getClusterInfo_args args = new getClusterInfo_args();
- sendBase("getClusterInfo", args);
- }
-
- public ClusterSummary recv_getClusterInfo() throws org.apache.thrift7.TException
- {
- getClusterInfo_result result = new getClusterInfo_result();
- receiveBase(result, "getClusterInfo");
- if (result.is_set_success()) {
- return result.success;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result");
- }
-
- public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getTopologyInfo(id);
- return recv_getTopologyInfo();
- }
-
- public void send_getTopologyInfo(String id) throws org.apache.thrift7.TException
- {
- getTopologyInfo_args args = new getTopologyInfo_args();
- args.set_id(id);
- sendBase("getTopologyInfo", args);
- }
-
- public TopologyInfo recv_getTopologyInfo() throws NotAliveException, org.apache.thrift7.TException
- {
- getTopologyInfo_result result = new getTopologyInfo_result();
- receiveBase(result, "getTopologyInfo");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result");
- }
-
- public TopologyInfo getTopologyInfoByName(String topologyName) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getTopologyInfoByName(topologyName);
- return recv_getTopologyInfoByName();
- }
-
- public void send_getTopologyInfoByName(String topologyName) throws org.apache.thrift7.TException
- {
- getTopologyInfoByName_args args = new getTopologyInfoByName_args();
- args.set_topologyName(topologyName);
- sendBase("getTopologyInfoByName", args);
- }
-
- public TopologyInfo recv_getTopologyInfoByName() throws NotAliveException, org.apache.thrift7.TException
- {
- getTopologyInfoByName_result result = new getTopologyInfoByName_result();
- receiveBase(result, "getTopologyInfoByName");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getTopologyInfoByName failed: unknown result");
- }
-
- public SupervisorWorkers getSupervisorWorkers(String host) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getSupervisorWorkers(host);
- return recv_getSupervisorWorkers();
- }
-
- public void send_getSupervisorWorkers(String host) throws org.apache.thrift7.TException
- {
- getSupervisorWorkers_args args = new getSupervisorWorkers_args();
- args.set_host(host);
- sendBase("getSupervisorWorkers", args);
- }
-
- public SupervisorWorkers recv_getSupervisorWorkers() throws NotAliveException, org.apache.thrift7.TException
- {
- getSupervisorWorkers_result result = new getSupervisorWorkers_result();
- receiveBase(result, "getSupervisorWorkers");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getSupervisorWorkers failed: unknown result");
- }
-
- public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getTopologyConf(id);
- return recv_getTopologyConf();
- }
-
- public void send_getTopologyConf(String id) throws org.apache.thrift7.TException
- {
- getTopologyConf_args args = new getTopologyConf_args();
- args.set_id(id);
- sendBase("getTopologyConf", args);
- }
-
- public String recv_getTopologyConf() throws NotAliveException, org.apache.thrift7.TException
- {
- getTopologyConf_result result = new getTopologyConf_result();
- receiveBase(result, "getTopologyConf");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getTopologyConf failed: unknown result");
- }
-
- public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getTopology(id);
- return recv_getTopology();
- }
-
- public void send_getTopology(String id) throws org.apache.thrift7.TException
- {
- getTopology_args args = new getTopology_args();
- args.set_id(id);
- sendBase("getTopology", args);
- }
-
- public StormTopology recv_getTopology() throws NotAliveException, org.apache.thrift7.TException
- {
- getTopology_result result = new getTopology_result();
- receiveBase(result, "getTopology");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getTopology failed: unknown result");
- }
-
- public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getUserTopology(id);
- return recv_getUserTopology();
- }
-
- public void send_getUserTopology(String id) throws org.apache.thrift7.TException
- {
- getUserTopology_args args = new getUserTopology_args();
- args.set_id(id);
- sendBase("getUserTopology", args);
- }
-
- public StormTopology recv_getUserTopology() throws NotAliveException, org.apache.thrift7.TException
- {
- getUserTopology_result result = new getUserTopology_result();
- receiveBase(result, "getUserTopology");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getUserTopology failed: unknown result");
- }
-
- public TopologyMetricInfo getTopologyMetric(String id) throws NotAliveException, org.apache.thrift7.TException
- {
- send_getTopologyMetric(id);
- return recv_getTopologyMetric();
- }
-
- public void send_getTopologyMetric(String id) throws org.apache.thrift7.TException
- {
- getTopologyMetric_args args = new getTopologyMetric_args();
- args.set_id(id);
- sendBase("getTopologyMetric", args);
- }
-
- public TopologyMetricInfo recv_getTopologyMetric() throws NotAliveException, org.apache.thrift7.TException
- {
- getTopologyMetric_result result = new getTopologyMetric_result();
- receiveBase(result, "getTopologyMetric");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.e != null) {
- throw result.e;
- }
- throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getTopologyMetric failed: unknown result");
- }
-
- }
- public static class AsyncClient extends org.apache.thrift7.async.TAsyncClient implements AsyncIface {
- public static class Factory implements org.apache.thrift7.async.TAsyncClientFactory<AsyncClient> {
- private org.apache.thrift7.async.TAsyncClientManager clientManager;
- private org.apache.thrift7.protocol.TProtocolFactory protocolFactory;
- public Factory(org.apache.thrift7.async.TAsyncClientManager clientManager, org.apache.thrift7.protocol.TProtocolFactory protocolFactory) {
- this.clientManager = clientManager;
- this.protocolFactory = protocolFactory;
- }
- public AsyncClient getAsyncClient(org.apache.thrift7.transport.TNonblockingTransport transport) {
- return new AsyncClient(protocolFactory, clientManager, transport);
- }
- }
-
- public AsyncClient(org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.async.TAsyncClientManager clientManager, org.apache.thrift7.transport.TNonblockingTransport transport) {
- super(protocolFactory, clientManager, transport);
- }
-
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift7.async.AsyncMethodCallback<submitTopology_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- submitTopology_call method_call = new submitTopology_call(name, uploadedJarLocation, jsonConf, topology, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class submitTopology_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- private String uploadedJarLocation;
- private String jsonConf;
- private StormTopology topology;
- public submitTopology_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift7.async.AsyncMethodCallback<submitTopology_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- this.uploadedJarLocation = uploadedJarLocation;
- this.jsonConf = jsonConf;
- this.topology = topology;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("submitTopology", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- submitTopology_args args = new submitTopology_args();
- args.set_name(name);
- args.set_uploadedJarLocation(uploadedJarLocation);
- args.set_jsonConf(jsonConf);
- args.set_topology(topology);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_submitTopology();
- }
- }
-
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift7.async.AsyncMethodCallback<submitTopologyWithOpts_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- submitTopologyWithOpts_call method_call = new submitTopologyWithOpts_call(name, uploadedJarLocation, jsonConf, topology, options, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class submitTopologyWithOpts_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- private String uploadedJarLocation;
- private String jsonConf;
- private StormTopology topology;
- private SubmitOptions options;
- public submitTopologyWithOpts_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift7.async.AsyncMethodCallback<submitTopologyWithOpts_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- this.uploadedJarLocation = uploadedJarLocation;
- this.jsonConf = jsonConf;
- this.topology = topology;
- this.options = options;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("submitTopologyWithOpts", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- submitTopologyWithOpts_args args = new submitTopologyWithOpts_args();
- args.set_name(name);
- args.set_uploadedJarLocation(uploadedJarLocation);
- args.set_jsonConf(jsonConf);
- args.set_topology(topology);
- args.set_options(options);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_submitTopologyWithOpts();
- }
- }
-
- public void killTopology(String name, org.apache.thrift7.async.AsyncMethodCallback<killTopology_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- killTopology_call method_call = new killTopology_call(name, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class killTopology_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- public killTopology_call(String name, org.apache.thrift7.async.AsyncMethodCallback<killTopology_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("killTopology", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- killTopology_args args = new killTopology_args();
- args.set_name(name);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_killTopology();
- }
- }
-
- public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift7.async.AsyncMethodCallback<killTopologyWithOpts_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- killTopologyWithOpts_call method_call = new killTopologyWithOpts_call(name, options, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class killTopologyWithOpts_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- private KillOptions options;
- public killTopologyWithOpts_call(String name, KillOptions options, org.apache.thrift7.async.AsyncMethodCallback<killTopologyWithOpts_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- this.options = options;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("killTopologyWithOpts", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- killTopologyWithOpts_args args = new killTopologyWithOpts_args();
- args.set_name(name);
- args.set_options(options);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_killTopologyWithOpts();
- }
- }
-
- public void activate(String name, org.apache.thrift7.async.AsyncMethodCallback<activate_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- activate_call method_call = new activate_call(name, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class activate_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- public activate_call(String name, org.apache.thrift7.async.AsyncMethodCallback<activate_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("activate", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- activate_args args = new activate_args();
- args.set_name(name);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_activate();
- }
- }
-
- public void deactivate(String name, org.apache.thrift7.async.AsyncMethodCallback<deactivate_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- deactivate_call method_call = new deactivate_call(name, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class deactivate_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- public deactivate_call(String name, org.apache.thrift7.async.AsyncMethodCallback<deactivate_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("deactivate", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- deactivate_args args = new deactivate_args();
- args.set_name(name);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_deactivate();
- }
- }
-
- public void rebalance(String name, RebalanceOptions options, org.apache.thrift7.async.AsyncMethodCallback<rebalance_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- rebalance_call method_call = new rebalance_call(name, options, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class rebalance_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- private RebalanceOptions options;
- public rebalance_call(String name, RebalanceOptions options, org.apache.thrift7.async.AsyncMethodCallback<rebalance_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- this.options = options;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("rebalance", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- rebalance_args args = new rebalance_args();
- args.set_name(name);
- args.set_options(options);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, InvalidTopologyException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_rebalance();
- }
- }
-
- public void metricMonitor(String name, MonitorOptions options, org.apache.thrift7.async.AsyncMethodCallback<metricMonitor_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- metricMonitor_call method_call = new metricMonitor_call(name, options, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class metricMonitor_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- private MonitorOptions options;
- public metricMonitor_call(String name, MonitorOptions options, org.apache.thrift7.async.AsyncMethodCallback<metricMonitor_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- this.options = options;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("metricMonitor", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- metricMonitor_args args = new metricMonitor_args();
- args.set_name(name);
- args.set_options(options);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_metricMonitor();
- }
- }
-
- public void restart(String name, String jsonConf, org.apache.thrift7.async.AsyncMethodCallback<restart_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- restart_call method_call = new restart_call(name, jsonConf, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class restart_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String name;
- private String jsonConf;
- public restart_call(String name, String jsonConf, org.apache.thrift7.async.AsyncMethodCallback<restart_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.name = name;
- this.jsonConf = jsonConf;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("restart", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- restart_args args = new restart_args();
- args.set_name(name);
- args.set_jsonConf(jsonConf);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_restart();
- }
- }
-
- public void beginLibUpload(String libName, org.apache.thrift7.async.AsyncMethodCallback<beginLibUpload_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- beginLibUpload_call method_call = new beginLibUpload_call(libName, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class beginLibUpload_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String libName;
- public beginLibUpload_call(String libName, org.apache.thrift7.async.AsyncMethodCallback<beginLibUpload_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.libName = libName;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("beginLibUpload", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- beginLibUpload_args args = new beginLibUpload_args();
- args.set_libName(libName);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_beginLibUpload();
- }
- }
-
- public void beginFileUpload(org.apache.thrift7.async.AsyncMethodCallback<beginFileUpload_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- beginFileUpload_call method_call = new beginFileUpload_call(resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class beginFileUpload_call extends org.apache.thrift7.async.TAsyncMethodCall {
- public beginFileUpload_call(org.apache.thrift7.async.AsyncMethodCallback<beginFileUpload_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("beginFileUpload", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- beginFileUpload_args args = new beginFileUpload_args();
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public String getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_beginFileUpload();
- }
- }
-
- public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift7.async.AsyncMethodCallback<uploadChunk_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- uploadChunk_call method_call = new uploadChunk_call(location, chunk, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class uploadChunk_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String location;
- private ByteBuffer chunk;
- public uploadChunk_call(String location, ByteBuffer chunk, org.apache.thrift7.async.AsyncMethodCallback<uploadChunk_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.location = location;
- this.chunk = chunk;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("uploadChunk", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- uploadChunk_args args = new uploadChunk_args();
- args.set_location(location);
- args.set_chunk(chunk);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_uploadChunk();
- }
- }
-
- public void finishFileUpload(String location, org.apache.thrift7.async.AsyncMethodCallback<finishFileUpload_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- finishFileUpload_call method_call = new finishFileUpload_call(location, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class finishFileUpload_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String location;
- public finishFileUpload_call(String location, org.apache.thrift7.async.AsyncMethodCallback<finishFileUpload_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.location = location;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("finishFileUpload", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- finishFileUpload_args args = new finishFileUpload_args();
- args.set_location(location);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_finishFileUpload();
- }
- }
-
- public void beginFileDownload(String file, org.apache.thrift7.async.AsyncMethodCallback<beginFileDownload_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- beginFileDownload_call method_call = new beginFileDownload_call(file, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class beginFileDownload_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String file;
- public beginFileDownload_call(String file, org.apache.thrift7.async.AsyncMethodCallback<beginFileDownload_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.file = file;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("beginFileDownload", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- beginFileDownload_args args = new beginFileDownload_args();
- args.set_file(file);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public String getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_beginFileDownload();
- }
- }
-
- public void downloadChunk(String id, org.apache.thrift7.async.AsyncMethodCallback<downloadChunk_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- downloadChunk_call method_call = new downloadChunk_call(id, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class downloadChunk_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String id;
- public downloadChunk_call(String id, org.apache.thrift7.async.AsyncMethodCallback<downloadChunk_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.id = id;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("downloadChunk", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- downloadChunk_args args = new downloadChunk_args();
- args.set_id(id);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public ByteBuffer getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_downloadChunk();
- }
- }
-
- public void getNimbusConf(org.apache.thrift7.async.AsyncMethodCallback<getNimbusConf_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getNimbusConf_call method_call = new getNimbusConf_call(resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getNimbusConf_call extends org.apache.thrift7.async.TAsyncMethodCall {
- public getNimbusConf_call(org.apache.thrift7.async.AsyncMethodCallback<getNimbusConf_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getNimbusConf", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getNimbusConf_args args = new getNimbusConf_args();
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public String getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getNimbusConf();
- }
- }
-
- public void getClusterInfo(org.apache.thrift7.async.AsyncMethodCallback<getClusterInfo_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getClusterInfo_call method_call = new getClusterInfo_call(resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getClusterInfo_call extends org.apache.thrift7.async.TAsyncMethodCall {
- public getClusterInfo_call(org.apache.thrift7.async.AsyncMethodCallback<getClusterInfo_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getClusterInfo", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getClusterInfo_args args = new getClusterInfo_args();
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public ClusterSummary getResult() throws org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getClusterInfo();
- }
- }
-
- public void getTopologyInfo(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopologyInfo_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getTopologyInfo_call method_call = new getTopologyInfo_call(id, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getTopologyInfo_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String id;
- public getTopologyInfo_call(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopologyInfo_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.id = id;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getTopologyInfo", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getTopologyInfo_args args = new getTopologyInfo_args();
- args.set_id(id);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public TopologyInfo getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getTopologyInfo();
- }
- }
-
- public void getTopologyInfoByName(String topologyName, org.apache.thrift7.async.AsyncMethodCallback<getTopologyInfoByName_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getTopologyInfoByName_call method_call = new getTopologyInfoByName_call(topologyName, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getTopologyInfoByName_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String topologyName;
- public getTopologyInfoByName_call(String topologyName, org.apache.thrift7.async.AsyncMethodCallback<getTopologyInfoByName_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.topologyName = topologyName;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getTopologyInfoByName", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getTopologyInfoByName_args args = new getTopologyInfoByName_args();
- args.set_topologyName(topologyName);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public TopologyInfo getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getTopologyInfoByName();
- }
- }
-
- public void getSupervisorWorkers(String host, org.apache.thrift7.async.AsyncMethodCallback<getSupervisorWorkers_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getSupervisorWorkers_call method_call = new getSupervisorWorkers_call(host, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getSupervisorWorkers_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String host;
- public getSupervisorWorkers_call(String host, org.apache.thrift7.async.AsyncMethodCallback<getSupervisorWorkers_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.host = host;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getSupervisorWorkers", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getSupervisorWorkers_args args = new getSupervisorWorkers_args();
- args.set_host(host);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public SupervisorWorkers getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getSupervisorWorkers();
- }
- }
-
- public void getTopologyConf(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopologyConf_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getTopologyConf_call method_call = new getTopologyConf_call(id, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getTopologyConf_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String id;
- public getTopologyConf_call(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopologyConf_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.id = id;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getTopologyConf", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getTopologyConf_args args = new getTopologyConf_args();
- args.set_id(id);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public String getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getTopologyConf();
- }
- }
-
- public void getTopology(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopology_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getTopology_call method_call = new getTopology_call(id, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getTopology_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String id;
- public getTopology_call(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopology_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.id = id;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getTopology", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getTopology_args args = new getTopology_args();
- args.set_id(id);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public StormTopology getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getTopology();
- }
- }
-
- public void getUserTopology(String id, org.apache.thrift7.async.AsyncMethodCallback<getUserTopology_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getUserTopology_call method_call = new getUserTopology_call(id, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getUserTopology_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String id;
- public getUserTopology_call(String id, org.apache.thrift7.async.AsyncMethodCallback<getUserTopology_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.id = id;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getUserTopology", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getUserTopology_args args = new getUserTopology_args();
- args.set_id(id);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public StormTopology getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getUserTopology();
- }
- }
-
- public void getTopologyMetric(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopologyMetric_call> resultHandler) throws org.apache.thrift7.TException {
- checkReady();
- getTopologyMetric_call method_call = new getTopologyMetric_call(id, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class getTopologyMetric_call extends org.apache.thrift7.async.TAsyncMethodCall {
- private String id;
- public getTopologyMetric_call(String id, org.apache.thrift7.async.AsyncMethodCallback<getTopologyMetric_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.id = id;
- }
-
- public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
- prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getTopologyMetric", org.apache.thrift7.protocol.TMessageType.CALL, 0));
- getTopologyMetric_args args = new getTopologyMetric_args();
- args.set_id(id);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public TopologyMetricInfo getResult() throws NotAliveException, org.apache.thrift7.TException {
- if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getTopologyMetric();
- }
- }
-
- }
-
- public static class Processor<I extends Iface> extends org.apache.thrift7.TBaseProcessor implements org.apache.thrift7.TProcessor {
- private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
- public Processor(I iface) {
- super(iface, getProcessMap(new HashMap<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>>()));
- }
-
- protected Processor(I iface, Map<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>> processMap) {
- super(iface, getProcessMap(processMap));
- }
-
- private static <I extends Iface> Map<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>> getProcessMap(Map<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>> processMap) {
- processMap.put("submitTopology", new submitTopology());
- processMap.put("submitTopologyWithOpts", new submitTopologyWithOpts());
- processMap.put("killTopology", new killTopology());
- processMap.put("killTopologyWithOpts", new killTopologyWithOpts());
- processMap.put("activate", new activate());
- processMap.put("deactivate", new deactivate());
- processMap.put("rebalance", new rebalance());
- processMap.put("metricMonitor", new metricMonitor());
- processMap.put("restart", new restart());
- processMap.put("beginLibUpload", new beginLibUpload());
- processMap.put("beginFileUpload", new beginFileUpload());
- processMap.put("uploadChunk", new uploadChunk());
- processMap.put("finishFileUpload", new finishFileUpload());
- processMap.put("beginFileDownload", new beginFileDownload());
- processMap.put("downloadChunk", new downloadChunk());
- processMap.put("getNimbusConf", new getNimbusConf());
- processMap.put("getClusterInfo", new getClusterInfo());
- processMap.put("getTopologyInfo", new getTopologyInfo());
- processMap.put("getTopologyInfoByName", new getTopologyInfoByName());
- processMap.put("getSupervisorWorkers", new getSupervisorWorkers());
- processMap.put("getTopologyConf", new getTopologyConf());
- processMap.put("getTopology", new getTopology());
- processMap.put("getUserTopology", new getUserTopology());
- processMap.put("getTopologyMetric", new getTopologyMetric());
- return processMap;
- }
-
- private static class submitTopology<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, submitTopology_args> {
- public submitTopology() {
- super("submitTopology");
- }
-
- protected submitTopology_args getEmptyArgsInstance() {
- return new submitTopology_args();
- }
-
- protected submitTopology_result getResult(I iface, submitTopology_args args) throws org.apache.thrift7.TException {
- submitTopology_result result = new submitTopology_result();
- try {
- iface.submitTopology(args.name, args.uploadedJarLocation, args.jsonConf, args.topology);
- } catch (AlreadyAliveException e) {
- result.e = e;
- } catch (InvalidTopologyException ite) {
- result.ite = ite;
- } catch (TopologyAssignException tae) {
- result.tae = tae;
- }
- return result;
- }
- }
-
- private static class submitTopologyWithOpts<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, submitTopologyWithOpts_args> {
- public submitTopologyWithOpts() {
- super("submitTopologyWithOpts");
- }
-
- protected submitTopologyWithOpts_args getEmptyArgsInstance() {
- return new submitTopologyWithOpts_args();
- }
-
- protected submitTopologyWithOpts_result getResult(I iface, submitTopologyWithOpts_args args) throws org.apache.thrift7.TException {
- submitTopologyWithOpts_result result = new submitTopologyWithOpts_result();
- try {
- iface.submitTopologyWithOpts(args.name, args.uploadedJarLocation, args.jsonConf, args.topology, args.options);
- } catch (AlreadyAliveException e) {
- result.e = e;
- } catch (InvalidTopologyException ite) {
- result.ite = ite;
- } catch (TopologyAssignException tae) {
- result.tae = tae;
- }
- return result;
- }
- }
-
- private static class killTopology<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, killTopology_args> {
- public killTopology() {
- super("killTopology");
- }
-
- protected killTopology_args getEmptyArgsInstance() {
- return new killTopology_args();
- }
-
- protected killTopology_result getResult(I iface, killTopology_args args) throws org.apache.thrift7.TException {
- killTopology_result result = new killTopology_result();
- try {
- iface.killTopology(args.name);
- } catch (NotAliveException e) {
- result.e = e;
- }
- return result;
- }
- }
-
- private static class killTopologyWithOpts<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, killTopologyWithOpts_args> {
- public killTopologyWithOpts() {
- super("killTopologyWithOpts");
- }
-
- protected killTopologyWithOpts_args getEmptyArgsInstance() {
- return new killTopologyWithOpts_args();
- }
-
- protected killTopologyWithOpts_result getResult(I iface, killTopologyWithOpts_args args) throws org.apache.thrift7.TException {
- killTopologyWithOpts_result result = new killTopologyWithOpts_result();
- try {
- iface.killTopologyWithOpts(args.name, args.options);
- } catch (NotAliveException e) {
- result.e = e;
- }
- return result;
- }
- }
-
- private static class activate<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, activate_args> {
- public activate() {
- super("activate");
- }
-
- protected activate_args getEmptyArgsInstance() {
- return new activate_args();
- }
-
- protected activate_result getResult(I iface, activate_args args) throws org.apache.thrift7.TException {
- activate_result result = new activate_result();
- try {
- iface.activate(args.name);
- } catch (NotAliveException e) {
- result.e = e;
- }
- return result;
- }
- }
-
- private static class deactivate<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, deactivate_args> {
- public deactivate() {
- super("deactivate");
- }
-
- protected deactivate_args getEmptyArgsInstance() {
- return new deactivate_args();
- }
-
- protected deactivate_result getResult(I iface, deactivate_args args) throws org.apache.thrift7.TException {
- deactivate_result result = new deactivate_result();
- try {
- iface.deactivate(args.name);
- } catch (NotAliveException e) {
- result.e = e;
- }
- return result;
- }
- }
-
- private static class rebalance<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, rebalance_args> {
- public rebalance() {
- super("rebalance");
- }
-
- protected rebalance_args getEmptyArgsInstance() {
- return new rebalance_args();
- }
-
- protected rebalance_result getResult(I iface, rebalance_args args) throws org.apache.thrift7.TException {
- rebalance_result result = new rebalance_result();
- try {
- iface.rebalance(args.name, args.options);
- } catch (NotAliveException e) {
- result.e = e;
- } catch (InvalidTopologyException ite) {
-
<TRUNCATED>