http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/Nimbus.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/Nimbus.java b/jstorm-core/src/main/java/backtype/storm/generated/Nimbus.java index c25d643..b0fb528 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/Nimbus.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/Nimbus.java @@ -34,138 +34,170 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class Nimbus { public interface Iface { - public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException; + public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException; - public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException; + public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException; - public void killTopology(String name) throws NotAliveException, org.apache.thrift.TException; + public void killTopology(String name) throws NotAliveException, TException; - public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift.TException; + public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, TException; - public void activate(String name) throws NotAliveException, org.apache.thrift.TException; + public void activate(String name) throws NotAliveException, TException; - public void deactivate(String name) throws NotAliveException, org.apache.thrift.TException; + public void deactivate(String name) throws NotAliveException, TException; - public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException; + public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, TException; - public void metricMonitor(String name, MonitorOptions options) throws NotAliveException, org.apache.thrift.TException; + public void metricMonitor(String name, MonitorOptions options) throws NotAliveException, TException; - public void restart(String name, String jsonConf) throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException; + public void restart(String name, String jsonConf) throws NotAliveException, InvalidTopologyException, TopologyAssignException, TException; - public void beginLibUpload(String libName) throws org.apache.thrift.TException; + public void beginLibUpload(String libName) throws TException; - public String beginFileUpload() throws org.apache.thrift.TException; + public String beginFileUpload() throws TException; - public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException; + public void uploadChunk(String location, ByteBuffer chunk) throws TException; - public void finishFileUpload(String location) throws org.apache.thrift.TException; + public void finishFileUpload(String location) throws TException; - public String beginFileDownload(String file) throws org.apache.thrift.TException; + public String beginFileDownload(String file) throws TException; - public ByteBuffer downloadChunk(String id) throws org.apache.thrift.TException; + public ByteBuffer downloadChunk(String id) throws TException; - public void finishFileDownload(String id) throws org.apache.thrift.TException; + public void finishFileDownload(String id) throws TException; - public String getNimbusConf() throws org.apache.thrift.TException; + public String getNimbusConf() throws TException; - public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift.TException; + public String getTopologyConf(String id) throws NotAliveException, TException; - public String getTopologyId(String topologyName) throws NotAliveException, org.apache.thrift.TException; + public String getTopologyId(String topologyName) throws NotAliveException, TException; - public ClusterSummary getClusterInfo() throws org.apache.thrift.TException; + public ClusterSummary getClusterInfo() throws TException; - public SupervisorWorkers getSupervisorWorkers(String host) throws NotAliveException, org.apache.thrift.TException; + public SupervisorWorkers getSupervisorWorkers(String host) throws NotAliveException, TException; - public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift.TException; + public TopologyInfo getTopologyInfo(String id) throws NotAliveException, TException; - public TopologyInfo getTopologyInfoByName(String topologyName) throws NotAliveException, org.apache.thrift.TException; + public TopologyInfo getTopologyInfoByName(String topologyName) throws NotAliveException, TException; - public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift.TException; + public StormTopology getTopology(String id) throws NotAliveException, TException; - public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift.TException; + public StormTopology getUserTopology(String id) throws NotAliveException, TException; - public void workerUploadMetric(WorkerUploadMetrics uploadMetrics) throws org.apache.thrift.TException; + public void uploadTopologyMetrics(String topologyId, TopologyMetric topologyMetrics) throws TException; - public TopologyMetric getTopologyMetric(String topologyName) throws org.apache.thrift.TException; + public Map<String,Long> registerMetrics(String topologyId, Set<String> metrics) throws TException; - public NettyMetric getNettyMetric(String topologyName, int pos) throws org.apache.thrift.TException; + public TopologyMetric getTopologyMetrics(String topologyId) throws TException; - public NettyMetric getServerNettyMetric(String topologyName, String serverName) throws org.apache.thrift.TException; + public List<MetricInfo> getMetrics(String topologyId, int type) throws TException; - public String getVersion() throws org.apache.thrift.TException; + public MetricInfo getNettyMetrics(String topologyId) throws TException; - public void updateConf(String name, String conf) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException; + public MetricInfo getNettyMetricsByHost(String topologyId, String host) throws TException; + + public MetricInfo getPagingNettyMetrics(String topologyId, String host, int page) throws TException; + + public int getNettyMetricSizeByHost(String topologyId, String host) throws TException; + + public MetricInfo getTaskMetrics(String topologyId, String component) throws TException; + + public List<MetricInfo> getTaskAndStreamMetrics(String topologyId, int taskId) throws TException; + + public List<MetricInfo> getSummarizedTopologyMetrics(String topologyId) throws TException; + + public String getVersion() throws TException; + + public void updateTopology(String name, String uploadedLocation, String updateConf) throws NotAliveException, InvalidTopologyException, TException; + + public void updateTaskHeartbeat(TopologyTaskHbInfo taskHbs) throws TException; } public interface AsyncIface { - public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, AsyncMethodCallback resultHandler) throws TException; + + public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, AsyncMethodCallback resultHandler) throws TException; + + public void killTopology(String name, AsyncMethodCallback resultHandler) throws TException; + + public void killTopologyWithOpts(String name, KillOptions options, AsyncMethodCallback resultHandler) throws TException; + + public void activate(String name, AsyncMethodCallback resultHandler) throws TException; + + public void deactivate(String name, AsyncMethodCallback resultHandler) throws TException; + + public void rebalance(String name, RebalanceOptions options, AsyncMethodCallback resultHandler) throws TException; + + public void metricMonitor(String name, MonitorOptions options, AsyncMethodCallback resultHandler) throws TException; + + public void restart(String name, String jsonConf, AsyncMethodCallback resultHandler) throws TException; - public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void beginLibUpload(String libName, AsyncMethodCallback resultHandler) throws TException; - public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void beginFileUpload(AsyncMethodCallback resultHandler) throws TException; - public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void uploadChunk(String location, ByteBuffer chunk, AsyncMethodCallback resultHandler) throws TException; - public void activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void finishFileUpload(String location, AsyncMethodCallback resultHandler) throws TException; - public void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void beginFileDownload(String file, AsyncMethodCallback resultHandler) throws TException; - public void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void downloadChunk(String id, AsyncMethodCallback resultHandler) throws TException; - public void metricMonitor(String name, MonitorOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void finishFileDownload(String id, AsyncMethodCallback resultHandler) throws TException; - public void restart(String name, String jsonConf, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getNimbusConf(AsyncMethodCallback resultHandler) throws TException; - public void beginLibUpload(String libName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTopologyConf(String id, AsyncMethodCallback resultHandler) throws TException; - public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTopologyId(String topologyName, AsyncMethodCallback resultHandler) throws TException; - public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getClusterInfo(AsyncMethodCallback resultHandler) throws TException; - public void finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getSupervisorWorkers(String host, AsyncMethodCallback resultHandler) throws TException; - public void beginFileDownload(String file, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTopologyInfo(String id, AsyncMethodCallback resultHandler) throws TException; - public void downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTopologyInfoByName(String topologyName, AsyncMethodCallback resultHandler) throws TException; - public void finishFileDownload(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTopology(String id, AsyncMethodCallback resultHandler) throws TException; - public void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getUserTopology(String id, AsyncMethodCallback resultHandler) throws TException; - public void getTopologyConf(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void uploadTopologyMetrics(String topologyId, TopologyMetric topologyMetrics, AsyncMethodCallback resultHandler) throws TException; - public void getTopologyId(String topologyName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void registerMetrics(String topologyId, Set<String> metrics, AsyncMethodCallback resultHandler) throws TException; - public void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTopologyMetrics(String topologyId, AsyncMethodCallback resultHandler) throws TException; - public void getSupervisorWorkers(String host, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getMetrics(String topologyId, int type, AsyncMethodCallback resultHandler) throws TException; - public void getTopologyInfo(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getNettyMetrics(String topologyId, AsyncMethodCallback resultHandler) throws TException; - public void getTopologyInfoByName(String topologyName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getNettyMetricsByHost(String topologyId, String host, AsyncMethodCallback resultHandler) throws TException; - public void getTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getPagingNettyMetrics(String topologyId, String host, int page, AsyncMethodCallback resultHandler) throws TException; - public void getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getNettyMetricSizeByHost(String topologyId, String host, AsyncMethodCallback resultHandler) throws TException; - public void workerUploadMetric(WorkerUploadMetrics uploadMetrics, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTaskMetrics(String topologyId, String component, AsyncMethodCallback resultHandler) throws TException; - public void getTopologyMetric(String topologyName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTaskAndStreamMetrics(String topologyId, int taskId, AsyncMethodCallback resultHandler) throws TException; - public void getNettyMetric(String topologyName, int pos, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getSummarizedTopologyMetrics(String topologyId, AsyncMethodCallback resultHandler) throws TException; - public void getServerNettyMetric(String topologyName, String serverName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getVersion(AsyncMethodCallback resultHandler) throws TException; - public void getVersion(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void updateTopology(String name, String uploadedLocation, String updateConf, AsyncMethodCallback resultHandler) throws TException; - public void updateConf(String name, String conf, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void updateTaskHeartbeat(TopologyTaskHbInfo taskHbs, AsyncMethodCallback resultHandler) throws TException; } @@ -189,13 +221,13 @@ public class Nimbus { super(iprot, oprot); } - public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException + public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException { send_submitTopology(name, uploadedJarLocation, jsonConf, topology); recv_submitTopology(); } - public void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.thrift.TException + public void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws TException { submitTopology_args args = new submitTopology_args(); args.set_name(name); @@ -205,7 +237,7 @@ public class Nimbus { sendBase("submitTopology", args); } - public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException + public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException { submitTopology_result result = new submitTopology_result(); receiveBase(result, "submitTopology"); @@ -221,13 +253,13 @@ public class Nimbus { return; } - public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException + public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, 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.thrift.TException + public void send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws TException { submitTopologyWithOpts_args args = new submitTopologyWithOpts_args(); args.set_name(name); @@ -238,7 +270,7 @@ public class Nimbus { sendBase("submitTopologyWithOpts", args); } - public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException + public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException { submitTopologyWithOpts_result result = new submitTopologyWithOpts_result(); receiveBase(result, "submitTopologyWithOpts"); @@ -254,20 +286,20 @@ public class Nimbus { return; } - public void killTopology(String name) throws NotAliveException, org.apache.thrift.TException + public void killTopology(String name) throws NotAliveException, TException { send_killTopology(name); recv_killTopology(); } - public void send_killTopology(String name) throws org.apache.thrift.TException + public void send_killTopology(String name) throws TException { killTopology_args args = new killTopology_args(); args.set_name(name); sendBase("killTopology", args); } - public void recv_killTopology() throws NotAliveException, org.apache.thrift.TException + public void recv_killTopology() throws NotAliveException, TException { killTopology_result result = new killTopology_result(); receiveBase(result, "killTopology"); @@ -277,13 +309,13 @@ public class Nimbus { return; } - public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift.TException + public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, TException { send_killTopologyWithOpts(name, options); recv_killTopologyWithOpts(); } - public void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.thrift.TException + public void send_killTopologyWithOpts(String name, KillOptions options) throws TException { killTopologyWithOpts_args args = new killTopologyWithOpts_args(); args.set_name(name); @@ -291,7 +323,7 @@ public class Nimbus { sendBase("killTopologyWithOpts", args); } - public void recv_killTopologyWithOpts() throws NotAliveException, org.apache.thrift.TException + public void recv_killTopologyWithOpts() throws NotAliveException, TException { killTopologyWithOpts_result result = new killTopologyWithOpts_result(); receiveBase(result, "killTopologyWithOpts"); @@ -301,20 +333,20 @@ public class Nimbus { return; } - public void activate(String name) throws NotAliveException, org.apache.thrift.TException + public void activate(String name) throws NotAliveException, TException { send_activate(name); recv_activate(); } - public void send_activate(String name) throws org.apache.thrift.TException + public void send_activate(String name) throws TException { activate_args args = new activate_args(); args.set_name(name); sendBase("activate", args); } - public void recv_activate() throws NotAliveException, org.apache.thrift.TException + public void recv_activate() throws NotAliveException, TException { activate_result result = new activate_result(); receiveBase(result, "activate"); @@ -324,20 +356,20 @@ public class Nimbus { return; } - public void deactivate(String name) throws NotAliveException, org.apache.thrift.TException + public void deactivate(String name) throws NotAliveException, TException { send_deactivate(name); recv_deactivate(); } - public void send_deactivate(String name) throws org.apache.thrift.TException + public void send_deactivate(String name) throws TException { deactivate_args args = new deactivate_args(); args.set_name(name); sendBase("deactivate", args); } - public void recv_deactivate() throws NotAliveException, org.apache.thrift.TException + public void recv_deactivate() throws NotAliveException, TException { deactivate_result result = new deactivate_result(); receiveBase(result, "deactivate"); @@ -347,13 +379,13 @@ public class Nimbus { return; } - public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException + public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, TException { send_rebalance(name, options); recv_rebalance(); } - public void send_rebalance(String name, RebalanceOptions options) throws org.apache.thrift.TException + public void send_rebalance(String name, RebalanceOptions options) throws TException { rebalance_args args = new rebalance_args(); args.set_name(name); @@ -361,7 +393,7 @@ public class Nimbus { sendBase("rebalance", args); } - public void recv_rebalance() throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException + public void recv_rebalance() throws NotAliveException, InvalidTopologyException, TException { rebalance_result result = new rebalance_result(); receiveBase(result, "rebalance"); @@ -374,13 +406,13 @@ public class Nimbus { return; } - public void metricMonitor(String name, MonitorOptions options) throws NotAliveException, org.apache.thrift.TException + public void metricMonitor(String name, MonitorOptions options) throws NotAliveException, TException { send_metricMonitor(name, options); recv_metricMonitor(); } - public void send_metricMonitor(String name, MonitorOptions options) throws org.apache.thrift.TException + public void send_metricMonitor(String name, MonitorOptions options) throws TException { metricMonitor_args args = new metricMonitor_args(); args.set_name(name); @@ -388,7 +420,7 @@ public class Nimbus { sendBase("metricMonitor", args); } - public void recv_metricMonitor() throws NotAliveException, org.apache.thrift.TException + public void recv_metricMonitor() throws NotAliveException, TException { metricMonitor_result result = new metricMonitor_result(); receiveBase(result, "metricMonitor"); @@ -398,13 +430,13 @@ public class Nimbus { return; } - public void restart(String name, String jsonConf) throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException + public void restart(String name, String jsonConf) throws NotAliveException, InvalidTopologyException, TopologyAssignException, TException { send_restart(name, jsonConf); recv_restart(); } - public void send_restart(String name, String jsonConf) throws org.apache.thrift.TException + public void send_restart(String name, String jsonConf) throws TException { restart_args args = new restart_args(); args.set_name(name); @@ -412,7 +444,7 @@ public class Nimbus { sendBase("restart", args); } - public void recv_restart() throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException + public void recv_restart() throws NotAliveException, InvalidTopologyException, TopologyAssignException, TException { restart_result result = new restart_result(); receiveBase(result, "restart"); @@ -428,39 +460,39 @@ public class Nimbus { return; } - public void beginLibUpload(String libName) throws org.apache.thrift.TException + public void beginLibUpload(String libName) throws TException { send_beginLibUpload(libName); recv_beginLibUpload(); } - public void send_beginLibUpload(String libName) throws org.apache.thrift.TException + public void send_beginLibUpload(String libName) throws TException { beginLibUpload_args args = new beginLibUpload_args(); args.set_libName(libName); sendBase("beginLibUpload", args); } - public void recv_beginLibUpload() throws org.apache.thrift.TException + public void recv_beginLibUpload() throws TException { beginLibUpload_result result = new beginLibUpload_result(); receiveBase(result, "beginLibUpload"); return; } - public String beginFileUpload() throws org.apache.thrift.TException + public String beginFileUpload() throws TException { send_beginFileUpload(); return recv_beginFileUpload(); } - public void send_beginFileUpload() throws org.apache.thrift.TException + public void send_beginFileUpload() throws TException { beginFileUpload_args args = new beginFileUpload_args(); sendBase("beginFileUpload", args); } - public String recv_beginFileUpload() throws org.apache.thrift.TException + public String recv_beginFileUpload() throws TException { beginFileUpload_result result = new beginFileUpload_result(); receiveBase(result, "beginFileUpload"); @@ -470,13 +502,13 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result"); } - public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException + public void uploadChunk(String location, ByteBuffer chunk) throws TException { send_uploadChunk(location, chunk); recv_uploadChunk(); } - public void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException + public void send_uploadChunk(String location, ByteBuffer chunk) throws TException { uploadChunk_args args = new uploadChunk_args(); args.set_location(location); @@ -484,47 +516,47 @@ public class Nimbus { sendBase("uploadChunk", args); } - public void recv_uploadChunk() throws org.apache.thrift.TException + public void recv_uploadChunk() throws TException { uploadChunk_result result = new uploadChunk_result(); receiveBase(result, "uploadChunk"); return; } - public void finishFileUpload(String location) throws org.apache.thrift.TException + public void finishFileUpload(String location) throws TException { send_finishFileUpload(location); recv_finishFileUpload(); } - public void send_finishFileUpload(String location) throws org.apache.thrift.TException + public void send_finishFileUpload(String location) throws TException { finishFileUpload_args args = new finishFileUpload_args(); args.set_location(location); sendBase("finishFileUpload", args); } - public void recv_finishFileUpload() throws org.apache.thrift.TException + public void recv_finishFileUpload() throws TException { finishFileUpload_result result = new finishFileUpload_result(); receiveBase(result, "finishFileUpload"); return; } - public String beginFileDownload(String file) throws org.apache.thrift.TException + public String beginFileDownload(String file) throws TException { send_beginFileDownload(file); return recv_beginFileDownload(); } - public void send_beginFileDownload(String file) throws org.apache.thrift.TException + public void send_beginFileDownload(String file) throws TException { beginFileDownload_args args = new beginFileDownload_args(); args.set_file(file); sendBase("beginFileDownload", args); } - public String recv_beginFileDownload() throws org.apache.thrift.TException + public String recv_beginFileDownload() throws TException { beginFileDownload_result result = new beginFileDownload_result(); receiveBase(result, "beginFileDownload"); @@ -534,20 +566,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result"); } - public ByteBuffer downloadChunk(String id) throws org.apache.thrift.TException + public ByteBuffer downloadChunk(String id) throws TException { send_downloadChunk(id); return recv_downloadChunk(); } - public void send_downloadChunk(String id) throws org.apache.thrift.TException + public void send_downloadChunk(String id) throws TException { downloadChunk_args args = new downloadChunk_args(); args.set_id(id); sendBase("downloadChunk", args); } - public ByteBuffer recv_downloadChunk() throws org.apache.thrift.TException + public ByteBuffer recv_downloadChunk() throws TException { downloadChunk_result result = new downloadChunk_result(); receiveBase(result, "downloadChunk"); @@ -557,39 +589,39 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result"); } - public void finishFileDownload(String id) throws org.apache.thrift.TException + public void finishFileDownload(String id) throws TException { send_finishFileDownload(id); recv_finishFileDownload(); } - public void send_finishFileDownload(String id) throws org.apache.thrift.TException + public void send_finishFileDownload(String id) throws TException { finishFileDownload_args args = new finishFileDownload_args(); args.set_id(id); sendBase("finishFileDownload", args); } - public void recv_finishFileDownload() throws org.apache.thrift.TException + public void recv_finishFileDownload() throws TException { finishFileDownload_result result = new finishFileDownload_result(); receiveBase(result, "finishFileDownload"); return; } - public String getNimbusConf() throws org.apache.thrift.TException + public String getNimbusConf() throws TException { send_getNimbusConf(); return recv_getNimbusConf(); } - public void send_getNimbusConf() throws org.apache.thrift.TException + public void send_getNimbusConf() throws TException { getNimbusConf_args args = new getNimbusConf_args(); sendBase("getNimbusConf", args); } - public String recv_getNimbusConf() throws org.apache.thrift.TException + public String recv_getNimbusConf() throws TException { getNimbusConf_result result = new getNimbusConf_result(); receiveBase(result, "getNimbusConf"); @@ -599,20 +631,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result"); } - public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift.TException + public String getTopologyConf(String id) throws NotAliveException, TException { send_getTopologyConf(id); return recv_getTopologyConf(); } - public void send_getTopologyConf(String id) throws org.apache.thrift.TException + public void send_getTopologyConf(String id) throws TException { getTopologyConf_args args = new getTopologyConf_args(); args.set_id(id); sendBase("getTopologyConf", args); } - public String recv_getTopologyConf() throws NotAliveException, org.apache.thrift.TException + public String recv_getTopologyConf() throws NotAliveException, TException { getTopologyConf_result result = new getTopologyConf_result(); receiveBase(result, "getTopologyConf"); @@ -625,20 +657,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyConf failed: unknown result"); } - public String getTopologyId(String topologyName) throws NotAliveException, org.apache.thrift.TException + public String getTopologyId(String topologyName) throws NotAliveException, TException { send_getTopologyId(topologyName); return recv_getTopologyId(); } - public void send_getTopologyId(String topologyName) throws org.apache.thrift.TException + public void send_getTopologyId(String topologyName) throws TException { getTopologyId_args args = new getTopologyId_args(); args.set_topologyName(topologyName); sendBase("getTopologyId", args); } - public String recv_getTopologyId() throws NotAliveException, org.apache.thrift.TException + public String recv_getTopologyId() throws NotAliveException, TException { getTopologyId_result result = new getTopologyId_result(); receiveBase(result, "getTopologyId"); @@ -651,19 +683,19 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyId failed: unknown result"); } - public ClusterSummary getClusterInfo() throws org.apache.thrift.TException + public ClusterSummary getClusterInfo() throws TException { send_getClusterInfo(); return recv_getClusterInfo(); } - public void send_getClusterInfo() throws org.apache.thrift.TException + public void send_getClusterInfo() throws TException { getClusterInfo_args args = new getClusterInfo_args(); sendBase("getClusterInfo", args); } - public ClusterSummary recv_getClusterInfo() throws org.apache.thrift.TException + public ClusterSummary recv_getClusterInfo() throws TException { getClusterInfo_result result = new getClusterInfo_result(); receiveBase(result, "getClusterInfo"); @@ -673,20 +705,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result"); } - public SupervisorWorkers getSupervisorWorkers(String host) throws NotAliveException, org.apache.thrift.TException + public SupervisorWorkers getSupervisorWorkers(String host) throws NotAliveException, TException { send_getSupervisorWorkers(host); return recv_getSupervisorWorkers(); } - public void send_getSupervisorWorkers(String host) throws org.apache.thrift.TException + public void send_getSupervisorWorkers(String host) throws TException { getSupervisorWorkers_args args = new getSupervisorWorkers_args(); args.set_host(host); sendBase("getSupervisorWorkers", args); } - public SupervisorWorkers recv_getSupervisorWorkers() throws NotAliveException, org.apache.thrift.TException + public SupervisorWorkers recv_getSupervisorWorkers() throws NotAliveException, TException { getSupervisorWorkers_result result = new getSupervisorWorkers_result(); receiveBase(result, "getSupervisorWorkers"); @@ -699,20 +731,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSupervisorWorkers failed: unknown result"); } - public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift.TException + public TopologyInfo getTopologyInfo(String id) throws NotAliveException, TException { send_getTopologyInfo(id); return recv_getTopologyInfo(); } - public void send_getTopologyInfo(String id) throws org.apache.thrift.TException + public void send_getTopologyInfo(String id) throws TException { getTopologyInfo_args args = new getTopologyInfo_args(); args.set_id(id); sendBase("getTopologyInfo", args); } - public TopologyInfo recv_getTopologyInfo() throws NotAliveException, org.apache.thrift.TException + public TopologyInfo recv_getTopologyInfo() throws NotAliveException, TException { getTopologyInfo_result result = new getTopologyInfo_result(); receiveBase(result, "getTopologyInfo"); @@ -725,20 +757,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result"); } - public TopologyInfo getTopologyInfoByName(String topologyName) throws NotAliveException, org.apache.thrift.TException + public TopologyInfo getTopologyInfoByName(String topologyName) throws NotAliveException, TException { send_getTopologyInfoByName(topologyName); return recv_getTopologyInfoByName(); } - public void send_getTopologyInfoByName(String topologyName) throws org.apache.thrift.TException + public void send_getTopologyInfoByName(String topologyName) throws TException { getTopologyInfoByName_args args = new getTopologyInfoByName_args(); args.set_topologyName(topologyName); sendBase("getTopologyInfoByName", args); } - public TopologyInfo recv_getTopologyInfoByName() throws NotAliveException, org.apache.thrift.TException + public TopologyInfo recv_getTopologyInfoByName() throws NotAliveException, TException { getTopologyInfoByName_result result = new getTopologyInfoByName_result(); receiveBase(result, "getTopologyInfoByName"); @@ -751,20 +783,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfoByName failed: unknown result"); } - public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift.TException + public StormTopology getTopology(String id) throws NotAliveException, TException { send_getTopology(id); return recv_getTopology(); } - public void send_getTopology(String id) throws org.apache.thrift.TException + public void send_getTopology(String id) throws TException { getTopology_args args = new getTopology_args(); args.set_id(id); sendBase("getTopology", args); } - public StormTopology recv_getTopology() throws NotAliveException, org.apache.thrift.TException + public StormTopology recv_getTopology() throws NotAliveException, TException { getTopology_result result = new getTopology_result(); receiveBase(result, "getTopology"); @@ -777,20 +809,20 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopology failed: unknown result"); } - public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift.TException + public StormTopology getUserTopology(String id) throws NotAliveException, TException { send_getUserTopology(id); return recv_getUserTopology(); } - public void send_getUserTopology(String id) throws org.apache.thrift.TException + public void send_getUserTopology(String id) throws TException { getUserTopology_args args = new getUserTopology_args(); args.set_id(id); sendBase("getUserTopology", args); } - public StormTopology recv_getUserTopology() throws NotAliveException, org.apache.thrift.TException + public StormTopology recv_getUserTopology() throws NotAliveException, TException { getUserTopology_result result = new getUserTopology_result(); receiveBase(result, "getUserTopology"); @@ -803,110 +835,278 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getUserTopology failed: unknown result"); } - public void workerUploadMetric(WorkerUploadMetrics uploadMetrics) throws org.apache.thrift.TException + public void uploadTopologyMetrics(String topologyId, TopologyMetric topologyMetrics) throws TException { - send_workerUploadMetric(uploadMetrics); - recv_workerUploadMetric(); + send_uploadTopologyMetrics(topologyId, topologyMetrics); + recv_uploadTopologyMetrics(); } - public void send_workerUploadMetric(WorkerUploadMetrics uploadMetrics) throws org.apache.thrift.TException + public void send_uploadTopologyMetrics(String topologyId, TopologyMetric topologyMetrics) throws TException { - workerUploadMetric_args args = new workerUploadMetric_args(); - args.set_uploadMetrics(uploadMetrics); - sendBase("workerUploadMetric", args); + uploadTopologyMetrics_args args = new uploadTopologyMetrics_args(); + args.set_topologyId(topologyId); + args.set_topologyMetrics(topologyMetrics); + sendBase("uploadTopologyMetrics", args); } - public void recv_workerUploadMetric() throws org.apache.thrift.TException + public void recv_uploadTopologyMetrics() throws TException { - workerUploadMetric_result result = new workerUploadMetric_result(); - receiveBase(result, "workerUploadMetric"); + uploadTopologyMetrics_result result = new uploadTopologyMetrics_result(); + receiveBase(result, "uploadTopologyMetrics"); return; } - public TopologyMetric getTopologyMetric(String topologyName) throws org.apache.thrift.TException + public Map<String,Long> registerMetrics(String topologyId, Set<String> metrics) throws TException { - send_getTopologyMetric(topologyName); - return recv_getTopologyMetric(); + send_registerMetrics(topologyId, metrics); + return recv_registerMetrics(); } - public void send_getTopologyMetric(String topologyName) throws org.apache.thrift.TException + public void send_registerMetrics(String topologyId, Set<String> metrics) throws TException { - getTopologyMetric_args args = new getTopologyMetric_args(); - args.set_topologyName(topologyName); - sendBase("getTopologyMetric", args); + registerMetrics_args args = new registerMetrics_args(); + args.set_topologyId(topologyId); + args.set_metrics(metrics); + sendBase("registerMetrics", args); } - public TopologyMetric recv_getTopologyMetric() throws org.apache.thrift.TException + public Map<String,Long> recv_registerMetrics() throws TException { - getTopologyMetric_result result = new getTopologyMetric_result(); - receiveBase(result, "getTopologyMetric"); + registerMetrics_result result = new registerMetrics_result(); + receiveBase(result, "registerMetrics"); if (result.is_set_success()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyMetric failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "registerMetrics failed: unknown result"); } - public NettyMetric getNettyMetric(String topologyName, int pos) throws org.apache.thrift.TException + public TopologyMetric getTopologyMetrics(String topologyId) throws TException { - send_getNettyMetric(topologyName, pos); - return recv_getNettyMetric(); + send_getTopologyMetrics(topologyId); + return recv_getTopologyMetrics(); } - public void send_getNettyMetric(String topologyName, int pos) throws org.apache.thrift.TException + public void send_getTopologyMetrics(String topologyId) throws TException { - getNettyMetric_args args = new getNettyMetric_args(); - args.set_topologyName(topologyName); - args.set_pos(pos); - sendBase("getNettyMetric", args); + getTopologyMetrics_args args = new getTopologyMetrics_args(); + args.set_topologyId(topologyId); + sendBase("getTopologyMetrics", args); } - public NettyMetric recv_getNettyMetric() throws org.apache.thrift.TException + public TopologyMetric recv_getTopologyMetrics() throws TException { - getNettyMetric_result result = new getNettyMetric_result(); - receiveBase(result, "getNettyMetric"); + getTopologyMetrics_result result = new getTopologyMetrics_result(); + receiveBase(result, "getTopologyMetrics"); if (result.is_set_success()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNettyMetric failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyMetrics failed: unknown result"); } - public NettyMetric getServerNettyMetric(String topologyName, String serverName) throws org.apache.thrift.TException + public List<MetricInfo> getMetrics(String topologyId, int type) throws TException { - send_getServerNettyMetric(topologyName, serverName); - return recv_getServerNettyMetric(); + send_getMetrics(topologyId, type); + return recv_getMetrics(); } - public void send_getServerNettyMetric(String topologyName, String serverName) throws org.apache.thrift.TException + public void send_getMetrics(String topologyId, int type) throws TException { - getServerNettyMetric_args args = new getServerNettyMetric_args(); - args.set_topologyName(topologyName); - args.set_serverName(serverName); - sendBase("getServerNettyMetric", args); + getMetrics_args args = new getMetrics_args(); + args.set_topologyId(topologyId); + args.set_type(type); + sendBase("getMetrics", args); + } + + public List<MetricInfo> recv_getMetrics() throws TException + { + getMetrics_result result = new getMetrics_result(); + receiveBase(result, "getMetrics"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getMetrics failed: unknown result"); + } + + public MetricInfo getNettyMetrics(String topologyId) throws TException + { + send_getNettyMetrics(topologyId); + return recv_getNettyMetrics(); + } + + public void send_getNettyMetrics(String topologyId) throws TException + { + getNettyMetrics_args args = new getNettyMetrics_args(); + args.set_topologyId(topologyId); + sendBase("getNettyMetrics", args); + } + + public MetricInfo recv_getNettyMetrics() throws TException + { + getNettyMetrics_result result = new getNettyMetrics_result(); + receiveBase(result, "getNettyMetrics"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNettyMetrics failed: unknown result"); + } + + public MetricInfo getNettyMetricsByHost(String topologyId, String host) throws TException + { + send_getNettyMetricsByHost(topologyId, host); + return recv_getNettyMetricsByHost(); + } + + public void send_getNettyMetricsByHost(String topologyId, String host) throws TException + { + getNettyMetricsByHost_args args = new getNettyMetricsByHost_args(); + args.set_topologyId(topologyId); + args.set_host(host); + sendBase("getNettyMetricsByHost", args); + } + + public MetricInfo recv_getNettyMetricsByHost() throws TException + { + getNettyMetricsByHost_result result = new getNettyMetricsByHost_result(); + receiveBase(result, "getNettyMetricsByHost"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNettyMetricsByHost failed: unknown result"); + } + + public MetricInfo getPagingNettyMetrics(String topologyId, String host, int page) throws TException + { + send_getPagingNettyMetrics(topologyId, host, page); + return recv_getPagingNettyMetrics(); + } + + public void send_getPagingNettyMetrics(String topologyId, String host, int page) throws TException + { + getPagingNettyMetrics_args args = new getPagingNettyMetrics_args(); + args.set_topologyId(topologyId); + args.set_host(host); + args.set_page(page); + sendBase("getPagingNettyMetrics", args); + } + + public MetricInfo recv_getPagingNettyMetrics() throws TException + { + getPagingNettyMetrics_result result = new getPagingNettyMetrics_result(); + receiveBase(result, "getPagingNettyMetrics"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPagingNettyMetrics failed: unknown result"); + } + + public int getNettyMetricSizeByHost(String topologyId, String host) throws TException + { + send_getNettyMetricSizeByHost(topologyId, host); + return recv_getNettyMetricSizeByHost(); + } + + public void send_getNettyMetricSizeByHost(String topologyId, String host) throws TException + { + getNettyMetricSizeByHost_args args = new getNettyMetricSizeByHost_args(); + args.set_topologyId(topologyId); + args.set_host(host); + sendBase("getNettyMetricSizeByHost", args); + } + + public int recv_getNettyMetricSizeByHost() throws TException + { + getNettyMetricSizeByHost_result result = new getNettyMetricSizeByHost_result(); + receiveBase(result, "getNettyMetricSizeByHost"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNettyMetricSizeByHost failed: unknown result"); + } + + public MetricInfo getTaskMetrics(String topologyId, String component) throws TException + { + send_getTaskMetrics(topologyId, component); + return recv_getTaskMetrics(); + } + + public void send_getTaskMetrics(String topologyId, String component) throws TException + { + getTaskMetrics_args args = new getTaskMetrics_args(); + args.set_topologyId(topologyId); + args.set_component(component); + sendBase("getTaskMetrics", args); + } + + public MetricInfo recv_getTaskMetrics() throws TException + { + getTaskMetrics_result result = new getTaskMetrics_result(); + receiveBase(result, "getTaskMetrics"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTaskMetrics failed: unknown result"); + } + + public List<MetricInfo> getTaskAndStreamMetrics(String topologyId, int taskId) throws TException + { + send_getTaskAndStreamMetrics(topologyId, taskId); + return recv_getTaskAndStreamMetrics(); + } + + public void send_getTaskAndStreamMetrics(String topologyId, int taskId) throws TException + { + getTaskAndStreamMetrics_args args = new getTaskAndStreamMetrics_args(); + args.set_topologyId(topologyId); + args.set_taskId(taskId); + sendBase("getTaskAndStreamMetrics", args); + } + + public List<MetricInfo> recv_getTaskAndStreamMetrics() throws TException + { + getTaskAndStreamMetrics_result result = new getTaskAndStreamMetrics_result(); + receiveBase(result, "getTaskAndStreamMetrics"); + if (result.is_set_success()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTaskAndStreamMetrics failed: unknown result"); + } + + public List<MetricInfo> getSummarizedTopologyMetrics(String topologyId) throws TException + { + send_getSummarizedTopologyMetrics(topologyId); + return recv_getSummarizedTopologyMetrics(); + } + + public void send_getSummarizedTopologyMetrics(String topologyId) throws TException + { + getSummarizedTopologyMetrics_args args = new getSummarizedTopologyMetrics_args(); + args.set_topologyId(topologyId); + sendBase("getSummarizedTopologyMetrics", args); } - public NettyMetric recv_getServerNettyMetric() throws org.apache.thrift.TException + public List<MetricInfo> recv_getSummarizedTopologyMetrics() throws TException { - getServerNettyMetric_result result = new getServerNettyMetric_result(); - receiveBase(result, "getServerNettyMetric"); + getSummarizedTopologyMetrics_result result = new getSummarizedTopologyMetrics_result(); + receiveBase(result, "getSummarizedTopologyMetrics"); if (result.is_set_success()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getServerNettyMetric failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSummarizedTopologyMetrics failed: unknown result"); } - public String getVersion() throws org.apache.thrift.TException + public String getVersion() throws TException { send_getVersion(); return recv_getVersion(); } - public void send_getVersion() throws org.apache.thrift.TException + public void send_getVersion() throws TException { getVersion_args args = new getVersion_args(); sendBase("getVersion", args); } - public String recv_getVersion() throws org.apache.thrift.TException + public String recv_getVersion() throws TException { getVersion_result result = new getVersion_result(); receiveBase(result, "getVersion"); @@ -916,24 +1116,25 @@ public class Nimbus { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVersion failed: unknown result"); } - public void updateConf(String name, String conf) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException + public void updateTopology(String name, String uploadedLocation, String updateConf) throws NotAliveException, InvalidTopologyException, TException { - send_updateConf(name, conf); - recv_updateConf(); + send_updateTopology(name, uploadedLocation, updateConf); + recv_updateTopology(); } - public void send_updateConf(String name, String conf) throws org.apache.thrift.TException + public void send_updateTopology(String name, String uploadedLocation, String updateConf) throws TException { - updateConf_args args = new updateConf_args(); + updateTopology_args args = new updateTopology_args(); args.set_name(name); - args.set_conf(conf); - sendBase("updateConf", args); + args.set_uploadedLocation(uploadedLocation); + args.set_updateConf(updateConf); + sendBase("updateTopology", args); } - public void recv_updateConf() throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException + public void recv_updateTopology() throws NotAliveException, InvalidTopologyException, TException { - updateConf_result result = new updateConf_result(); - receiveBase(result, "updateConf"); + updateTopology_result result = new updateTopology_result(); + receiveBase(result, "updateTopology"); if (result.e != null) { throw result.e; } @@ -943,6 +1144,26 @@ public class Nimbus { return; } + public void updateTaskHeartbeat(TopologyTaskHbInfo taskHbs) throws TException + { + send_updateTaskHeartbeat(taskHbs); + recv_updateTaskHeartbeat(); + } + + public void send_updateTaskHeartbeat(TopologyTaskHbInfo taskHbs) throws TException + { + updateTaskHeartbeat_args args = new updateTaskHeartbeat_args(); + args.set_taskHbs(taskHbs); + sendBase("updateTaskHeartbeat", args); + } + + public void recv_updateTaskHeartbeat() throws TException + { + updateTaskHeartbeat_result result = new updateTaskHeartbeat_result(); + receiveBase(result, "updateTaskHeartbeat"); + return; + } + } public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { @@ -961,7 +1182,7 @@ public class Nimbus { super(protocolFactory, clientManager, transport); } - public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, AsyncMethodCallback resultHandler) throws TException { checkReady(); submitTopology_call method_call = new submitTopology_call(name, uploadedJarLocation, jsonConf, topology, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -973,7 +1194,7 @@ public class Nimbus { private String uploadedJarLocation; private String jsonConf; private StormTopology topology; - public submitTopology_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public submitTopology_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; this.uploadedJarLocation = uploadedJarLocation; @@ -981,7 +1202,7 @@ public class Nimbus { this.topology = topology; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("submitTopology", org.apache.thrift.protocol.TMessageType.CALL, 0)); submitTopology_args args = new submitTopology_args(); args.set_name(name); @@ -992,8 +1213,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1002,7 +1223,7 @@ public class Nimbus { } } - public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, AsyncMethodCallback resultHandler) throws TException { checkReady(); submitTopologyWithOpts_call method_call = new submitTopologyWithOpts_call(name, uploadedJarLocation, jsonConf, topology, options, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1015,7 +1236,7 @@ public class Nimbus { private String jsonConf; private StormTopology topology; private SubmitOptions options; - public submitTopologyWithOpts_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public submitTopologyWithOpts_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; this.uploadedJarLocation = uploadedJarLocation; @@ -1024,7 +1245,7 @@ public class Nimbus { this.options = options; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("submitTopologyWithOpts", org.apache.thrift.protocol.TMessageType.CALL, 0)); submitTopologyWithOpts_args args = new submitTopologyWithOpts_args(); args.set_name(name); @@ -1036,8 +1257,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws AlreadyAliveException, InvalidTopologyException, TopologyAssignException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1046,7 +1267,7 @@ public class Nimbus { } } - public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void killTopology(String name, AsyncMethodCallback resultHandler) throws TException { checkReady(); killTopology_call method_call = new killTopology_call(name, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1055,12 +1276,12 @@ public class Nimbus { public static class killTopology_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; - public killTopology_call(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public killTopology_call(String name, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("killTopology", org.apache.thrift.protocol.TMessageType.CALL, 0)); killTopology_args args = new killTopology_args(); args.set_name(name); @@ -1068,8 +1289,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1078,7 +1299,7 @@ public class Nimbus { } } - public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void killTopologyWithOpts(String name, KillOptions options, AsyncMethodCallback resultHandler) throws TException { checkReady(); killTopologyWithOpts_call method_call = new killTopologyWithOpts_call(name, options, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1088,13 +1309,13 @@ public class Nimbus { public static class killTopologyWithOpts_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; private KillOptions options; - public killTopologyWithOpts_call(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public killTopologyWithOpts_call(String name, KillOptions options, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; this.options = options; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("killTopologyWithOpts", org.apache.thrift.protocol.TMessageType.CALL, 0)); killTopologyWithOpts_args args = new killTopologyWithOpts_args(); args.set_name(name); @@ -1103,8 +1324,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1113,7 +1334,7 @@ public class Nimbus { } } - public void activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void activate(String name, AsyncMethodCallback resultHandler) throws TException { checkReady(); activate_call method_call = new activate_call(name, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1122,12 +1343,12 @@ public class Nimbus { public static class activate_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; - public activate_call(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public activate_call(String name, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("activate", org.apache.thrift.protocol.TMessageType.CALL, 0)); activate_args args = new activate_args(); args.set_name(name); @@ -1135,8 +1356,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1145,7 +1366,7 @@ public class Nimbus { } } - public void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void deactivate(String name, AsyncMethodCallback resultHandler) throws TException { checkReady(); deactivate_call method_call = new deactivate_call(name, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1154,12 +1375,12 @@ public class Nimbus { public static class deactivate_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; - public deactivate_call(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public deactivate_call(String name, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deactivate", org.apache.thrift.protocol.TMessageType.CALL, 0)); deactivate_args args = new deactivate_args(); args.set_name(name); @@ -1167,8 +1388,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1177,7 +1398,7 @@ public class Nimbus { } } - public void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void rebalance(String name, RebalanceOptions options, AsyncMethodCallback resultHandler) throws TException { checkReady(); rebalance_call method_call = new rebalance_call(name, options, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1187,13 +1408,13 @@ public class Nimbus { public static class rebalance_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; private RebalanceOptions options; - public rebalance_call(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public rebalance_call(String name, RebalanceOptions options, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; this.options = options; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("rebalance", org.apache.thrift.protocol.TMessageType.CALL, 0)); rebalance_args args = new rebalance_args(); args.set_name(name); @@ -1202,8 +1423,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, InvalidTopologyException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1212,7 +1433,7 @@ public class Nimbus { } } - public void metricMonitor(String name, MonitorOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void metricMonitor(String name, MonitorOptions options, AsyncMethodCallback resultHandler) throws TException { checkReady(); metricMonitor_call method_call = new metricMonitor_call(name, options, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1222,13 +1443,13 @@ public class Nimbus { public static class metricMonitor_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; private MonitorOptions options; - public metricMonitor_call(String name, MonitorOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public metricMonitor_call(String name, MonitorOptions options, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; this.options = options; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("metricMonitor", org.apache.thrift.protocol.TMessageType.CALL, 0)); metricMonitor_args args = new metricMonitor_args(); args.set_name(name); @@ -1237,8 +1458,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1247,7 +1468,7 @@ public class Nimbus { } } - public void restart(String name, String jsonConf, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void restart(String name, String jsonConf, AsyncMethodCallback resultHandler) throws TException { checkReady(); restart_call method_call = new restart_call(name, jsonConf, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1257,13 +1478,13 @@ public class Nimbus { public static class restart_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; private String jsonConf; - public restart_call(String name, String jsonConf, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public restart_call(String name, String jsonConf, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; this.jsonConf = jsonConf; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("restart", org.apache.thrift.protocol.TMessageType.CALL, 0)); restart_args args = new restart_args(); args.set_name(name); @@ -1272,8 +1493,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws NotAliveException, InvalidTopologyException, TopologyAssignException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws NotAliveException, InvalidTopologyException, TopologyAssignException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1282,7 +1503,7 @@ public class Nimbus { } } - public void beginLibUpload(String libName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void beginLibUpload(String libName, AsyncMethodCallback resultHandler) throws TException { checkReady(); beginLibUpload_call method_call = new beginLibUpload_call(libName, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1291,12 +1512,12 @@ public class Nimbus { public static class beginLibUpload_call extends org.apache.thrift.async.TAsyncMethodCall { private String libName; - public beginLibUpload_call(String libName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public beginLibUpload_call(String libName, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.libName = libName; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("beginLibUpload", org.apache.thrift.protocol.TMessageType.CALL, 0)); beginLibUpload_args args = new beginLibUpload_args(); args.set_libName(libName); @@ -1304,8 +1525,8 @@ public class Nimbus { prot.writeMessageEnd(); } - public void getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public void getResult() throws TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1314,7 +1535,7 @@ public class Nimbus { } } - public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void beginFileUpload(AsyncMethodCallback resultHandler) throws TException { checkReady(); beginFileUpload_call method_call = new beginFileUpload_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -1322,19 +1543,19 @@ public class Nimbus { } public static class beginFileUpload_call extends org.apache.thrift.async.TAsyncMethodCall { - public beginFileUpload_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public beginFileUpload_call(AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); } - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("beginFileUpload", org.apache.thrift.protocol.TMessageType.CALL, 0)); beginFileUpload_args args = new beginFileUpload_args(); args.write(prot); prot.writeMessageEnd(); } - public String getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public String getResult() throws TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -1343,7 +1564,7 @@ public class Nimbus { } } - public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void uploadChunk(String location, ByteBuffer chunk, AsyncMethodCallback resultHandler) throws TEx
<TRUNCATED>
