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/12/01 23:05:19 UTC
[41/51] [partial] storm git commit: Update JStorm to latest release
2.1.0
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>