You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/07/30 18:22:50 UTC
[2/6] storm git commit: STORM-2947: Remove deprecated field and
method from Thrift
http://git-wip-us.apache.org/repos/asf/storm/blob/1768062f/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
index de9a3b3..47bc7fc 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -101,8 +101,6 @@ public class Nimbus {
public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.storm.thrift.TException;
- public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.storm.thrift.TException;
-
public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.storm.thrift.TException;
public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException;
@@ -237,8 +235,6 @@ public class Nimbus {
public void finishFileUpload(java.lang.String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void beginFileDownload(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException;
-
public void downloadChunk(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException;
public void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException;
@@ -1093,32 +1089,6 @@ public class Nimbus {
return;
}
- public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.storm.thrift.TException
- {
- send_beginFileDownload(file);
- return recv_beginFileDownload();
- }
-
- public void send_beginFileDownload(java.lang.String file) throws org.apache.storm.thrift.TException
- {
- beginFileDownload_args args = new beginFileDownload_args();
- args.set_file(file);
- sendBase("beginFileDownload", args);
- }
-
- public java.lang.String recv_beginFileDownload() throws AuthorizationException, org.apache.storm.thrift.TException
- {
- beginFileDownload_result result = new beginFileDownload_result();
- receiveBase(result, "beginFileDownload");
- if (result.is_set_success()) {
- return result.success;
- }
- if (result.aze != null) {
- throw result.aze;
- }
- throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
- }
-
public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_downloadChunk(id);
@@ -2700,38 +2670,6 @@ public class Nimbus {
}
}
- public void beginFileDownload(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
- checkReady();
- beginFileDownload_call method_call = new beginFileDownload_call(file, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class beginFileDownload_call extends org.apache.storm.thrift.async.TAsyncMethodCall<java.lang.String> {
- private java.lang.String file;
- public beginFileDownload_call(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) throws org.apache.storm.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.file = file;
- }
-
- public void write_args(org.apache.storm.thrift.protocol.TProtocol prot) throws org.apache.storm.thrift.TException {
- prot.writeMessageBegin(new org.apache.storm.thrift.protocol.TMessage("beginFileDownload", org.apache.storm.thrift.protocol.TMessageType.CALL, 0));
- beginFileDownload_args args = new beginFileDownload_args();
- args.set_file(file);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public java.lang.String getResult() throws AuthorizationException, org.apache.storm.thrift.TException {
- if (getState() != org.apache.storm.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new java.lang.IllegalStateException("Method call not finished!");
- }
- org.apache.storm.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.storm.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.storm.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_beginFileDownload();
- }
- }
-
public void downloadChunk(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException {
checkReady();
downloadChunk_call method_call = new downloadChunk_call(id, resultHandler, this, ___protocolFactory, ___transport);
@@ -3430,7 +3368,6 @@ public class Nimbus {
processMap.put("beginFileUpload", new beginFileUpload());
processMap.put("uploadChunk", new uploadChunk());
processMap.put("finishFileUpload", new finishFileUpload());
- processMap.put("beginFileDownload", new beginFileDownload());
processMap.put("downloadChunk", new downloadChunk());
processMap.put("getNimbusConf", new getNimbusConf());
processMap.put("getClusterInfo", new getClusterInfo());
@@ -4346,35 +4283,6 @@ public class Nimbus {
}
}
- public static class beginFileDownload<I extends Iface> extends org.apache.storm.thrift.ProcessFunction<I, beginFileDownload_args> {
- public beginFileDownload() {
- super("beginFileDownload");
- }
-
- public beginFileDownload_args getEmptyArgsInstance() {
- return new beginFileDownload_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- @Override
- protected boolean handleRuntimeExceptions() {
- return false;
- }
-
- public beginFileDownload_result getResult(I iface, beginFileDownload_args args) throws org.apache.storm.thrift.TException {
- beginFileDownload_result result = new beginFileDownload_result();
- try {
- result.success = iface.beginFileDownload(args.file);
- } catch (AuthorizationException aze) {
- result.aze = aze;
- }
- return result;
- }
- }
-
public static class downloadChunk<I extends Iface> extends org.apache.storm.thrift.ProcessFunction<I, downloadChunk_args> {
public downloadChunk() {
super("downloadChunk");
@@ -5014,7 +4922,6 @@ public class Nimbus {
processMap.put("beginFileUpload", new beginFileUpload());
processMap.put("uploadChunk", new uploadChunk());
processMap.put("finishFileUpload", new finishFileUpload());
- processMap.put("beginFileDownload", new beginFileDownload());
processMap.put("downloadChunk", new downloadChunk());
processMap.put("getNimbusConf", new getNimbusConf());
processMap.put("getClusterInfo", new getClusterInfo());
@@ -7035,20 +6942,85 @@ public class Nimbus {
}
}
- public static class beginFileDownload<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, beginFileDownload_args, java.lang.String> {
- public beginFileDownload() {
- super("beginFileDownload");
+ public static class downloadChunk<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, downloadChunk_args, java.nio.ByteBuffer> {
+ public downloadChunk() {
+ super("downloadChunk");
+ }
+
+ public downloadChunk_args getEmptyArgsInstance() {
+ return new downloadChunk_args();
+ }
+
+ public org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer>() {
+ public void onComplete(java.nio.ByteBuffer o) {
+ downloadChunk_result result = new downloadChunk_result();
+ result.success = o;
+ try {
+ fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
+ } catch (org.apache.storm.thrift.transport.TTransportException e) {
+ _LOGGER.error("TTransportException writing to internal frame buffer", e);
+ fb.close();
+ } catch (java.lang.Exception e) {
+ _LOGGER.error("Exception writing to internal frame buffer", e);
+ onError(e);
+ }
+ }
+ public void onError(java.lang.Exception e) {
+ byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
+ org.apache.storm.thrift.TSerializable msg;
+ downloadChunk_result result = new downloadChunk_result();
+ if (e instanceof AuthorizationException) {
+ result.aze = (AuthorizationException) e;
+ result.set_aze_isSet(true);
+ msg = result;
+ } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
+ _LOGGER.error("TTransportException inside handler", e);
+ fb.close();
+ return;
+ } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
+ _LOGGER.error("TApplicationException inside handler", e);
+ msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.storm.thrift.TApplicationException)e;
+ } else {
+ _LOGGER.error("Exception inside handler", e);
+ msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+ msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ } catch (java.lang.Exception ex) {
+ _LOGGER.error("Exception writing to internal frame buffer", ex);
+ fb.close();
+ }
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, downloadChunk_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.downloadChunk(args.id,resultHandler);
+ }
+ }
+
+ public static class getNimbusConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getNimbusConf_args, java.lang.String> {
+ public getNimbusConf() {
+ super("getNimbusConf");
}
- public beginFileDownload_args getEmptyArgsInstance() {
- return new beginFileDownload_args();
+ public getNimbusConf_args getEmptyArgsInstance() {
+ return new getNimbusConf_args();
}
public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() {
public void onComplete(java.lang.String o) {
- beginFileDownload_result result = new beginFileDownload_result();
+ getNimbusConf_result result = new getNimbusConf_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7063,7 +7035,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- beginFileDownload_result result = new beginFileDownload_result();
+ getNimbusConf_result result = new getNimbusConf_result();
if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
@@ -7095,25 +7067,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, beginFileDownload_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
- iface.beginFileDownload(args.file,resultHandler);
+ public void start(I iface, getNimbusConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getNimbusConf(resultHandler);
}
}
- public static class downloadChunk<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, downloadChunk_args, java.nio.ByteBuffer> {
- public downloadChunk() {
- super("downloadChunk");
+ public static class getClusterInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getClusterInfo_args, ClusterSummary> {
+ public getClusterInfo() {
+ super("getClusterInfo");
}
- public downloadChunk_args getEmptyArgsInstance() {
- return new downloadChunk_args();
+ public getClusterInfo_args getEmptyArgsInstance() {
+ return new getClusterInfo_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer>() {
- public void onComplete(java.nio.ByteBuffer o) {
- downloadChunk_result result = new downloadChunk_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary>() {
+ public void onComplete(ClusterSummary o) {
+ getClusterInfo_result result = new getClusterInfo_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7128,7 +7100,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- downloadChunk_result result = new downloadChunk_result();
+ getClusterInfo_result result = new getClusterInfo_result();
if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
@@ -7160,25 +7132,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, downloadChunk_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException {
- iface.downloadChunk(args.id,resultHandler);
+ public void start(I iface, getClusterInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getClusterInfo(resultHandler);
}
}
- public static class getNimbusConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getNimbusConf_args, java.lang.String> {
- public getNimbusConf() {
- super("getNimbusConf");
+ public static class getLeader<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getLeader_args, NimbusSummary> {
+ public getLeader() {
+ super("getLeader");
}
- public getNimbusConf_args getEmptyArgsInstance() {
- return new getNimbusConf_args();
+ public getLeader_args getEmptyArgsInstance() {
+ return new getLeader_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() {
- public void onComplete(java.lang.String o) {
- getNimbusConf_result result = new getNimbusConf_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary>() {
+ public void onComplete(NimbusSummary o) {
+ getLeader_result result = new getLeader_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7193,7 +7165,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getNimbusConf_result result = new getNimbusConf_result();
+ getLeader_result result = new getLeader_result();
if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
@@ -7225,26 +7197,27 @@ public class Nimbus {
return false;
}
- public void start(I iface, getNimbusConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getNimbusConf(resultHandler);
+ public void start(I iface, getLeader_args args, org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getLeader(resultHandler);
}
}
- public static class getClusterInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getClusterInfo_args, ClusterSummary> {
- public getClusterInfo() {
- super("getClusterInfo");
+ public static class isTopologyNameAllowed<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, isTopologyNameAllowed_args, java.lang.Boolean> {
+ public isTopologyNameAllowed() {
+ super("isTopologyNameAllowed");
}
- public getClusterInfo_args getEmptyArgsInstance() {
- return new getClusterInfo_args();
+ public isTopologyNameAllowed_args getEmptyArgsInstance() {
+ return new isTopologyNameAllowed_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary>() {
- public void onComplete(ClusterSummary o) {
- getClusterInfo_result result = new getClusterInfo_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
+ public void onComplete(java.lang.Boolean o) {
+ isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
result.success = o;
+ result.set_success_isSet(true);
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
} catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -7258,7 +7231,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getClusterInfo_result result = new getClusterInfo_result();
+ isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
@@ -7290,25 +7263,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getClusterInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getClusterInfo(resultHandler);
+ public void start(I iface, isTopologyNameAllowed_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.isTopologyNameAllowed(args.name,resultHandler);
}
}
- public static class getLeader<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getLeader_args, NimbusSummary> {
- public getLeader() {
- super("getLeader");
+ public static class getTopologyInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfo_args, TopologyInfo> {
+ public getTopologyInfo() {
+ super("getTopologyInfo");
}
- public getLeader_args getEmptyArgsInstance() {
- return new getLeader_args();
+ public getTopologyInfo_args getEmptyArgsInstance() {
+ return new getTopologyInfo_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary>() {
- public void onComplete(NimbusSummary o) {
- getLeader_result result = new getLeader_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() {
+ public void onComplete(TopologyInfo o) {
+ getTopologyInfo_result result = new getTopologyInfo_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7323,8 +7296,150 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getLeader_result result = new getLeader_result();
- if (e instanceof AuthorizationException) {
+ getTopologyInfo_result result = new getTopologyInfo_result();
+ if (e instanceof NotAliveException) {
+ result.e = (NotAliveException) e;
+ result.set_e_isSet(true);
+ msg = result;
+ } else if (e instanceof AuthorizationException) {
+ result.aze = (AuthorizationException) e;
+ result.set_aze_isSet(true);
+ msg = result;
+ } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
+ _LOGGER.error("TTransportException inside handler", e);
+ fb.close();
+ return;
+ } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
+ _LOGGER.error("TApplicationException inside handler", e);
+ msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.storm.thrift.TApplicationException)e;
+ } else {
+ _LOGGER.error("Exception inside handler", e);
+ msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+ msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ } catch (java.lang.Exception ex) {
+ _LOGGER.error("Exception writing to internal frame buffer", ex);
+ fb.close();
+ }
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, getTopologyInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getTopologyInfo(args.id,resultHandler);
+ }
+ }
+
+ public static class getTopologyInfoWithOpts<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfoWithOpts_args, TopologyInfo> {
+ public getTopologyInfoWithOpts() {
+ super("getTopologyInfoWithOpts");
+ }
+
+ public getTopologyInfoWithOpts_args getEmptyArgsInstance() {
+ return new getTopologyInfoWithOpts_args();
+ }
+
+ public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() {
+ public void onComplete(TopologyInfo o) {
+ getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+ result.success = o;
+ try {
+ fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
+ } catch (org.apache.storm.thrift.transport.TTransportException e) {
+ _LOGGER.error("TTransportException writing to internal frame buffer", e);
+ fb.close();
+ } catch (java.lang.Exception e) {
+ _LOGGER.error("Exception writing to internal frame buffer", e);
+ onError(e);
+ }
+ }
+ public void onError(java.lang.Exception e) {
+ byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
+ org.apache.storm.thrift.TSerializable msg;
+ getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+ if (e instanceof NotAliveException) {
+ result.e = (NotAliveException) e;
+ result.set_e_isSet(true);
+ msg = result;
+ } else if (e instanceof AuthorizationException) {
+ result.aze = (AuthorizationException) e;
+ result.set_aze_isSet(true);
+ msg = result;
+ } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
+ _LOGGER.error("TTransportException inside handler", e);
+ fb.close();
+ return;
+ } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
+ _LOGGER.error("TApplicationException inside handler", e);
+ msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.storm.thrift.TApplicationException)e;
+ } else {
+ _LOGGER.error("Exception inside handler", e);
+ msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+ msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ } catch (java.lang.Exception ex) {
+ _LOGGER.error("Exception writing to internal frame buffer", ex);
+ fb.close();
+ }
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, getTopologyInfoWithOpts_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getTopologyInfoWithOpts(args.id, args.options,resultHandler);
+ }
+ }
+
+ public static class getTopologyPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyPageInfo_args, TopologyPageInfo> {
+ public getTopologyPageInfo() {
+ super("getTopologyPageInfo");
+ }
+
+ public getTopologyPageInfo_args getEmptyArgsInstance() {
+ return new getTopologyPageInfo_args();
+ }
+
+ public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo>() {
+ public void onComplete(TopologyPageInfo o) {
+ getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+ result.success = o;
+ try {
+ fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
+ } catch (org.apache.storm.thrift.transport.TTransportException e) {
+ _LOGGER.error("TTransportException writing to internal frame buffer", e);
+ fb.close();
+ } catch (java.lang.Exception e) {
+ _LOGGER.error("Exception writing to internal frame buffer", e);
+ onError(e);
+ }
+ }
+ public void onError(java.lang.Exception e) {
+ byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
+ org.apache.storm.thrift.TSerializable msg;
+ getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+ if (e instanceof NotAliveException) {
+ result.e = (NotAliveException) e;
+ result.set_e_isSet(true);
+ msg = result;
+ } else if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
msg = result;
@@ -7355,27 +7470,26 @@ public class Nimbus {
return false;
}
- public void start(I iface, getLeader_args args, org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getLeader(resultHandler);
+ public void start(I iface, getTopologyPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getTopologyPageInfo(args.id, args.window, args.is_include_sys,resultHandler);
}
}
- public static class isTopologyNameAllowed<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, isTopologyNameAllowed_args, java.lang.Boolean> {
- public isTopologyNameAllowed() {
- super("isTopologyNameAllowed");
+ public static class getSupervisorPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorPageInfo_args, SupervisorPageInfo> {
+ public getSupervisorPageInfo() {
+ super("getSupervisorPageInfo");
}
- public isTopologyNameAllowed_args getEmptyArgsInstance() {
- return new isTopologyNameAllowed_args();
+ public getSupervisorPageInfo_args getEmptyArgsInstance() {
+ return new getSupervisorPageInfo_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
- public void onComplete(java.lang.Boolean o) {
- isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo>() {
+ public void onComplete(SupervisorPageInfo o) {
+ getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
result.success = o;
- result.set_success_isSet(true);
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
} catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -7389,8 +7503,12 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
- if (e instanceof AuthorizationException) {
+ getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
+ if (e instanceof NotAliveException) {
+ result.e = (NotAliveException) e;
+ result.set_e_isSet(true);
+ msg = result;
+ } else if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
msg = result;
@@ -7421,25 +7539,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, isTopologyNameAllowed_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.storm.thrift.TException {
- iface.isTopologyNameAllowed(args.name,resultHandler);
+ public void start(I iface, getSupervisorPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getSupervisorPageInfo(args.id, args.host, args.is_include_sys,resultHandler);
}
}
- public static class getTopologyInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfo_args, TopologyInfo> {
- public getTopologyInfo() {
- super("getTopologyInfo");
+ public static class getComponentPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getComponentPageInfo_args, ComponentPageInfo> {
+ public getComponentPageInfo() {
+ super("getComponentPageInfo");
}
- public getTopologyInfo_args getEmptyArgsInstance() {
- return new getTopologyInfo_args();
+ public getComponentPageInfo_args getEmptyArgsInstance() {
+ return new getComponentPageInfo_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() {
- public void onComplete(TopologyInfo o) {
- getTopologyInfo_result result = new getTopologyInfo_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo>() {
+ public void onComplete(ComponentPageInfo o) {
+ getComponentPageInfo_result result = new getComponentPageInfo_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7454,7 +7572,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getTopologyInfo_result result = new getTopologyInfo_result();
+ getComponentPageInfo_result result = new getComponentPageInfo_result();
if (e instanceof NotAliveException) {
result.e = (NotAliveException) e;
result.set_e_isSet(true);
@@ -7490,25 +7608,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getTopologyInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getTopologyInfo(args.id,resultHandler);
+ public void start(I iface, getComponentPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getComponentPageInfo(args.topology_id, args.component_id, args.window, args.is_include_sys,resultHandler);
}
}
- public static class getTopologyInfoWithOpts<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfoWithOpts_args, TopologyInfo> {
- public getTopologyInfoWithOpts() {
- super("getTopologyInfoWithOpts");
+ public static class getTopologyConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyConf_args, java.lang.String> {
+ public getTopologyConf() {
+ super("getTopologyConf");
}
- public getTopologyInfoWithOpts_args getEmptyArgsInstance() {
- return new getTopologyInfoWithOpts_args();
+ public getTopologyConf_args getEmptyArgsInstance() {
+ return new getTopologyConf_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() {
- public void onComplete(TopologyInfo o) {
- getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() {
+ public void onComplete(java.lang.String o) {
+ getTopologyConf_result result = new getTopologyConf_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7523,7 +7641,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+ getTopologyConf_result result = new getTopologyConf_result();
if (e instanceof NotAliveException) {
result.e = (NotAliveException) e;
result.set_e_isSet(true);
@@ -7559,25 +7677,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getTopologyInfoWithOpts_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getTopologyInfoWithOpts(args.id, args.options,resultHandler);
+ public void start(I iface, getTopologyConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getTopologyConf(args.id,resultHandler);
}
}
- public static class getTopologyPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyPageInfo_args, TopologyPageInfo> {
- public getTopologyPageInfo() {
- super("getTopologyPageInfo");
+ public static class getTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopology_args, StormTopology> {
+ public getTopology() {
+ super("getTopology");
}
- public getTopologyPageInfo_args getEmptyArgsInstance() {
- return new getTopologyPageInfo_args();
+ public getTopology_args getEmptyArgsInstance() {
+ return new getTopology_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo>() {
- public void onComplete(TopologyPageInfo o) {
- getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() {
+ public void onComplete(StormTopology o) {
+ getTopology_result result = new getTopology_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7592,7 +7710,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+ getTopology_result result = new getTopology_result();
if (e instanceof NotAliveException) {
result.e = (NotAliveException) e;
result.set_e_isSet(true);
@@ -7628,25 +7746,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getTopologyPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getTopologyPageInfo(args.id, args.window, args.is_include_sys,resultHandler);
+ public void start(I iface, getTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getTopology(args.id,resultHandler);
}
}
- public static class getSupervisorPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorPageInfo_args, SupervisorPageInfo> {
- public getSupervisorPageInfo() {
- super("getSupervisorPageInfo");
+ public static class getUserTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getUserTopology_args, StormTopology> {
+ public getUserTopology() {
+ super("getUserTopology");
}
- public getSupervisorPageInfo_args getEmptyArgsInstance() {
- return new getSupervisorPageInfo_args();
+ public getUserTopology_args getEmptyArgsInstance() {
+ return new getUserTopology_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo>() {
- public void onComplete(SupervisorPageInfo o) {
- getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() {
+ public void onComplete(StormTopology o) {
+ getUserTopology_result result = new getUserTopology_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7661,7 +7779,7 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
+ getUserTopology_result result = new getUserTopology_result();
if (e instanceof NotAliveException) {
result.e = (NotAliveException) e;
result.set_e_isSet(true);
@@ -7697,25 +7815,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getSupervisorPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getSupervisorPageInfo(args.id, args.host, args.is_include_sys,resultHandler);
+ public void start(I iface, getUserTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getUserTopology(args.id,resultHandler);
}
}
- public static class getComponentPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getComponentPageInfo_args, ComponentPageInfo> {
- public getComponentPageInfo() {
- super("getComponentPageInfo");
+ public static class getTopologyHistory<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyHistory_args, TopologyHistoryInfo> {
+ public getTopologyHistory() {
+ super("getTopologyHistory");
}
- public getComponentPageInfo_args getEmptyArgsInstance() {
- return new getComponentPageInfo_args();
+ public getTopologyHistory_args getEmptyArgsInstance() {
+ return new getTopologyHistory_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo>() {
- public void onComplete(ComponentPageInfo o) {
- getComponentPageInfo_result result = new getComponentPageInfo_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo>() {
+ public void onComplete(TopologyHistoryInfo o) {
+ getTopologyHistory_result result = new getTopologyHistory_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7730,12 +7848,8 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getComponentPageInfo_result result = new getComponentPageInfo_result();
- if (e instanceof NotAliveException) {
- result.e = (NotAliveException) e;
- result.set_e_isSet(true);
- msg = result;
- } else if (e instanceof AuthorizationException) {
+ getTopologyHistory_result result = new getTopologyHistory_result();
+ if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
msg = result;
@@ -7766,25 +7880,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getComponentPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getComponentPageInfo(args.topology_id, args.component_id, args.window, args.is_include_sys,resultHandler);
+ public void start(I iface, getTopologyHistory_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getTopologyHistory(args.user,resultHandler);
}
}
- public static class getTopologyConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyConf_args, java.lang.String> {
- public getTopologyConf() {
- super("getTopologyConf");
+ public static class getOwnerResourceSummaries<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getOwnerResourceSummaries_args, java.util.List<OwnerResourceSummary>> {
+ public getOwnerResourceSummaries() {
+ super("getOwnerResourceSummaries");
}
- public getTopologyConf_args getEmptyArgsInstance() {
- return new getTopologyConf_args();
+ public getOwnerResourceSummaries_args getEmptyArgsInstance() {
+ return new getOwnerResourceSummaries_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() {
- public void onComplete(java.lang.String o) {
- getTopologyConf_result result = new getTopologyConf_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>>() {
+ public void onComplete(java.util.List<OwnerResourceSummary> o) {
+ getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7799,12 +7913,8 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getTopologyConf_result result = new getTopologyConf_result();
- if (e instanceof NotAliveException) {
- result.e = (NotAliveException) e;
- result.set_e_isSet(true);
- msg = result;
- } else if (e instanceof AuthorizationException) {
+ getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
+ if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
msg = result;
@@ -7835,25 +7945,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getTopologyConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getTopologyConf(args.id,resultHandler);
+ public void start(I iface, getOwnerResourceSummaries_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getOwnerResourceSummaries(args.owner,resultHandler);
}
}
- public static class getTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopology_args, StormTopology> {
- public getTopology() {
- super("getTopology");
+ public static class getSupervisorAssignments<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorAssignments_args, SupervisorAssignments> {
+ public getSupervisorAssignments() {
+ super("getSupervisorAssignments");
}
- public getTopology_args getEmptyArgsInstance() {
- return new getTopology_args();
+ public getSupervisorAssignments_args getEmptyArgsInstance() {
+ return new getSupervisorAssignments_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() {
- public void onComplete(StormTopology o) {
- getTopology_result result = new getTopology_result();
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments>() {
+ public void onComplete(SupervisorAssignments o) {
+ getSupervisorAssignments_result result = new getSupervisorAssignments_result();
result.success = o;
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7868,12 +7978,8 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getTopology_result result = new getTopology_result();
- if (e instanceof NotAliveException) {
- result.e = (NotAliveException) e;
- result.set_e_isSet(true);
- msg = result;
- } else if (e instanceof AuthorizationException) {
+ getSupervisorAssignments_result result = new getSupervisorAssignments_result();
+ if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
msg = result;
@@ -7904,26 +8010,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getTopology(args.id,resultHandler);
+ public void start(I iface, getSupervisorAssignments_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.getSupervisorAssignments(args.node,resultHandler);
}
}
- public static class getUserTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getUserTopology_args, StormTopology> {
- public getUserTopology() {
- super("getUserTopology");
+ public static class sendSupervisorWorkerHeartbeats<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeats_args, Void> {
+ public sendSupervisorWorkerHeartbeats() {
+ super("sendSupervisorWorkerHeartbeats");
}
- public getUserTopology_args getEmptyArgsInstance() {
- return new getUserTopology_args();
+ public sendSupervisorWorkerHeartbeats_args getEmptyArgsInstance() {
+ return new sendSupervisorWorkerHeartbeats_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() {
- public void onComplete(StormTopology o) {
- getUserTopology_result result = new getUserTopology_result();
- result.success = o;
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
} catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -7937,12 +8042,8 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getUserTopology_result result = new getUserTopology_result();
- if (e instanceof NotAliveException) {
- result.e = (NotAliveException) e;
- result.set_e_isSet(true);
- msg = result;
- } else if (e instanceof AuthorizationException) {
+ sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
+ if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
msg = result;
@@ -7973,26 +8074,25 @@ public class Nimbus {
return false;
}
- public void start(I iface, getUserTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getUserTopology(args.id,resultHandler);
+ public void start(I iface, sendSupervisorWorkerHeartbeats_args args, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException {
+ iface.sendSupervisorWorkerHeartbeats(args.heartbeats,resultHandler);
}
}
- public static class getTopologyHistory<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyHistory_args, TopologyHistoryInfo> {
- public getTopologyHistory() {
- super("getTopologyHistory");
+ public static class sendSupervisorWorkerHeartbeat<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeat_args, Void> {
+ public sendSupervisorWorkerHeartbeat() {
+ super("sendSupervisorWorkerHeartbeat");
}
- public getTopologyHistory_args getEmptyArgsInstance() {
- return new getTopologyHistory_args();
+ public sendSupervisorWorkerHeartbeat_args getEmptyArgsInstance() {
+ return new sendSupervisorWorkerHeartbeat_args();
}
- public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+ public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo>() {
- public void onComplete(TopologyHistoryInfo o) {
- getTopologyHistory_result result = new getTopologyHistory_result();
- result.success = o;
+ return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
try {
fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
} catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -8006,272 +8106,14 @@ public class Nimbus {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
org.apache.storm.thrift.TSerializable msg;
- getTopologyHistory_result result = new getTopologyHistory_result();
+ sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
if (e instanceof AuthorizationException) {
result.aze = (AuthorizationException) e;
result.set_aze_isSet(true);
- msg = result;
- } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
- _LOGGER.error("TTransportException inside handler", e);
- fb.close();
- return;
- } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
- _LOGGER.error("TApplicationException inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.storm.thrift.TApplicationException)e;
- } else {
- _LOGGER.error("Exception inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- } catch (java.lang.Exception ex) {
- _LOGGER.error("Exception writing to internal frame buffer", ex);
- fb.close();
- }
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, getTopologyHistory_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getTopologyHistory(args.user,resultHandler);
- }
- }
-
- public static class getOwnerResourceSummaries<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getOwnerResourceSummaries_args, java.util.List<OwnerResourceSummary>> {
- public getOwnerResourceSummaries() {
- super("getOwnerResourceSummaries");
- }
-
- public getOwnerResourceSummaries_args getEmptyArgsInstance() {
- return new getOwnerResourceSummaries_args();
- }
-
- public org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
- final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>>() {
- public void onComplete(java.util.List<OwnerResourceSummary> o) {
- getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
- result.success = o;
- try {
- fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
- } catch (org.apache.storm.thrift.transport.TTransportException e) {
- _LOGGER.error("TTransportException writing to internal frame buffer", e);
- fb.close();
- } catch (java.lang.Exception e) {
- _LOGGER.error("Exception writing to internal frame buffer", e);
- onError(e);
- }
- }
- public void onError(java.lang.Exception e) {
- byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
- org.apache.storm.thrift.TSerializable msg;
- getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
- if (e instanceof AuthorizationException) {
- result.aze = (AuthorizationException) e;
- result.set_aze_isSet(true);
- msg = result;
- } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
- _LOGGER.error("TTransportException inside handler", e);
- fb.close();
- return;
- } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
- _LOGGER.error("TApplicationException inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.storm.thrift.TApplicationException)e;
- } else {
- _LOGGER.error("Exception inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- } catch (java.lang.Exception ex) {
- _LOGGER.error("Exception writing to internal frame buffer", ex);
- fb.close();
- }
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, getOwnerResourceSummaries_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getOwnerResourceSummaries(args.owner,resultHandler);
- }
- }
-
- public static class getSupervisorAssignments<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorAssignments_args, SupervisorAssignments> {
- public getSupervisorAssignments() {
- super("getSupervisorAssignments");
- }
-
- public getSupervisorAssignments_args getEmptyArgsInstance() {
- return new getSupervisorAssignments_args();
- }
-
- public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
- final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments>() {
- public void onComplete(SupervisorAssignments o) {
- getSupervisorAssignments_result result = new getSupervisorAssignments_result();
- result.success = o;
- try {
- fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
- } catch (org.apache.storm.thrift.transport.TTransportException e) {
- _LOGGER.error("TTransportException writing to internal frame buffer", e);
- fb.close();
- } catch (java.lang.Exception e) {
- _LOGGER.error("Exception writing to internal frame buffer", e);
- onError(e);
- }
- }
- public void onError(java.lang.Exception e) {
- byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
- org.apache.storm.thrift.TSerializable msg;
- getSupervisorAssignments_result result = new getSupervisorAssignments_result();
- if (e instanceof AuthorizationException) {
- result.aze = (AuthorizationException) e;
- result.set_aze_isSet(true);
- msg = result;
- } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
- _LOGGER.error("TTransportException inside handler", e);
- fb.close();
- return;
- } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
- _LOGGER.error("TApplicationException inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.storm.thrift.TApplicationException)e;
- } else {
- _LOGGER.error("Exception inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- } catch (java.lang.Exception ex) {
- _LOGGER.error("Exception writing to internal frame buffer", ex);
- fb.close();
- }
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, getSupervisorAssignments_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException {
- iface.getSupervisorAssignments(args.node,resultHandler);
- }
- }
-
- public static class sendSupervisorWorkerHeartbeats<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeats_args, Void> {
- public sendSupervisorWorkerHeartbeats() {
- super("sendSupervisorWorkerHeartbeats");
- }
-
- public sendSupervisorWorkerHeartbeats_args getEmptyArgsInstance() {
- return new sendSupervisorWorkerHeartbeats_args();
- }
-
- public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
- final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
- try {
- fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
- } catch (org.apache.storm.thrift.transport.TTransportException e) {
- _LOGGER.error("TTransportException writing to internal frame buffer", e);
- fb.close();
- } catch (java.lang.Exception e) {
- _LOGGER.error("Exception writing to internal frame buffer", e);
- onError(e);
- }
- }
- public void onError(java.lang.Exception e) {
- byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
- org.apache.storm.thrift.TSerializable msg;
- sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
- if (e instanceof AuthorizationException) {
- result.aze = (AuthorizationException) e;
- result.set_aze_isSet(true);
- msg = result;
- } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
- _LOGGER.error("TTransportException inside handler", e);
- fb.close();
- return;
- } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
- _LOGGER.error("TApplicationException inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.storm.thrift.TApplicationException)e;
- } else {
- _LOGGER.error("Exception inside handler", e);
- msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
- msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- } catch (java.lang.Exception ex) {
- _LOGGER.error("Exception writing to internal frame buffer", ex);
- fb.close();
- }
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, sendSupervisorWorkerHeartbeats_args args, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException {
- iface.sendSupervisorWorkerHeartbeats(args.heartbeats,resultHandler);
- }
- }
-
- public static class sendSupervisorWorkerHeartbeat<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeat_args, Void> {
- public sendSupervisorWorkerHeartbeat() {
- super("sendSupervisorWorkerHeartbeat");
- }
-
- public sendSupervisorWorkerHeartbeat_args getEmptyArgsInstance() {
- return new sendSupervisorWorkerHeartbeat_args();
- }
-
- public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
- final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
- try {
- fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
- } catch (org.apache.storm.thrift.transport.TTransportException e) {
- _LOGGER.error("TTransportException writing to internal frame buffer", e);
- fb.close();
- } catch (java.lang.Exception e) {
- _LOGGER.error("Exception writing to internal frame buffer", e);
- onError(e);
- }
- }
- public void onError(java.lang.Exception e) {
- byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
- org.apache.storm.thrift.TSerializable msg;
- sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
- if (e instanceof AuthorizationException) {
- result.aze = (AuthorizationException) e;
- result.set_aze_isSet(true);
- msg = result;
- } else if (e instanceof NotAliveException) {
- result.e = (NotAliveException) e;
- result.set_e_isSet(true);
+ msg = result;
+ } else if (e instanceof NotAliveException) {
+ result.e = (NotAliveException) e;
+ result.set_e_isSet(true);
msg = result;
} else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
_LOGGER.error("TTransportException inside handler", e);
@@ -33279,909 +33121,14 @@ public class Nimbus {
public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
- case SUCCESS:
- if (value == null) {
- unset_success();
- } else {
- set_success((java.lang.String)value);
- }
- break;
-
- case AZE:
- if (value == null) {
- unset_aze();
- } else {
- set_aze((AuthorizationException)value);
- }
- break;
-
- }
- }
-
- public java.lang.Object getFieldValue(_Fields field) {
- switch (field) {
- case SUCCESS:
- return get_success();
-
- case AZE:
- return get_aze();
-
- }
- throw new java.lang.IllegalStateException();
- }
-
- /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
- public boolean isSet(_Fields field) {
- if (field == null) {
- throw new java.lang.IllegalArgumentException();
- }
-
- switch (field) {
- case SUCCESS:
- return is_set_success();
- case AZE:
- return is_set_aze();
- }
- throw new java.lang.IllegalStateException();
- }
-
- @Override
- public boolean equals(java.lang.Object that) {
- if (that == null)
- return false;
- if (that instanceof beginFileUpload_result)
- return this.equals((beginFileUpload_result)that);
- return false;
- }
-
- public boolean equals(beginFileUpload_result that) {
- if (that == null)
- return false;
- if (this == that)
- return true;
-
- boolean this_present_success = true && this.is_set_success();
- boolean that_present_success = true && that.is_set_success();
- if (this_present_success || that_present_success) {
- if (!(this_present_success && that_present_success))
- return false;
- if (!this.success.equals(that.success))
- return false;
- }
-
- boolean this_present_aze = true && this.is_set_aze();
- boolean that_present_aze = true && that.is_set_aze();
- if (this_present_aze || that_present_aze) {
- if (!(this_present_aze && that_present_aze))
- return false;
- if (!this.aze.equals(that.aze))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- int hashCode = 1;
-
- hashCode = hashCode * 8191 + ((is_set_success()) ? 131071 : 524287);
- if (is_set_success())
- hashCode = hashCode * 8191 + success.hashCode();
-
- hashCode = hashCode * 8191 + ((is_set_aze()) ? 131071 : 524287);
- if (is_set_aze())
- hashCode = hashCode * 8191 + aze.hashCode();
-
- return hashCode;
- }
-
- @Override
- public int compareTo(beginFileUpload_result other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = java.lang.Boolean.valueOf(is_set_success()).compareTo(other.is_set_success());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_success()) {
- lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.success, other.success);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = java.lang.Boolean.valueOf(is_set_aze()).compareTo(other.is_set_aze());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_aze()) {
- lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.aze, other.aze);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- return 0;
- }
-
- public _Fields fieldForId(int fieldId) {
- return _Fields.findByThriftId(fieldId);
- }
-
- public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException {
- scheme(iprot).read(iprot, this);
- }
-
- public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
- scheme(oprot).write(oprot, this);
- }
-
- @Override
- public java.lang.String toString() {
- java.lang.StringBuilder sb = new java.lang.StringBuilder("beginFileUpload_result(");
- boolean first = true;
-
- sb.append("success:");
- if (this.success == null) {
- sb.append("null");
- } else {
- sb.append(this.success);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("aze:");
- if (this.aze == null) {
- sb.append("null");
- } else {
- sb.append(this.aze);
- }
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.storm.thrift.TException {
- // check for required fields
- // check for sub-struct validity
- }
-
- private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
- try {
- write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.storm.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
- try {
- read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.storm.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private static class beginFileUpload_resultStandardSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
- public beginFileUpload_resultStandardScheme getScheme() {
- return new beginFileUpload_resultStandardScheme();
- }
- }
-
- private static class beginFileUpload_resultStandardScheme extends org.apache.storm.thrift.scheme.StandardScheme<beginFileUpload_result> {
-
- public void read(org.apache.storm.thrift.protocol.TProtocol iprot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
- org.apache.storm.thrift.protocol.TField schemeField;
- iprot.readStructBegin();
- while (true)
- {
- schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.storm.thrift.protocol.TType.STOP) {
- break;
- }
- switch (schemeField.id) {
- case 0: // SUCCESS
- if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRING) {
- struct.success = iprot.readString();
- struct.set_success_isSet(true);
- } else {
- org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 1: // AZE
- if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRUCT) {
- struct.aze = new AuthorizationException();
- struct.aze.read(iprot);
- struct.set_aze_isSet(true);
- } else {
- org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.storm.thrift.protocol.TProtocol oprot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.success != null) {
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- oprot.writeString(struct.success);
- oprot.writeFieldEnd();
- }
- if (struct.aze != null) {
- oprot.writeFieldBegin(AZE_FIELD_DESC);
- struct.aze.write(oprot);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class beginFileUpload_resultTupleSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
- public beginFileUpload_resultTupleScheme getScheme() {
- return new beginFileUpload_resultTupleScheme();
- }
- }
-
- private static class beginFileUpload_resultTupleScheme extends org.apache.storm.thrift.scheme.TupleScheme<beginFileUpload_result> {
-
- @Override
- public void write(org.apache.storm.thrift.protocol.TProtocol prot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
- org.apache.storm.thrift.protocol.TTupleProtocol oprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
- java.util.BitSet optionals = new java.util.BitSet();
- if (struct.is_set_success()) {
- optionals.set(0);
- }
- if (struct.is_set_aze()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
- if (struct.is_set_success()) {
- oprot.writeString(struct.success);
- }
- if (struct.is_set_aze()) {
- struct.aze.write(oprot);
- }
- }
-
- @Override
- public void read(org.apache.storm.thrift.protocol.TProtocol prot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
- org.apache.storm.thrift.protocol.TTupleProtocol iprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
- java.util.BitSet incoming = iprot.readBitSet(2);
- if (incoming.get(0)) {
- struct.success = iprot.readString();
- struct.set_success_isSet(true);
- }
- if (incoming.get(1)) {
- struct.aze = new AuthorizationException();
- struct.aze.read(iprot);
- struct.set_aze_isSet(true);
- }
- }
- }
-
- private static <S extends org.apache.storm.thrift.scheme.IScheme> S scheme(org.apache.storm.thrift.protocol.TProtocol proto) {
- return (org.apache.storm.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
- }
- }
-
- public static class uploadChunk_args implements org.apache.storm.thrift.TBase<uploadChunk_args, uploadChunk_args._Fields>, java.io.Serializable, Cloneable, Comparable<uploadChunk_args> {
- private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("uploadChunk_args");
-
- private static final org.apache.storm.thrift.protocol.TField LOCATION_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("location", org.apache.storm.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.storm.thrift.protocol.TField CHUNK_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("chunk", org.apache.storm.thrift.protocol.TType.STRING, (short)2);
-
- private static final org.apache.storm.thrift.scheme.Sch
<TRUNCATED>