http://git-wip-us.apache.org/repos/asf/zeppelin/blob/42bcf420/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 feaebcc..7b2a76e 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,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-29") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2017-1-25") public class RemoteInterpreterService { public interface Iface { @@ -82,12 +82,16 @@ public class RemoteInterpreterService { public void resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException; + public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object) throws org.apache.thrift.TException; + public List<String> resourcePoolGetAll() throws org.apache.thrift.TException; public ByteBuffer resourceGet(String sessionKey, String paragraphId, String resourceName) throws org.apache.thrift.TException; public boolean resourceRemove(String sessionKey, String paragraphId, String resourceName) throws org.apache.thrift.TException; + public ByteBuffer resourceInvokeMethod(String sessionKey, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException; + public void angularObjectUpdate(String name, String sessionKey, String paragraphId, String object) throws org.apache.thrift.TException; public void angularObjectAdd(String name, String sessionKey, String paragraphId, String object) throws org.apache.thrift.TException; @@ -134,12 +138,16 @@ public class RemoteInterpreterService { public void resourceResponseGet(String resourceId, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void resourceGet(String sessionKey, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void resourceRemove(String sessionKey, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void resourceInvokeMethod(String sessionKey, String paragraphId, String resourceName, String invokeMessage, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void angularObjectUpdate(String name, String sessionKey, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void angularObjectAdd(String name, String sessionKey, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -473,6 +481,27 @@ public class RemoteInterpreterService { return; } + public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object) throws org.apache.thrift.TException + { + send_resourceResponseInvokeMethod(invokeMessage, object); + recv_resourceResponseInvokeMethod(); + } + + public void send_resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object) throws org.apache.thrift.TException + { + resourceResponseInvokeMethod_args args = new resourceResponseInvokeMethod_args(); + args.setInvokeMessage(invokeMessage); + args.setObject(object); + sendBase("resourceResponseInvokeMethod", args); + } + + public void recv_resourceResponseInvokeMethod() throws org.apache.thrift.TException + { + resourceResponseInvokeMethod_result result = new resourceResponseInvokeMethod_result(); + receiveBase(result, "resourceResponseInvokeMethod"); + return; + } + public List<String> resourcePoolGetAll() throws org.apache.thrift.TException { send_resourcePoolGetAll(); @@ -545,6 +574,32 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceRemove failed: unknown result"); } + public ByteBuffer resourceInvokeMethod(String sessionKey, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException + { + send_resourceInvokeMethod(sessionKey, paragraphId, resourceName, invokeMessage); + return recv_resourceInvokeMethod(); + } + + public void send_resourceInvokeMethod(String sessionKey, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException + { + resourceInvokeMethod_args args = new resourceInvokeMethod_args(); + args.setSessionKey(sessionKey); + args.setParagraphId(paragraphId); + args.setResourceName(resourceName); + args.setInvokeMessage(invokeMessage); + sendBase("resourceInvokeMethod", args); + } + + public ByteBuffer recv_resourceInvokeMethod() throws org.apache.thrift.TException + { + resourceInvokeMethod_result result = new resourceInvokeMethod_result(); + receiveBase(result, "resourceInvokeMethod"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceInvokeMethod failed: unknown result"); + } + public void angularObjectUpdate(String name, String sessionKey, String paragraphId, String object) throws org.apache.thrift.TException { send_angularObjectUpdate(name, sessionKey, paragraphId, object); @@ -1210,6 +1265,41 @@ public class RemoteInterpreterService { } } + public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + resourceResponseInvokeMethod_call method_call = new resourceResponseInvokeMethod_call(invokeMessage, object, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class resourceResponseInvokeMethod_call extends org.apache.thrift.async.TAsyncMethodCall { + private String invokeMessage; + private ByteBuffer object; + public resourceResponseInvokeMethod_call(String invokeMessage, 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.invokeMessage = invokeMessage; + 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("resourceResponseInvokeMethod", org.apache.thrift.protocol.TMessageType.CALL, 0)); + resourceResponseInvokeMethod_args args = new resourceResponseInvokeMethod_args(); + args.setInvokeMessage(invokeMessage); + 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_resourceResponseInvokeMethod(); + } + } + public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); resourcePoolGetAll_call method_call = new resourcePoolGetAll_call(resultHandler, this, ___protocolFactory, ___transport); @@ -1315,6 +1405,47 @@ public class RemoteInterpreterService { } } + public void resourceInvokeMethod(String sessionKey, String paragraphId, String resourceName, String invokeMessage, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + resourceInvokeMethod_call method_call = new resourceInvokeMethod_call(sessionKey, paragraphId, resourceName, invokeMessage, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class resourceInvokeMethod_call extends org.apache.thrift.async.TAsyncMethodCall { + private String sessionKey; + private String paragraphId; + private String resourceName; + private String invokeMessage; + public resourceInvokeMethod_call(String sessionKey, String paragraphId, String resourceName, String invokeMessage, 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.sessionKey = sessionKey; + this.paragraphId = paragraphId; + this.resourceName = resourceName; + this.invokeMessage = invokeMessage; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceInvokeMethod", org.apache.thrift.protocol.TMessageType.CALL, 0)); + resourceInvokeMethod_args args = new resourceInvokeMethod_args(); + args.setSessionKey(sessionKey); + args.setParagraphId(paragraphId); + args.setResourceName(resourceName); + args.setInvokeMessage(invokeMessage); + 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_resourceInvokeMethod(); + } + } + public void angularObjectUpdate(String name, String sessionKey, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); angularObjectUpdate_call method_call = new angularObjectUpdate_call(name, sessionKey, paragraphId, object, resultHandler, this, ___protocolFactory, ___transport); @@ -1630,9 +1761,11 @@ public class RemoteInterpreterService { processMap.put("getEvent", new getEvent()); processMap.put("resourcePoolResponseGetAll", new resourcePoolResponseGetAll()); processMap.put("resourceResponseGet", new resourceResponseGet()); + processMap.put("resourceResponseInvokeMethod", new resourceResponseInvokeMethod()); processMap.put("resourcePoolGetAll", new resourcePoolGetAll()); processMap.put("resourceGet", new resourceGet()); processMap.put("resourceRemove", new resourceRemove()); + processMap.put("resourceInvokeMethod", new resourceInvokeMethod()); processMap.put("angularObjectUpdate", new angularObjectUpdate()); processMap.put("angularObjectAdd", new angularObjectAdd()); processMap.put("angularObjectRemove", new angularObjectRemove()); @@ -1905,6 +2038,26 @@ public class RemoteInterpreterService { } } + public static class resourceResponseInvokeMethod<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resourceResponseInvokeMethod_args> { + public resourceResponseInvokeMethod() { + super("resourceResponseInvokeMethod"); + } + + public resourceResponseInvokeMethod_args getEmptyArgsInstance() { + return new resourceResponseInvokeMethod_args(); + } + + protected boolean isOneway() { + return false; + } + + public resourceResponseInvokeMethod_result getResult(I iface, resourceResponseInvokeMethod_args args) throws org.apache.thrift.TException { + resourceResponseInvokeMethod_result result = new resourceResponseInvokeMethod_result(); + iface.resourceResponseInvokeMethod(args.invokeMessage, args.object); + return result; + } + } + public static class resourcePoolGetAll<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resourcePoolGetAll_args> { public resourcePoolGetAll() { super("resourcePoolGetAll"); @@ -1966,6 +2119,26 @@ public class RemoteInterpreterService { } } + public static class resourceInvokeMethod<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resourceInvokeMethod_args> { + public resourceInvokeMethod() { + super("resourceInvokeMethod"); + } + + public resourceInvokeMethod_args getEmptyArgsInstance() { + return new resourceInvokeMethod_args(); + } + + protected boolean isOneway() { + return false; + } + + public resourceInvokeMethod_result getResult(I iface, resourceInvokeMethod_args args) throws org.apache.thrift.TException { + resourceInvokeMethod_result result = new resourceInvokeMethod_result(); + result.success = iface.resourceInvokeMethod(args.sessionKey, args.paragraphId, args.resourceName, args.invokeMessage); + return result; + } + } + public static class angularObjectUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, angularObjectUpdate_args> { public angularObjectUpdate() { super("angularObjectUpdate"); @@ -2152,9 +2325,11 @@ public class RemoteInterpreterService { processMap.put("getEvent", new getEvent()); processMap.put("resourcePoolResponseGetAll", new resourcePoolResponseGetAll()); processMap.put("resourceResponseGet", new resourceResponseGet()); + processMap.put("resourceResponseInvokeMethod", new resourceResponseInvokeMethod()); processMap.put("resourcePoolGetAll", new resourcePoolGetAll()); processMap.put("resourceGet", new resourceGet()); processMap.put("resourceRemove", new resourceRemove()); + processMap.put("resourceInvokeMethod", new resourceInvokeMethod()); processMap.put("angularObjectUpdate", new angularObjectUpdate()); processMap.put("angularObjectAdd", new angularObjectAdd()); processMap.put("angularObjectRemove", new angularObjectRemove()); @@ -2823,6 +2998,56 @@ public class RemoteInterpreterService { } } + public static class resourceResponseInvokeMethod<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resourceResponseInvokeMethod_args, Void> { + public resourceResponseInvokeMethod() { + super("resourceResponseInvokeMethod"); + } + + public resourceResponseInvokeMethod_args getEmptyArgsInstance() { + return new resourceResponseInvokeMethod_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) { + resourceResponseInvokeMethod_result result = new resourceResponseInvokeMethod_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; + resourceResponseInvokeMethod_result result = new resourceResponseInvokeMethod_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, resourceResponseInvokeMethod_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.resourceResponseInvokeMethod(args.invokeMessage, args.object,resultHandler); + } + } + public static class resourcePoolGetAll<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resourcePoolGetAll_args, List<String>> { public resourcePoolGetAll() { super("resourcePoolGetAll"); @@ -2977,6 +3202,57 @@ public class RemoteInterpreterService { } } + public static class resourceInvokeMethod<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resourceInvokeMethod_args, ByteBuffer> { + public resourceInvokeMethod() { + super("resourceInvokeMethod"); + } + + public resourceInvokeMethod_args getEmptyArgsInstance() { + return new resourceInvokeMethod_args(); + } + + 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) { + resourceInvokeMethod_result result = new resourceInvokeMethod_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; + resourceInvokeMethod_result result = new resourceInvokeMethod_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, resourceInvokeMethod_args args, org.apache.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws TException { + iface.resourceInvokeMethod(args.sessionKey, args.paragraphId, args.resourceName, args.invokeMessage,resultHandler); + } + } + public static class angularObjectUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, angularObjectUpdate_args, Void> { public angularObjectUpdate() { super("angularObjectUpdate"); @@ -13934,20 +14210,25 @@ public class RemoteInterpreterService { } - public static class resourcePoolGetAll_args implements org.apache.thrift.TBase<resourcePoolGetAll_args, resourcePoolGetAll_args._Fields>, java.io.Serializable, Cloneable, Comparable<resourcePoolGetAll_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("resourcePoolGetAll_args"); + public static class resourceResponseInvokeMethod_args implements org.apache.thrift.TBase<resourceResponseInvokeMethod_args, resourceResponseInvokeMethod_args._Fields>, java.io.Serializable, Cloneable, Comparable<resourceResponseInvokeMethod_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("resourceResponseInvokeMethod_args"); + private static final org.apache.thrift.protocol.TField INVOKE_MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("invokeMessage", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField OBJECT_FIELD_DESC = new org.apache.thrift.protocol.TField("object", org.apache.thrift.protocol.TType.STRING, (short)2); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new resourcePoolGetAll_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new resourcePoolGetAll_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new resourceResponseInvokeMethod_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new resourceResponseInvokeMethod_argsTupleSchemeFactory()); } + public String invokeMessage; // required + public ByteBuffer object; // 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 { -; + INVOKE_MESSAGE((short)1, "invokeMessage"), + OBJECT((short)2, "object"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -13962,6 +14243,10 @@ public class RemoteInterpreterService { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { + case 1: // INVOKE_MESSAGE + return INVOKE_MESSAGE; + case 2: // OBJECT + return OBJECT; default: return null; } @@ -14000,83 +14285,1684 @@ public class RemoteInterpreterService { 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.INVOKE_MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("invokeMessage", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.OBJECT, new org.apache.thrift.meta_data.FieldMetaData("object", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(resourcePoolGetAll_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(resourceResponseInvokeMethod_args.class, metaDataMap); } - public resourcePoolGetAll_args() { + public resourceResponseInvokeMethod_args() { + } + + public resourceResponseInvokeMethod_args( + String invokeMessage, + ByteBuffer object) + { + this(); + this.invokeMessage = invokeMessage; + this.object = org.apache.thrift.TBaseHelper.copyBinary(object); } /** * Performs a deep copy on <i>other</i>. */ - public resourcePoolGetAll_args(resourcePoolGetAll_args other) { + public resourceResponseInvokeMethod_args(resourceResponseInvokeMethod_args other) { + if (other.isSetInvokeMessage()) { + this.invokeMessage = other.invokeMessage; + } + if (other.isSetObject()) { + this.object = org.apache.thrift.TBaseHelper.copyBinary(other.object); + } } - public resourcePoolGetAll_args deepCopy() { - return new resourcePoolGetAll_args(this); + public resourceResponseInvokeMethod_args deepCopy() { + return new resourceResponseInvokeMethod_args(this); } @Override public void clear() { + this.invokeMessage = null; + this.object = null; } - public void setFieldValue(_Fields field, Object value) { - switch (field) { - } + public String getInvokeMessage() { + return this.invokeMessage; } - public Object getFieldValue(_Fields field) { - switch (field) { - } - throw new IllegalStateException(); + public resourceResponseInvokeMethod_args setInvokeMessage(String invokeMessage) { + this.invokeMessage = invokeMessage; + return this; } - /** 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(); + public void unsetInvokeMessage() { + this.invokeMessage = null; } - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof resourcePoolGetAll_args) - return this.equals((resourcePoolGetAll_args)that); - return false; + /** Returns true if field invokeMessage is set (has been assigned a value) and false otherwise */ + public boolean isSetInvokeMessage() { + return this.invokeMessage != null; } - public boolean equals(resourcePoolGetAll_args that) { - if (that == null) - return false; - - return true; + public void setInvokeMessageIsSet(boolean value) { + if (!value) { + this.invokeMessage = null; + } } - @Override + public byte[] getObject() { + setObject(org.apache.thrift.TBaseHelper.rightSize(object)); + return object == null ? null : object.array(); + } + + public ByteBuffer bufferForObject() { + return org.apache.thrift.TBaseHelper.copyBinary(object); + } + + public resourceResponseInvokeMethod_args setObject(byte[] object) { + this.object = object == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(object, object.length)); + return this; + } + + public resourceResponseInvokeMethod_args setObject(ByteBuffer object) { + this.object = org.apache.thrift.TBaseHelper.copyBinary(object); + return this; + } + + public void unsetObject() { + this.object = null; + } + + /** Returns true if field object is set (has been assigned a value) and false otherwise */ + public boolean isSetObject() { + return this.object != null; + } + + public void setObjectIsSet(boolean value) { + if (!value) { + this.object = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case INVOKE_MESSAGE: + if (value == null) { + unsetInvokeMessage(); + } else { + setInvokeMessage((String)value); + } + break; + + case OBJECT: + if (value == null) { + unsetObject(); + } else { + setObject((ByteBuffer)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case INVOKE_MESSAGE: + return getInvokeMessage(); + + case OBJECT: + return getObject(); + + } + 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 INVOKE_MESSAGE: + return isSetInvokeMessage(); + case OBJECT: + return isSetObject(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof resourceResponseInvokeMethod_args) + return this.equals((resourceResponseInvokeMethod_args)that); + return false; + } + + public boolean equals(resourceResponseInvokeMethod_args that) { + if (that == null) + return false; + + boolean this_present_invokeMessage = true && this.isSetInvokeMessage(); + boolean that_present_invokeMessage = true && that.isSetInvokeMessage(); + if (this_present_invokeMessage || that_present_invokeMessage) { + if (!(this_present_invokeMessage && that_present_invokeMessage)) + return false; + if (!this.invokeMessage.equals(that.invokeMessage)) + return false; + } + + boolean this_present_object = true && this.isSetObject(); + boolean that_present_object = true && that.isSetObject(); + if (this_present_object || that_present_object) { + if (!(this_present_object && that_present_object)) + return false; + if (!this.object.equals(that.object)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_invokeMessage = true && (isSetInvokeMessage()); + list.add(present_invokeMessage); + if (present_invokeMessage) + list.add(invokeMessage); + + boolean present_object = true && (isSetObject()); + list.add(present_object); + if (present_object) + list.add(object); + + return list.hashCode(); + } + + @Override + public int compareTo(resourceResponseInvokeMethod_args other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetInvokeMessage()).compareTo(other.isSetInvokeMessage()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetInvokeMessage()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.invokeMessage, other.invokeMessage); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetObject()).compareTo(other.isSetObject()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetObject()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.object, other.object); + 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("resourceResponseInvokeMethod_args("); + boolean first = true; + + sb.append("invokeMessage:"); + if (this.invokeMessage == null) { + sb.append("null"); + } else { + sb.append(this.invokeMessage); + } + first = false; + if (!first) sb.append(", "); + sb.append("object:"); + if (this.object == null) { + sb.append("null"); + } else { + org.apache.thrift.TBaseHelper.toString(this.object, sb); + } + 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 resourceResponseInvokeMethod_argsStandardSchemeFactory implements SchemeFactory { + public resourceResponseInvokeMethod_argsStandardScheme getScheme() { + return new resourceResponseInvokeMethod_argsStandardScheme(); + } + } + + private static class resourceResponseInvokeMethod_argsStandardScheme extends StandardScheme<resourceResponseInvokeMethod_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, resourceResponseInvokeMethod_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: // INVOKE_MESSAGE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.invokeMessage = iprot.readString(); + struct.setInvokeMessageIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // OBJECT + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.object = iprot.readBinary(); + struct.setObjectIsSet(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, resourceResponseInvokeMethod_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.invokeMessage != null) { + oprot.writeFieldBegin(INVOKE_MESSAGE_FIELD_DESC); + oprot.writeString(struct.invokeMessage); + oprot.writeFieldEnd(); + } + if (struct.object != null) { + oprot.writeFieldBegin(OBJECT_FIELD_DESC); + oprot.writeBinary(struct.object); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class resourceResponseInvokeMethod_argsTupleSchemeFactory implements SchemeFactory { + public resourceResponseInvokeMethod_argsTupleScheme getScheme() { + return new resourceResponseInvokeMethod_argsTupleScheme(); + } + } + + private static class resourceResponseInvokeMethod_argsTupleScheme extends TupleScheme<resourceResponseInvokeMethod_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, resourceResponseInvokeMethod_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetInvokeMessage()) { + optionals.set(0); + } + if (struct.isSetObject()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetInvokeMessage()) { + oprot.writeString(struct.invokeMessage); + } + if (struct.isSetObject()) { + oprot.writeBinary(struct.object); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, resourceResponseInvokeMethod_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.invokeMessage = iprot.readString(); + struct.setInvokeMessageIsSet(true); + } + if (incoming.get(1)) { + struct.object = iprot.readBinary(); + struct.setObjectIsSet(true); + } + } + } + + } + + public static class resourceResponseInvokeMethod_result implements org.apache.thrift.TBase<resourceResponseInvokeMethod_result, resourceResponseInvokeMethod_result._Fields>, java.io.Serializable, Cloneable, Comparable<resourceResponseInvokeMethod_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("resourceResponseInvokeMethod_result"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new resourceResponseInvokeMethod_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new resourceResponseInvokeMethod_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(resourceResponseInvokeMethod_result.class, metaDataMap); + } + + public resourceResponseInvokeMethod_result() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public resourceResponseInvokeMethod_result(resourceResponseInvokeMethod_result other) { + } + + public resourceResponseInvokeMethod_result deepCopy() { + return new resourceResponseInvokeMethod_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 resourceResponseInvokeMethod_result) + return this.equals((resourceResponseInvokeMethod_result)that); + return false; + } + + public boolean equals(resourceResponseInvokeMethod_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(resourceResponseInvokeMethod_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("resourceResponseInvokeMethod_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 resourceResponseInvokeMethod_resultStandardSchemeFactory implements SchemeFactory { + public resourceResponseInvokeMethod_resultStandardScheme getScheme() { + return new resourceResponseInvokeMethod_resultStandardScheme(); + } + } + + private static class resourceResponseInvokeMethod_resultStandardScheme extends StandardScheme<resourceResponseInvokeMethod_result> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, resourceResponseInvokeMethod_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, resourceResponseInvokeMethod_result struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class resourceResponseInvokeMethod_resultTupleSchemeFactory implements SchemeFactory { + public resourceResponseInvokeMethod_resultTupleScheme getScheme() { + return new resourceResponseInvokeMethod_resultTupleScheme(); + } + } + + private static class resourceResponseInvokeMethod_resultTupleScheme extends TupleScheme<resourceResponseInvokeMethod_result> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, resourceResponseInvokeMethod_result struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, resourceResponseInvokeMethod_result struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + + } + + public static class resourcePoolGetAll_args implements org.apache.thrift.TBase<resourcePoolGetAll_args, resourcePoolGetAll_args._Fields>, java.io.Serializable, Cloneable, Comparable<resourcePoolGetAll_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("resourcePoolGetAll_args"); + + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new resourcePoolGetAll_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new resourcePoolGetAll_argsTupleSchemeFactory()); + } + + + /** 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(resourcePoolGetAll_args.class, metaDataMap); + } + + public resourcePoolGetAll_args() { + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public resourcePoolGetAll_args(resourcePoolGetAll_args other) { + } + + public resourcePoolGetAll_args deepCopy() { + return new resourcePoolGetAll_args(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 resourcePoolGetAll_args) + return this.equals((resourcePoolGetAll_args)that); + return false; + } + + public boolean equals(resourcePoolGetAll_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(resourcePoolGetAll_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("resourcePoolGetAll_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 resourcePoolGetAll_argsStandardSchemeFactory implements SchemeFactory { + public resourcePoolGetAll_argsStandardScheme getScheme() { + return new resourcePoolGetAll_argsStandardScheme(); + } + } + + private static class resourcePoolGetAll_argsStandardScheme extends StandardScheme<resourcePoolGetAll_args> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, resourcePoolGetAll_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, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class resourcePoolGetAll_argsTupleSchemeFactory implements SchemeFactory { + public resourcePoolGetAll_argsTupleScheme getScheme() { + return new resourcePoolGetAll_argsTupleScheme(); + } + } + + private static class resourcePoolGetAll_argsTupleScheme extends TupleScheme<resourcePoolGetAll_args> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + } + } + + } + + public static class resourcePoolGetAll_result implements org.apache.thrift.TBase<resourcePoolGetAll_result, resourcePoolGetAll_result._Fields>, java.io.Serializable, Cloneable, Comparable<resourcePoolGetAll_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("resourcePoolGetAll_result"); + + private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new resourcePoolGetAll_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new resourcePoolGetAll_resultTupleSchemeFactory()); + } + + public List<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.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(resourcePoolGetAll_result.class, metaDataMap); + } + + public resourcePoolGetAll_result() { + } + + public resourcePoolGetAll_result( + List<String> success) + { + this(); + this.success = success; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public resourcePoolGetAll_result(resourcePoolGetAll_result other) { + if (other.isSetSuccess()) { + List<String> __this__success = new ArrayList<String>(other.success); + this.success = __this__success; + } + } + + public resourcePoolGetAll_result deepCopy() { + return new resourcePoolGetAll_result(this); + } + + @Override + public void clear() { + this.success = null; + } + + public int getSuccessSize() { + return (this.success == null) ? 0 : this.success.size(); + } + + public java.util.Iterator<String> getSuccessIterator() { + return (this.success == null) ? null : this.success.iterator(); + } + + public void addToSuccess(String elem) { + if (this.success == null) { + this.success = new ArrayList<String>(); + } + this.success.add(elem); + } + + public List<String> getSuccess() { + return this.success; + } + + public resourcePoolGetAll_result setSuccess(List<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((List<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 resourcePoolGetAll_result) + return this.equals((resourcePoolGetAll_result)that); + return false; + } + + public boolean equals(resourcePoolGetAll_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(resourcePoolGetAll_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("resourcePoolGetAll_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 resourcePoolGetAll_resultStandardSchemeFactory implements SchemeFactory { + public resourcePoolGetAll_resultStandardScheme getScheme() { + return new resourcePoolGetAll_resultStandardScheme(); + } + } + + private static class resourcePoolGetAll_resultStandardScheme extends StandardScheme<resourcePoolGetAll_result> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, resourcePoolGetAll_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) { + case 0: // SUCCESS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list34 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list34.size); + String _elem35; + for (int _i36 = 0; _i36 < _list34.size; ++_i36) + { + _elem35 = iprot.readString(); + struct.success.add(_elem35); + } + iprot.readListEnd(); + } + struct.setSuccessIsSet(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, resourcePoolGetAll_result struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.success != null) { + oprot.writeFieldBegin(SUCCESS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size())); + for (String _iter37 : struct.success) + { + oprot.writeString(_iter37); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class resourcePoolGetAll_resultTupleSchemeFactory implements SchemeFactory { + public resourcePoolGetAll_resultTupleScheme getScheme() { + return new resourcePoolGetAll_resultTupleScheme(); + } + } + + private static class resourcePoolGetAll_resultTupleScheme extends TupleScheme<resourcePoolGetAll_result> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, resourcePoolGetAll_result struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSuccess()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetSuccess()) { + { + oprot.writeI32(struct.success.size()); + for (String _iter38 : struct.success) + { + oprot.writeString(_iter38); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, resourcePoolGetAll_result struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + { + org.apache.thrift.protocol.TList _list39 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.success = new ArrayList<String>(_list39.size); + String _elem40; + for (int _i41 = 0; _i41 < _list39.size; ++_i41) + { + _elem40 = iprot.readString(); + struct.success.add(_elem40); + } + } + struct.setSuccessIsSet(true); + } + } + } + + } + + public static class resourceGet_args implements org.apache.thrift.TBase<resourceGet_args, resourceGet_args._Fields>, java.io.Serializable, Cloneable, Comparable<resourceGet_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("resourceGet_args"); + + private static final org.apache.thrift.protocol.TField SESSION_KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("sessionKey", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField PARAGRAPH_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("paragraphId", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField RESOURCE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("resourceName", org.apache.thrift.protocol.TType.STRING, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new resourceGet_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new resourceGet_argsTupleSchemeFactory()); + } + + public String sessionKey; // required + public String paragraphId; // required + public String resourceName; // 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 { + SESSION_KEY((short)1, "sessionKey"), + PARAGRAPH_ID((short)2, "paragraphId"), + RESOURCE_NAME((short)3, "resourceName"); + + 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: // SESSION_KEY + return SESSION_KEY; + case 2: // PARAGRAPH_ID + return PARAGRAPH_ID; + case 3: // RESOURCE_NAME + return RESOURCE_NAME; + 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.SESSION_KEY, new org.apache.thrift.meta_data.FieldMetaData("sessionKey", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.PARAGRAPH_ID, new org.apache.thrift.meta_data.FieldMetaData("paragraphId", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.RESOURCE_NAME, new org.apache.thrift.meta_data.FieldMetaData("resourceName", 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(resourceGet_args.class, metaDataMap); + } + + public resourceGet_args() { + } + + public resourceGet_args( + String sessionKey, + String paragraphId, + String resourceName) + { + this(); + this.sessionKey = sessionKey; + this.paragraphId = paragraphId; + this.resourceName = resourceName; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public resourceGet_args(resourceGet_args other) { + if (other.isSetSessionKey()) { + this.sessionKey = other.sessionKey; + } + if (other.isSetParagraphId()) { + this.paragraphId = other.paragraphId; + } + if (other.isSetResourceName()) { + this.resourceName = other.resourceName; + } + } + + public resourceGet_args deepCopy() { + return new resourceGet_args(this); + } + + @Override + public void clear() { + this.sessionKey = null; + this.paragraphId = null; + this.resourceName = null; + } + + public String getSessionKey() { + return this.sessionKey; + } + + public resourceGet_args setSessionKey(String sessionKey) { + this.sessionKey = sessionKey; + return this; + } + + public void unsetSessionKey() { + this.sessionKey = null; + } + + /** Returns true if field sessionKey is set (has been assigned a value) and false otherwise */ + public boolean isSetSessionKey() { + return this.sessionKey != null; + } + + public void setSessionKeyIsSet(boolean value) { + if (!value) { + this.sessionKey = null; + } + } + + public String getParagraphId() { + return this.paragraphId; + } + + public resourceGet_args setParagraphId(String paragraphId) { + this.paragraphId = paragraphId; + return this; + } + + public void unsetParagraphId() { + this.paragraphId = null; + } + + /** Returns true if field paragraphId is set (has been assigned a value) and false otherwise */ + public boolean isSetParagraphId() { + return this.paragraphId != null; + } + + public void setParagraphIdIsSet(boolean value) { + if (!value) { + this.paragraphId = null; + } + } + + public String getResourceName() { + return this.resourceName; + } + + public resourceGet_args setResourceName(String resourceName) { + this.resourceName = resourceName; + return this; + } + + public void unsetResourceName() { + this.resourceName = null; + } + + /** Returns true if field resourceName is set (has been assigned a value) and false otherwise */ + public boolean isSetResourceName() { + return this.resourceName != null; + } + + public void setResourceNameIsSet(boolean value) { + if (!value) { + this.resourceName = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case SESSION_KEY: + if (value == null) { + unsetSessionKey(); + } else { + setSessionKey((String)value); + } + break; + + case PARAGRAPH_ID: + if (value == null) { + unsetParagraphId(); + } else { + setParagraphId((String)value); + } + break; + + case RESOURCE_NAME: + if (value == null) { + unsetResourceName(); + } else { + setResourceName((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case SESSION_KEY: + return getSessionKey(); + + case PARAGRAPH_ID: + return getParagraphId(); + + case RESOURCE_NAME: + return getResourceName(); + + } + 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 SESSION_KEY: + return isSetSessionKey(); + case PARAGRAPH_ID: + return isSetParagraphId(); + case RESOURCE_NAME: + return isSetResourceName(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof resourceGet_args) + return this.equals((resourceGet_args)that); + return false; + } + + public boolean equals(resourceGet_args that) { + if (that == null) + return false; + + boolean this_present_sessionKey = true && this.isSetSessionKey(); + boolean that_present_sessionKey = true && that.isSetSessionKey(); + if (this_present_sessionKey || that_present_sessionKey) { + if (!(this_present_sessionKey && that_present_sessionKey)) + return false; + if (!this.sessionKey.equals(that.sessionKey)) + return false; + } + + boolean this_present_paragraphId = true && this.isSetParagraphId(); + boolean that_present_paragraphId = true && that.isSetParagraphId(); + if (this_present_paragraphId || that_present_paragraphId) { + if (!(this_present_paragraphId && that_present_paragraphId)) + return false; + if (!this.paragraphId.equals(that.paragraphId)) + return false; + } + + boolean this_present_resourceName = true && this.isSetResourceName(); + boolean that_present_resourceName = true && that.isSetResourceName(); + if (this_present_resourceName || that_present_resourceName) { + if (!(this_present_resourceName && that_present_resourceName)) + return false; + if (!this.resourceName.equals(that.resourceName)) + return false; + } + + return true; + } + + @Override public int hashCode() { List<Object> list = new ArrayList<Object>(); + boolean present_sessionKey = true && (isSetSessionKey()); + list.add(present_sessionKey); + if (present_sessionKey) + list.add(sessionKey); + + boolean present_paragraphId = true && (isSetParagraphId()); + list.add(present_paragraphId); + if (present_paragraphId) + list.add(paragraphId); + + boolean present_resourceName = true && (isSetResourceName()); + list.add(present_resourceName); + if (present_resourceName) + list.add(resourceName); + return list.hashCode(); } @Override - public int compareTo(resourcePoolGetAll_args other) { + public int compareTo(resourceGet_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; + lastComparison = Boolean.valueOf(isSetSessionKey()).compareTo(other.isSetSessionKey()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSessionKey()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sessionKey, other.sessionKey); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetParagraphId()).compareTo(other.isSetParagraphId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetParagraphId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphId, other.paragraphId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetResourceName()).compareTo(other.isSetResourceName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetResourceName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resourceName, other.resourceName); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -14094,9 +15980,32 @@ public class RemoteInterpreterService { @Override public String toString() { - StringBuilder sb = new StringBuilder("resourcePoolGetAll_args("); + StringBuilder sb = new StringBuilder("resourceGet_args("); boolean first = true; + sb.append("sessionKey:"); + if (this.sessionKey == null) { + sb.append("null"); + } else { + sb.append(this.sessionKey); + } + first = false; + if (!first) sb.append(", "); + sb.append("paragraphId:"); + if (this.paragraphId == null) { + sb.append("null"); + } else { + sb.append(this.paragraphId); + } + first = false; + if (!first) sb.append(", "); + sb.append("resourceName:"); + if (this.resourceName == null) { + sb.append("null"); + } else { + sb.append(this.resourceName); + } + first = false; sb.append(")"); return sb.toString(); } @@ -14122,15 +16031,15 @@ public class RemoteInterpreterService { } } - private static class resourcePoolGetAll_argsStandardSchemeFactory implements SchemeFactory { - public resourcePoolGetAll_argsStandardScheme getScheme() { - return new resourcePoolGetAll_argsStandardScheme(); + private static class resourceGet_argsStandardSchemeFactory implements SchemeFactory { + public resourceGet_argsStandardScheme getScheme() { + return new resourceGet_argsStandardScheme(); } } - private static class resourcePoolGetAll_argsStandardScheme extends StandardScheme<resourcePoolGetAll_args> { + private static class resourceGet_argsStandardScheme extends StandardScheme<resourceGet_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, resourceGet_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -14140,6 +16049,30 @@ public class RemoteInterpreterService { break; } switch (schemeField.id) { + case 1: // SESSION_KEY + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.sessionKey = iprot.readString(); + struct.setSessionKeyIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // PARAGRAPH_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.paragraphId = iprot.readString(); + struct.setParagraphIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // RESOURCE_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.resourceName = iprot.readString(); + struct.setResourceNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -14151,49 +16084,97 @@ public class RemoteInterpreterService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, resourceGet_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.sessionKey != null) { + oprot.writeFieldBegin(SESSION_KEY_FIELD_DESC); + oprot.writeString(struct.sessionKey); + oprot.writeFieldEnd(); + } + if (struct.paragraphId != null) { + oprot.writeFieldBegin(PARAGRAPH_ID_FIELD_DESC); + oprot.writeString(struct.paragraphId); + oprot.writeFieldEnd(); + } + if (struct.resourceName != null) { + oprot.writeFieldBegin(RESOURCE_NAME_FIELD_DESC); + oprot.writeString(struct.resourceName); + oprot.writeFieldEnd(); + } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class resourcePoolGetAll_argsTupleSchemeFactory implements SchemeFactory { - public resourcePoolGetAll_argsTupleScheme getScheme() { - return new resourcePoolGetAll_argsTupleScheme(); + private static class resourceGet_argsTupleSchemeFactory implements SchemeFactory { + public resourceGet_argsTupleScheme getScheme() { + return new resourceGet_argsTupleScheme(); } } - private static class resourcePoolGetAll_argsTupleScheme extends TupleScheme<resourcePoolGetAll_args> { + private static class resourceGet_argsTupleScheme extends TupleScheme<resourceGet_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, resourceGet_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetSessionKey()) { + optionals.set(0); + } + if (struct.isSetParagraphId()) { + optionals.set(1); + } + if (struct.isSetResourceName()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetSessionKey()) { + oprot.writeString(struct.sessionKey); + } + if (struct.isSetParagraphId()) { + oprot.writeString(struct.paragraphId); + } + if (struct.isSetResourceName()) { + oprot.writeString(struct.resourceName); + } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, resourcePoolGetAll_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, resourceGet_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + struct.sessionKey = iprot.readString(); + struct.setSessionKeyIsSet(true); + } + if (incoming.get(1)) { + struct.paragraphId = iprot.readString(); + struct.setParagraphIdIsSet(true); + } + if (incoming.get(2)) { + struct.resourceName =
<TRUNCATED>