http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/ddf2c89e/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java ---------------------------------------------------------------------- diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java index fbcc514..abf4316 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java @@ -51,12 +51,12 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-1-4") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-1-24") public class RemoteInterpreterService { public interface Iface { - public void createInterpreter(String className, Map<String,String> properties) throws org.apache.thrift.TException; + public void createInterpreter(String intpGroupId, String className, Map<String,String> properties) throws org.apache.thrift.TException; public void open(String className) throws org.apache.thrift.TException; @@ -78,6 +78,14 @@ public class RemoteInterpreterService { public RemoteInterpreterEvent getEvent() throws org.apache.thrift.TException; + public void resourcePoolResponseGetAll(List<String> resources) throws org.apache.thrift.TException; + + public void resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException; + + public List<String> resoucePoolGetAll() throws org.apache.thrift.TException; + + public ByteBuffer resourceGet(String resourceName) throws org.apache.thrift.TException; + public void angularObjectUpdate(String name, String noteId, String paragraphId, String object) throws org.apache.thrift.TException; public void angularObjectAdd(String name, String noteId, String paragraphId, String object) throws org.apache.thrift.TException; @@ -88,7 +96,7 @@ public class RemoteInterpreterService { public interface AsyncIface { - public void createInterpreter(String className, Map<String,String> properties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void createInterpreter(String intpGroupId, String className, Map<String,String> properties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void open(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -110,6 +118,14 @@ public class RemoteInterpreterService { public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void resourcePoolResponseGetAll(List<String> resources, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resourceResponseGet(String resourceId, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resoucePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resourceGet(String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void angularObjectUpdate(String name, String noteId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void angularObjectAdd(String name, String noteId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -138,15 +154,16 @@ public class RemoteInterpreterService { super(iprot, oprot); } - public void createInterpreter(String className, Map<String,String> properties) throws org.apache.thrift.TException + public void createInterpreter(String intpGroupId, String className, Map<String,String> properties) throws org.apache.thrift.TException { - send_createInterpreter(className, properties); + send_createInterpreter(intpGroupId, className, properties); recv_createInterpreter(); } - public void send_createInterpreter(String className, Map<String,String> properties) throws org.apache.thrift.TException + public void send_createInterpreter(String intpGroupId, String className, Map<String,String> properties) throws org.apache.thrift.TException { createInterpreter_args args = new createInterpreter_args(); + args.setIntpGroupId(intpGroupId); args.setClassName(className); args.setProperties(properties); sendBase("createInterpreter", args); @@ -381,6 +398,92 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getEvent failed: unknown result"); } + public void resourcePoolResponseGetAll(List<String> resources) throws org.apache.thrift.TException + { + send_resourcePoolResponseGetAll(resources); + recv_resourcePoolResponseGetAll(); + } + + public void send_resourcePoolResponseGetAll(List<String> resources) throws org.apache.thrift.TException + { + resourcePoolResponseGetAll_args args = new resourcePoolResponseGetAll_args(); + args.setResources(resources); + sendBase("resourcePoolResponseGetAll", args); + } + + public void recv_resourcePoolResponseGetAll() throws org.apache.thrift.TException + { + resourcePoolResponseGetAll_result result = new resourcePoolResponseGetAll_result(); + receiveBase(result, "resourcePoolResponseGetAll"); + return; + } + + public void resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException + { + send_resourceResponseGet(resourceId, object); + recv_resourceResponseGet(); + } + + public void send_resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException + { + resourceResponseGet_args args = new resourceResponseGet_args(); + args.setResourceId(resourceId); + args.setObject(object); + sendBase("resourceResponseGet", args); + } + + public void recv_resourceResponseGet() throws org.apache.thrift.TException + { + resourceResponseGet_result result = new resourceResponseGet_result(); + receiveBase(result, "resourceResponseGet"); + return; + } + + public List<String> resoucePoolGetAll() throws org.apache.thrift.TException + { + send_resoucePoolGetAll(); + return recv_resoucePoolGetAll(); + } + + public void send_resoucePoolGetAll() throws org.apache.thrift.TException + { + resoucePoolGetAll_args args = new resoucePoolGetAll_args(); + sendBase("resoucePoolGetAll", args); + } + + public List<String> recv_resoucePoolGetAll() throws org.apache.thrift.TException + { + resoucePoolGetAll_result result = new resoucePoolGetAll_result(); + receiveBase(result, "resoucePoolGetAll"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resoucePoolGetAll failed: unknown result"); + } + + public ByteBuffer resourceGet(String resourceName) throws org.apache.thrift.TException + { + send_resourceGet(resourceName); + return recv_resourceGet(); + } + + public void send_resourceGet(String resourceName) throws org.apache.thrift.TException + { + resourceGet_args args = new resourceGet_args(); + args.setResourceName(resourceName); + sendBase("resourceGet", args); + } + + public ByteBuffer recv_resourceGet() throws org.apache.thrift.TException + { + resourceGet_result result = new resourceGet_result(); + receiveBase(result, "resourceGet"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceGet failed: unknown result"); + } + public void angularObjectUpdate(String name, String noteId, String paragraphId, String object) throws org.apache.thrift.TException { send_angularObjectUpdate(name, noteId, paragraphId, object); @@ -467,18 +570,20 @@ public class RemoteInterpreterService { super(protocolFactory, clientManager, transport); } - public void createInterpreter(String className, Map<String,String> properties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void createInterpreter(String intpGroupId, String className, Map<String,String> properties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - createInterpreter_call method_call = new createInterpreter_call(className, properties, resultHandler, this, ___protocolFactory, ___transport); + createInterpreter_call method_call = new createInterpreter_call(intpGroupId, className, properties, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class createInterpreter_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; private String className; private Map<String,String> properties; - public createInterpreter_call(String className, Map<String,String> properties, 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 createInterpreter_call(String intpGroupId, String className, Map<String,String> properties, 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 { super(client, protocolFactory, transport, resultHandler, false); + this.intpGroupId = intpGroupId; this.className = className; this.properties = properties; } @@ -486,6 +591,7 @@ public class RemoteInterpreterService { public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createInterpreter", org.apache.thrift.protocol.TMessageType.CALL, 0)); createInterpreter_args args = new createInterpreter_args(); + args.setIntpGroupId(intpGroupId); args.setClassName(className); args.setProperties(properties); args.write(prot); @@ -834,6 +940,134 @@ public class RemoteInterpreterService { } } + public void resourcePoolResponseGetAll(List<String> resources, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + resourcePoolResponseGetAll_call method_call = new resourcePoolResponseGetAll_call(resources, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class resourcePoolResponseGetAll_call extends org.apache.thrift.async.TAsyncMethodCall { + private List<String> resources; + public resourcePoolResponseGetAll_call(List<String> resources, 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 { + super(client, protocolFactory, transport, resultHandler, false); + this.resources = resources; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourcePoolResponseGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0)); + resourcePoolResponseGetAll_args args = new resourcePoolResponseGetAll_args(); + args.setResources(resources); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + (new Client(prot)).recv_resourcePoolResponseGetAll(); + } + } + + public void resourceResponseGet(String resourceId, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + resourceResponseGet_call method_call = new resourceResponseGet_call(resourceId, object, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class resourceResponseGet_call extends org.apache.thrift.async.TAsyncMethodCall { + private String resourceId; + private ByteBuffer object; + public resourceResponseGet_call(String resourceId, ByteBuffer object, 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 { + super(client, protocolFactory, transport, resultHandler, false); + this.resourceId = resourceId; + this.object = object; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceResponseGet", org.apache.thrift.protocol.TMessageType.CALL, 0)); + resourceResponseGet_args args = new resourceResponseGet_args(); + args.setResourceId(resourceId); + args.setObject(object); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + (new Client(prot)).recv_resourceResponseGet(); + } + } + + public void resoucePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + resoucePoolGetAll_call method_call = new resoucePoolGetAll_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class resoucePoolGetAll_call extends org.apache.thrift.async.TAsyncMethodCall { + public resoucePoolGetAll_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 { + super(client, protocolFactory, transport, resultHandler, false); + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resoucePoolGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0)); + resoucePoolGetAll_args args = new resoucePoolGetAll_args(); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<String> getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_resoucePoolGetAll(); + } + } + + public void resourceGet(String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + resourceGet_call method_call = new resourceGet_call(resourceName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class resourceGet_call extends org.apache.thrift.async.TAsyncMethodCall { + private String resourceName; + public resourceGet_call(String resourceName, 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 { + super(client, protocolFactory, transport, resultHandler, false); + this.resourceName = resourceName; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceGet", org.apache.thrift.protocol.TMessageType.CALL, 0)); + resourceGet_args args = new resourceGet_args(); + args.setResourceName(resourceName); + args.write(prot); + prot.writeMessageEnd(); + } + + public ByteBuffer getResult() throws org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_resourceGet(); + } + } + public void angularObjectUpdate(String name, String noteId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); angularObjectUpdate_call method_call = new angularObjectUpdate_call(name, noteId, paragraphId, object, resultHandler, this, ___protocolFactory, ___transport); @@ -978,6 +1212,10 @@ public class RemoteInterpreterService { processMap.put("shutdown", new shutdown()); processMap.put("getStatus", new getStatus()); processMap.put("getEvent", new getEvent()); + processMap.put("resourcePoolResponseGetAll", new resourcePoolResponseGetAll()); + processMap.put("resourceResponseGet", new resourceResponseGet()); + processMap.put("resoucePoolGetAll", new resoucePoolGetAll()); + processMap.put("resourceGet", new resourceGet()); processMap.put("angularObjectUpdate", new angularObjectUpdate()); processMap.put("angularObjectAdd", new angularObjectAdd()); processMap.put("angularObjectRemove", new angularObjectRemove()); @@ -999,7 +1237,7 @@ public class RemoteInterpreterService { public createInterpreter_result getResult(I iface, createInterpreter_args args) throws org.apache.thrift.TException { createInterpreter_result result = new createInterpreter_result(); - iface.createInterpreter(args.className, args.properties); + iface.createInterpreter(args.intpGroupId, args.className, args.properties); return result; } } @@ -1205,6 +1443,86 @@ public class RemoteInterpreterService { } } + public static class resourcePoolResponseGetAll<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resourcePoolResponseGetAll_args> { + public resourcePoolResponseGetAll() { + super("resourcePoolResponseGetAll"); + } + + public resourcePoolResponseGetAll_args getEmptyArgsInstance() { + return new resourcePoolResponseGetAll_args(); + } + + protected boolean isOneway() { + return false; + } + + public resourcePoolResponseGetAll_result getResult(I iface, resourcePoolResponseGetAll_args args) throws org.apache.thrift.TException { + resourcePoolResponseGetAll_result result = new resourcePoolResponseGetAll_result(); + iface.resourcePoolResponseGetAll(args.resources); + return result; + } + } + + public static class resourceResponseGet<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resourceResponseGet_args> { + public resourceResponseGet() { + super("resourceResponseGet"); + } + + public resourceResponseGet_args getEmptyArgsInstance() { + return new resourceResponseGet_args(); + } + + protected boolean isOneway() { + return false; + } + + public resourceResponseGet_result getResult(I iface, resourceResponseGet_args args) throws org.apache.thrift.TException { + resourceResponseGet_result result = new resourceResponseGet_result(); + iface.resourceResponseGet(args.resourceId, args.object); + return result; + } + } + + public static class resoucePoolGetAll<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resoucePoolGetAll_args> { + public resoucePoolGetAll() { + super("resoucePoolGetAll"); + } + + public resoucePoolGetAll_args getEmptyArgsInstance() { + return new resoucePoolGetAll_args(); + } + + protected boolean isOneway() { + return false; + } + + public resoucePoolGetAll_result getResult(I iface, resoucePoolGetAll_args args) throws org.apache.thrift.TException { + resoucePoolGetAll_result result = new resoucePoolGetAll_result(); + result.success = iface.resoucePoolGetAll(); + return result; + } + } + + public static class resourceGet<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resourceGet_args> { + public resourceGet() { + super("resourceGet"); + } + + public resourceGet_args getEmptyArgsInstance() { + return new resourceGet_args(); + } + + protected boolean isOneway() { + return false; + } + + public resourceGet_result getResult(I iface, resourceGet_args args) throws org.apache.thrift.TException { + resourceGet_result result = new resourceGet_result(); + result.success = iface.resourceGet(args.resourceName); + return result; + } + } + public static class angularObjectUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, angularObjectUpdate_args> { public angularObjectUpdate() { super("angularObjectUpdate"); @@ -1289,6 +1607,10 @@ public class RemoteInterpreterService { processMap.put("shutdown", new shutdown()); processMap.put("getStatus", new getStatus()); processMap.put("getEvent", new getEvent()); + processMap.put("resourcePoolResponseGetAll", new resourcePoolResponseGetAll()); + processMap.put("resourceResponseGet", new resourceResponseGet()); + processMap.put("resoucePoolGetAll", new resoucePoolGetAll()); + processMap.put("resourceGet", new resourceGet()); processMap.put("angularObjectUpdate", new angularObjectUpdate()); processMap.put("angularObjectAdd", new angularObjectAdd()); processMap.put("angularObjectRemove", new angularObjectRemove()); @@ -1341,7 +1663,7 @@ public class RemoteInterpreterService { } public void start(I iface, createInterpreter_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.createInterpreter(args.className, args.properties,resultHandler); + iface.createInterpreter(args.intpGroupId, args.className, args.properties,resultHandler); } } @@ -1852,20 +2174,20 @@ public class RemoteInterpreterService { } } - public static class angularObjectUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectUpdate_args, Void> { - public angularObjectUpdate() { - super("angularObjectUpdate"); + public static class resourcePoolResponseGetAll<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resourcePoolResponseGetAll_args, Void> { + public resourcePoolResponseGetAll() { + super("resourcePoolResponseGetAll"); } - public angularObjectUpdate_args getEmptyArgsInstance() { - return new angularObjectUpdate_args(); + public resourcePoolResponseGetAll_args getEmptyArgsInstance() { + return new resourcePoolResponseGetAll_args(); } public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Void>() { public void onComplete(Void o) { - angularObjectUpdate_result result = new angularObjectUpdate_result(); + resourcePoolResponseGetAll_result result = new resourcePoolResponseGetAll_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -1877,7 +2199,7 @@ public class RemoteInterpreterService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - angularObjectUpdate_result result = new angularObjectUpdate_result(); + resourcePoolResponseGetAll_result result = new resourcePoolResponseGetAll_result(); { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); @@ -1897,25 +2219,25 @@ public class RemoteInterpreterService { return false; } - public void start(I iface, angularObjectUpdate_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.angularObjectUpdate(args.name, args.noteId, args.paragraphId, args.object,resultHandler); + public void start(I iface, resourcePoolResponseGetAll_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.resourcePoolResponseGetAll(args.resources,resultHandler); } } - public static class angularObjectAdd<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectAdd_args, Void> { - public angularObjectAdd() { - super("angularObjectAdd"); + public static class resourceResponseGet<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resourceResponseGet_args, Void> { + public resourceResponseGet() { + super("resourceResponseGet"); } - public angularObjectAdd_args getEmptyArgsInstance() { - return new angularObjectAdd_args(); + public resourceResponseGet_args getEmptyArgsInstance() { + return new resourceResponseGet_args(); } public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Void>() { public void onComplete(Void o) { - angularObjectAdd_result result = new angularObjectAdd_result(); + resourceResponseGet_result result = new resourceResponseGet_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -1927,7 +2249,7 @@ public class RemoteInterpreterService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - angularObjectAdd_result result = new angularObjectAdd_result(); + resourceResponseGet_result result = new resourceResponseGet_result(); { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); @@ -1947,25 +2269,26 @@ public class RemoteInterpreterService { return false; } - public void start(I iface, angularObjectAdd_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.angularObjectAdd(args.name, args.noteId, args.paragraphId, args.object,resultHandler); + public void start(I iface, resourceResponseGet_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.resourceResponseGet(args.resourceId, args.object,resultHandler); } } - public static class angularObjectRemove<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectRemove_args, Void> { - public angularObjectRemove() { - super("angularObjectRemove"); + public static class resoucePoolGetAll<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resoucePoolGetAll_args, List<String>> { + public resoucePoolGetAll() { + super("resoucePoolGetAll"); } - public angularObjectRemove_args getEmptyArgsInstance() { - return new angularObjectRemove_args(); + public resoucePoolGetAll_args getEmptyArgsInstance() { + return new resoucePoolGetAll_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - angularObjectRemove_result result = new angularObjectRemove_result(); + return new AsyncMethodCallback<List<String>>() { + public void onComplete(List<String> o) { + resoucePoolGetAll_result result = new resoucePoolGetAll_result(); + result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -1977,7 +2300,7 @@ public class RemoteInterpreterService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - angularObjectRemove_result result = new angularObjectRemove_result(); + resoucePoolGetAll_result result = new resoucePoolGetAll_result(); { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); @@ -1997,49 +2320,255 @@ public class RemoteInterpreterService { return false; } - public void start(I iface, angularObjectRemove_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.angularObjectRemove(args.name, args.noteId, args.paragraphId,resultHandler); + public void start(I iface, resoucePoolGetAll_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { + iface.resoucePoolGetAll(resultHandler); } } - } - - public static class createInterpreter_args implements org.apache.thrift.TBase<createInterpreter_args, createInterpreter_args._Fields>, java.io.Serializable, Cloneable, Comparable<createInterpreter_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("createInterpreter_args"); - - private static final org.apache.thrift.protocol.TField CLASS_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("className", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField PROPERTIES_FIELD_DESC = new org.apache.thrift.protocol.TField("properties", org.apache.thrift.protocol.TType.MAP, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new createInterpreter_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new createInterpreter_argsTupleSchemeFactory()); - } - - public String className; // required - public Map<String,String> properties; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - CLASS_NAME((short)1, "className"), - PROPERTIES((short)2, "properties"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + public static class resourceGet<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resourceGet_args, ByteBuffer> { + public resourceGet() { + super("resourceGet"); + } - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } + public resourceGet_args getEmptyArgsInstance() { + return new resourceGet_args(); } - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // CLASS_NAME + public AsyncMethodCallback<ByteBuffer> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<ByteBuffer>() { + public void onComplete(ByteBuffer o) { + resourceGet_result result = new resourceGet_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + resourceGet_result result = new resourceGet_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, resourceGet_args args, org.apache.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws TException { + iface.resourceGet(args.resourceName,resultHandler); + } + } + + public static class angularObjectUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectUpdate_args, Void> { + public angularObjectUpdate() { + super("angularObjectUpdate"); + } + + public angularObjectUpdate_args getEmptyArgsInstance() { + return new angularObjectUpdate_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + angularObjectUpdate_result result = new angularObjectUpdate_result(); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + angularObjectUpdate_result result = new angularObjectUpdate_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, angularObjectUpdate_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.angularObjectUpdate(args.name, args.noteId, args.paragraphId, args.object,resultHandler); + } + } + + public static class angularObjectAdd<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectAdd_args, Void> { + public angularObjectAdd() { + super("angularObjectAdd"); + } + + public angularObjectAdd_args getEmptyArgsInstance() { + return new angularObjectAdd_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + angularObjectAdd_result result = new angularObjectAdd_result(); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + angularObjectAdd_result result = new angularObjectAdd_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, angularObjectAdd_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.angularObjectAdd(args.name, args.noteId, args.paragraphId, args.object,resultHandler); + } + } + + public static class angularObjectRemove<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectRemove_args, Void> { + public angularObjectRemove() { + super("angularObjectRemove"); + } + + public angularObjectRemove_args getEmptyArgsInstance() { + return new angularObjectRemove_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + angularObjectRemove_result result = new angularObjectRemove_result(); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + angularObjectRemove_result result = new angularObjectRemove_result(); + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, angularObjectRemove_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.angularObjectRemove(args.name, args.noteId, args.paragraphId,resultHandler); + } + } + + } + + public static class createInterpreter_args implements org.apache.thrift.TBase<createInterpreter_args, createInterpreter_args._Fields>, java.io.Serializable, Cloneable, Comparable<createInterpreter_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("createInterpreter_args"); + + private static final org.apache.thrift.protocol.TField INTP_GROUP_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("intpGroupId", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField CLASS_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("className", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField PROPERTIES_FIELD_DESC = new org.apache.thrift.protocol.TField("properties", org.apache.thrift.protocol.TType.MAP, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new createInterpreter_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new createInterpreter_argsTupleSchemeFactory()); + } + + public String intpGroupId; // required + public String className; // required + public Map<String,String> properties; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + INTP_GROUP_ID((short)1, "intpGroupId"), + CLASS_NAME((short)2, "className"), + PROPERTIES((short)3, "properties"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // INTP_GROUP_ID + return INTP_GROUP_ID; + case 2: // CLASS_NAME return CLASS_NAME; - case 2: // PROPERTIES + case 3: // PROPERTIES return PROPERTIES; default: return null; @@ -2084,6 +2613,8 @@ public class RemoteInterpreterService { public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.INTP_GROUP_ID, new org.apache.thrift.meta_data.FieldMetaData("intpGroupId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.CLASS_NAME, new org.apache.thrift.meta_data.FieldMetaData("className", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.PROPERTIES, new org.apache.thrift.meta_data.FieldMetaData("properties", org.apache.thrift.TFieldRequirementType.DEFAULT, @@ -2098,10 +2629,12 @@ public class RemoteInterpreterService { } public createInterpreter_args( + String intpGroupId, String className, Map<String,String> properties) { this(); + this.intpGroupId = intpGroupId; this.className = className; this.properties = properties; } @@ -2110,6 +2643,9 @@ public class RemoteInterpreterService { * Performs a deep copy on <i>other</i>. */ public createInterpreter_args(createInterpreter_args other) { + if (other.isSetIntpGroupId()) { + this.intpGroupId = other.intpGroupId; + } if (other.isSetClassName()) { this.className = other.className; } @@ -2125,10 +2661,35 @@ public class RemoteInterpreterService { @Override public void clear() { + this.intpGroupId = null; this.className = null; this.properties = null; } + public String getIntpGroupId() { + return this.intpGroupId; + } + + public createInterpreter_args setIntpGroupId(String intpGroupId) { + this.intpGroupId = intpGroupId; + return this; + } + + public void unsetIntpGroupId() { + this.intpGroupId = null; + } + + /** Returns true if field intpGroupId is set (has been assigned a value) and false otherwise */ + public boolean isSetIntpGroupId() { + return this.intpGroupId != null; + } + + public void setIntpGroupIdIsSet(boolean value) { + if (!value) { + this.intpGroupId = null; + } + } + public String getClassName() { return this.className; } @@ -2190,6 +2751,14 @@ public class RemoteInterpreterService { public void setFieldValue(_Fields field, Object value) { switch (field) { + case INTP_GROUP_ID: + if (value == null) { + unsetIntpGroupId(); + } else { + setIntpGroupId((String)value); + } + break; + case CLASS_NAME: if (value == null) { unsetClassName(); @@ -2211,6 +2780,9 @@ public class RemoteInterpreterService { public Object getFieldValue(_Fields field) { switch (field) { + case INTP_GROUP_ID: + return getIntpGroupId(); + case CLASS_NAME: return getClassName(); @@ -2228,6 +2800,8 @@ public class RemoteInterpreterService { } switch (field) { + case INTP_GROUP_ID: + return isSetIntpGroupId(); case CLASS_NAME: return isSetClassName(); case PROPERTIES: @@ -2249,6 +2823,15 @@ public class RemoteInterpreterService { if (that == null) return false; + boolean this_present_intpGroupId = true && this.isSetIntpGroupId(); + boolean that_present_intpGroupId = true && that.isSetIntpGroupId(); + if (this_present_intpGroupId || that_present_intpGroupId) { + if (!(this_present_intpGroupId && that_present_intpGroupId)) + return false; + if (!this.intpGroupId.equals(that.intpGroupId)) + return false; + } + boolean this_present_className = true && this.isSetClassName(); boolean that_present_className = true && that.isSetClassName(); if (this_present_className || that_present_className) { @@ -2274,6 +2857,11 @@ public class RemoteInterpreterService { public int hashCode() { List<Object> list = new ArrayList<Object>(); + boolean present_intpGroupId = true && (isSetIntpGroupId()); + list.add(present_intpGroupId); + if (present_intpGroupId) + list.add(intpGroupId); + boolean present_className = true && (isSetClassName()); list.add(present_className); if (present_className) @@ -2295,6 +2883,16 @@ public class RemoteInterpreterService { int lastComparison = 0; + lastComparison = Boolean.valueOf(isSetIntpGroupId()).compareTo(other.isSetIntpGroupId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetIntpGroupId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.intpGroupId, other.intpGroupId); + if (lastComparison != 0) { + return lastComparison; + } + } lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; @@ -2335,6 +2933,14 @@ public class RemoteInterpreterService { StringBuilder sb = new StringBuilder("createInterpreter_args("); boolean first = true; + sb.append("intpGroupId:"); + if (this.intpGroupId == null) { + sb.append("null"); + } else { + sb.append(this.intpGroupId); + } + first = false; + if (!first) sb.append(", "); sb.append("className:"); if (this.className == null) { sb.append("null"); @@ -2393,15 +2999,23 @@ public class RemoteInterpreterService { break; } switch (schemeField.id) { - case 1: // CLASS_NAME + case 1: // INTP_GROUP_ID if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.className = iprot.readString(); + struct.intpGroupId = iprot.readString(); + struct.setIntpGroupIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // CLASS_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.className = iprot.readString(); struct.setClassNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 2: // PROPERTIES + case 3: // PROPERTIES if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin(); @@ -2436,6 +3050,11 @@ public class RemoteInterpreterService { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.intpGroupId != null) { + oprot.writeFieldBegin(INTP_GROUP_ID_FIELD_DESC); + oprot.writeString(struct.intpGroupId); + oprot.writeFieldEnd(); + } if (struct.className != null) { oprot.writeFieldBegin(CLASS_NAME_FIELD_DESC); oprot.writeString(struct.className); @@ -2472,13 +3091,19 @@ public class RemoteInterpreterService { public void write(org.apache.thrift.protocol.TProtocol prot, createInterpreter_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); - if (struct.isSetClassName()) { + if (struct.isSetIntpGroupId()) { optionals.set(0); } - if (struct.isSetProperties()) { + if (struct.isSetClassName()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetProperties()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetIntpGroupId()) { + oprot.writeString(struct.intpGroupId); + } if (struct.isSetClassName()) { oprot.writeString(struct.className); } @@ -2497,12 +3122,16 @@ public class RemoteInterpreterService { @Override public void read(org.apache.thrift.protocol.TProtocol prot, createInterpreter_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { + struct.intpGroupId = iprot.readString(); + struct.setIntpGroupIdIsSet(true); + } + if (incoming.get(1)) { struct.className = iprot.readString(); struct.setClassNameIsSet(true); } - if (incoming.get(1)) { + if (incoming.get(2)) { { org.apache.thrift.protocol.TMap _map6 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); struct.properties = new HashMap<String,String>(2*_map6.size); @@ -8272,13 +8901,2615 @@ public class RemoteInterpreterService { public void clear() { } - public void setFieldValue(_Fields field, Object value) { - switch (field) { + public void setFieldValue(_Fields field, Object value) { + switch (field) { + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + } + throw new 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 IllegalArgumentException(); + } + + switch (field) { + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof shutdown_args) + return this.equals((shutdown_args)that); + return false; + } + + public boolean equals(shutdown_args that) { + if (that == null) + return false; + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + return list.hashCode(); + } + + @Override + public int compareTo(shutdown_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("shutdown_args("); + boolean first = true; + + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.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.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class shutdown_argsStandardSchemeFactory implements SchemeFactory { + public shutdown_argsStandardScheme getScheme() { + return new shutdown_argsStandardScheme(); + } + } + + private static class shutdown_argsStandardScheme extends StandardScheme<shutdown_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, shutdown_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, shutdown_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class shutdown_argsTupleSchemeFactory implements SchemeFactory { + public shutdown_argsTupleScheme getScheme() { + return new shutdown_argsTupleScheme(); + } + } + + private static class shutdown_argsTupleScheme extends TupleScheme<shutdown_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, shutdown_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, shutdown_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + + } + + public static class shutdown_result implements org.apache.thrift.TBase<shutdown_result, shutdown_result._Fields>, java.io.Serializable, Cloneable, Comparable<shutdown_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("shutdown_result"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new shutdown_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new shutdown_resultTupleSchemeFactory()); + } + + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { +; + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(shutdown_result.class, metaDataMap); + } + + public shutdown_result() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public shutdown_result(shutdown_result other) { + } + + public shutdown_result deepCopy() { + return new shutdown_result(this); + } + + @Override + public void clear() { + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + } + throw new 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 IllegalArgumentException(); + } + + switch (field) { + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof shutdown_result) + return this.equals((shutdown_result)that); + return false; + } + + public boolean equals(shutdown_result that) { + if (that == null) + return false; + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + return list.hashCode(); + } + + @Override + public int compareTo(shutdown_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("shutdown_result("); + boolean first = true; + + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.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.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class shutdown_resultStandardSchemeFactory implements SchemeFactory { + public shutdown_resultStandardScheme getScheme() { + return new shutdown_resultStandardScheme(); + } + } + + private static class shutdown_resultStandardScheme extends StandardScheme<shutdown_result> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, shutdown_result struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, shutdown_result struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class shutdown_resultTupleSchemeFactory implements SchemeFactory { + public shutdown_resultTupleScheme getScheme() { + return new shutdown_resultTupleScheme(); + } + } + + private static class shutdown_resultTupleScheme extends TupleScheme<shutdown_result> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, shutdown_result struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, shutdown_result struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + + } + + public static class getStatus_args implements org.apache.thrift.TBase<getStatus_args, getStatus_args._Fields>, java.io.Serializable, Cloneable, Comparable<getStatus_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getStatus_args"); + + private static final org.apache.thrift.protocol.TField JOB_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("jobId", org.apache.thrift.protocol.TType.STRING, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new getStatus_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getStatus_argsTupleSchemeFactory()); + } + + public String jobId; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + JOB_ID((short)1, "jobId"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // JOB_ID + return JOB_ID; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.JOB_ID, new org.apache.thrift.meta_data.FieldMetaData("jobId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getStatus_args.class, metaDataMap); + } + + public getStatus_args() { + } + + public getStatus_args( + String jobId) + { + this(); + this.jobId = jobId; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public getStatus_args(getStatus_args other) { + if (other.isSetJobId()) { + this.jobId = other.jobId; + } + } + + public getStatus_args deepCopy() { + return new getStatus_args(this); + } + + @Override + public void clear() { + this.jobId = null; + } + + public String getJobId() { + return this.jobId; + } + + public getStatus_args setJobId(String jobId) { + this.jobId = jobId; + return this; + } + + public void unsetJobId() { + this.jobId = null; + } + + /** Returns true if field jobId is set (has been assigned a value) and false otherwise */ + public boolean isSetJobId() { + return this.jobId != null; + } + + public void setJobIdIsSet(boolean value) { + if (!value) { + this.jobId = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case JOB_ID: + if (value == null) { + unsetJobId(); + } else { + setJobId((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case JOB_ID: + return getJobId(); + + } + throw new 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 IllegalArgumentException(); + } + + switch (field) { + case JOB_ID: + return isSetJobId(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof getStatus_args) + return this.equals((getStatus_args)that); + return false; + } + + public boolean equals(getStatus_args that) { + if (that == null) + return false; + + boolean this_present_jobId = true && this.isSetJobId(); + boolean that_present_jobId = true && that.isSetJobId(); + if (this_present_jobId || that_present_jobId) { + if (!(this_present_jobId && that_present_jobId)) + return false; + if (!this.jobId.equals(that.jobId)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_jobId = true && (isSetJobId()); + list.add(present_jobId); + if (present_jobId) + list.add(jobId); + + return list.hashCode(); + } + + @Override + public int compareTo(getStatus_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetJobId()).compareTo(other.isSetJobId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetJobId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobId, other.jobId); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("getStatus_args("); + boolean first = true; + + sb.append("jobId:"); + if (this.jobId == null) { + sb.append("null"); + } else { + sb.append(this.jobId); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.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.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class getStatus_argsStandardSchemeFactory implements SchemeFactory { + public getStatus_argsStandardScheme getScheme() { + return new getStatus_argsStandardScheme(); + } + } + + private static class getStatus_argsStandardScheme extends StandardScheme<getStatus_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, getStatus_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // JOB_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.jobId = iprot.readString(); + struct.setJobIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, getStatus_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.jobId != null) { + oprot.writeFieldBegin(JOB_ID_FIELD_DESC); + oprot.writeString(struct.jobId); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class getStatus_argsTupleSchemeFactory implements SchemeFactory { + public getStatus_argsTupleScheme getScheme() { + return new getStatus_argsTupleScheme(); + } + } + + private static class getStatus_argsTupleScheme extends TupleScheme<getStatus_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, getStatus_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetJobId()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetJobId()) { + oprot.writeString(struct.jobId); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, getStatus_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.jobId = iprot.readString(); + struct.setJobIdIsSet(true); + } + } + } + + } + + public static class getStatus_result implements org.apache.thrift.TBase<getStatus_result, getStatus_result._Fields>, java.io.Serializable, Cloneable, Comparable<getStatus_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getStatus_result"); + + private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new getStatus_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getStatus_resultTupleSchemeFactory()); + } + + public String success; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + SUCCESS((short)0, "success"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 0: // SUCCESS + return SUCCESS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getStatus_result.class, metaDataMap); + } + + public getStatus_result() { + } + + public getStatus_result( + String success) + { + this(); + this.success = success; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public getStatus_result(getStatus_result other) { + if (other.isSetSuccess()) { + this.success = other.success; + } + } + + public getStatus_result deepCopy() { + return new getStatus_result(this); + } + + @Override + public void clear() { + this.success = null; + } + + public String getSuccess() { + return this.success; + } + + public getStatus_result setSuccess(String success) { + this.success = success; + return this; + } + + public void unsetSuccess() { + this.success = null; + } + + /** Returns true if field success is set (has been assigned a value) and false otherwise */ + public boolean isSetSuccess() { + return this.success != null; + } + + public void setSuccessIsSet(boolean value) { + if (!value) { + this.success = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SUCCESS: + return getSuccess(); + + } + throw new 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 IllegalArgumentException(); + } + + switch (field) { + case SUCCESS: + return isSetSuccess(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof getStatus_result) + return this.equals((getStatus_result)that); + return false; + } + + public boolean equals(getStatus_result that) { + if (that == null) + return false; + + boolean this_present_success = true && this.isSetSuccess(); + boolean that_present_success = true && that.isSetSuccess(); + if (this_present_success || that_present_success) { + if (!(this_present_success && that_present_success)) + return false; + if (!this.success.equals(that.success)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_success = true && (isSetSuccess()); + list.add(present_success); + if (present_success) + list.add(success); + + return list.hashCode(); + } + + @Override + public int compareTo(getStatus_result other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSuccess()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("getStatus_result("); + boolean first = true; + + sb.append("success:"); + if (this.success == null) { + sb.append("null"); + } else { + sb.append(this.success); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.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.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class getStatus_resultStandardSchemeFactory implements SchemeFactory { + public getStatus_resultStandardScheme getScheme() { + return new getStatus_resultStandardScheme(); + } + } + + private static class getStatus_resultStandardScheme extends StandardScheme<getStatus_result> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, getStatus_result struct) throws org.apache.thrift.TException { + org.apac
<TRUNCATED>
