From 498ad4d83672230262817ddfdae152e197633202 Mon Sep 17 00:00:00 2001 From: caofangkun Date: Fri, 7 Aug 2015 10:49:53 +0800 Subject: [PATCH 1/3] ZEPPELIN-206: provide shell genthrift.sh to generate java code and auto insert license header --- .../thrift/RemoteInterpreterContext.java | 95 +- .../thrift/RemoteInterpreterEvent.java | 54 +- .../thrift/RemoteInterpreterEventType.java | 19 +- .../thrift/RemoteInterpreterResult.java | 77 +- .../thrift/RemoteInterpreterService.java | 1397 ++++++++++++++--- .../src/main/thrift/genthrift.sh | 28 + .../src/main/thrift/java_license_header.txt | 17 + 7 files changed, 1421 insertions(+), 266 deletions(-) create mode 100755 zeppelin-interpreter/src/main/thrift/genthrift.sh create mode 100644 zeppelin-interpreter/src/main/thrift/java_license_header.txt diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java index 7a757ab4f42..a55d5de5df9 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java @@ -1,5 +1,22 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -15,6 +32,8 @@ import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -27,10 +46,13 @@ import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class RemoteInterpreterContext implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-7") +public class RemoteInterpreterContext implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterContext"); private static final org.apache.thrift.protocol.TField NOTE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("noteId", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -579,83 +601,120 @@ public boolean equals(RemoteInterpreterContext that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_noteId = true && (isSetNoteId()); + list.add(present_noteId); + if (present_noteId) + list.add(noteId); + + boolean present_paragraphId = true && (isSetParagraphId()); + list.add(present_paragraphId); + if (present_paragraphId) + list.add(paragraphId); + + boolean present_paragraphTitle = true && (isSetParagraphTitle()); + list.add(present_paragraphTitle); + if (present_paragraphTitle) + list.add(paragraphTitle); + + boolean present_paragraphText = true && (isSetParagraphText()); + list.add(present_paragraphText); + if (present_paragraphText) + list.add(paragraphText); + + boolean present_config = true && (isSetConfig()); + list.add(present_config); + if (present_config) + list.add(config); + + boolean present_gui = true && (isSetGui()); + list.add(present_gui); + if (present_gui) + list.add(gui); + + boolean present_runners = true && (isSetRunners()); + list.add(present_runners); + if (present_runners) + list.add(runners); + + return list.hashCode(); } + @Override public int compareTo(RemoteInterpreterContext other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - RemoteInterpreterContext typedOther = (RemoteInterpreterContext)other; - lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(typedOther.isSetNoteId()); + lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(other.isSetNoteId()); if (lastComparison != 0) { return lastComparison; } if (isSetNoteId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, typedOther.noteId); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, other.noteId); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetParagraphId()).compareTo(typedOther.isSetParagraphId()); + lastComparison = Boolean.valueOf(isSetParagraphId()).compareTo(other.isSetParagraphId()); if (lastComparison != 0) { return lastComparison; } if (isSetParagraphId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphId, typedOther.paragraphId); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphId, other.paragraphId); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetParagraphTitle()).compareTo(typedOther.isSetParagraphTitle()); + lastComparison = Boolean.valueOf(isSetParagraphTitle()).compareTo(other.isSetParagraphTitle()); if (lastComparison != 0) { return lastComparison; } if (isSetParagraphTitle()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphTitle, typedOther.paragraphTitle); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphTitle, other.paragraphTitle); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetParagraphText()).compareTo(typedOther.isSetParagraphText()); + lastComparison = Boolean.valueOf(isSetParagraphText()).compareTo(other.isSetParagraphText()); if (lastComparison != 0) { return lastComparison; } if (isSetParagraphText()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphText, typedOther.paragraphText); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paragraphText, other.paragraphText); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetConfig()).compareTo(typedOther.isSetConfig()); + lastComparison = Boolean.valueOf(isSetConfig()).compareTo(other.isSetConfig()); if (lastComparison != 0) { return lastComparison; } if (isSetConfig()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.config, typedOther.config); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.config, other.config); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetGui()).compareTo(typedOther.isSetGui()); + lastComparison = Boolean.valueOf(isSetGui()).compareTo(other.isSetGui()); if (lastComparison != 0) { return lastComparison; } if (isSetGui()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gui, typedOther.gui); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gui, other.gui); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetRunners()).compareTo(typedOther.isSetRunners()); + lastComparison = Boolean.valueOf(isSetRunners()).compareTo(other.isSetRunners()); if (lastComparison != 0) { return lastComparison; } if (isSetRunners()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runners, typedOther.runners); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runners, other.runners); if (lastComparison != 0) { return lastComparison; } diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java index b44ea963166..96a49b512a4 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java @@ -1,5 +1,22 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -15,6 +32,8 @@ import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -27,10 +46,13 @@ import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class RemoteInterpreterEvent implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-7") +public class RemoteInterpreterEvent implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterEvent"); private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)1); @@ -300,33 +322,45 @@ public boolean equals(RemoteInterpreterEvent that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_type = true && (isSetType()); + list.add(present_type); + if (present_type) + list.add(type.getValue()); + + boolean present_data = true && (isSetData()); + list.add(present_data); + if (present_data) + list.add(data); + + return list.hashCode(); } + @Override public int compareTo(RemoteInterpreterEvent other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - RemoteInterpreterEvent typedOther = (RemoteInterpreterEvent)other; - lastComparison = Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType()); + lastComparison = Boolean.valueOf(isSetType()).compareTo(other.isSetType()); if (lastComparison != 0) { return lastComparison; } if (isSetType()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, typedOther.type); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetData()).compareTo(typedOther.isSetData()); + lastComparison = Boolean.valueOf(isSetData()).compareTo(other.isSetData()); if (lastComparison != 0) { return lastComparison; } if (isSetData()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.data, typedOther.data); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.data, other.data); if (lastComparison != 0) { return lastComparison; } @@ -411,7 +445,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, RemoteInterpreterEv switch (schemeField.id) { case 1: // TYPE if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.type = RemoteInterpreterEventType.findByValue(iprot.readI32()); + struct.type = org.apache.zeppelin.interpreter.thrift.RemoteInterpreterEventType.findByValue(iprot.readI32()); struct.setTypeIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -488,7 +522,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterEve TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { - struct.type = RemoteInterpreterEventType.findByValue(iprot.readI32()); + struct.type = org.apache.zeppelin.interpreter.thrift.RemoteInterpreterEventType.findByValue(iprot.readI32()); struct.setTypeIsSet(true); } if (incoming.get(1)) { diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventType.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventType.java index abbc68f364a..9a7d142b7bb 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventType.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventType.java @@ -1,5 +1,22 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResult.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResult.java index 5a68bd0b2c0..36c0f252eb9 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResult.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResult.java @@ -1,5 +1,22 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -15,6 +32,8 @@ import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -27,10 +46,13 @@ import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class RemoteInterpreterResult implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-7") +public class RemoteInterpreterResult implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterResult"); private static final org.apache.thrift.protocol.TField CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("code", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -461,63 +483,90 @@ public boolean equals(RemoteInterpreterResult that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_code = true && (isSetCode()); + list.add(present_code); + if (present_code) + list.add(code); + + boolean present_type = true && (isSetType()); + list.add(present_type); + if (present_type) + list.add(type); + + boolean present_msg = true && (isSetMsg()); + list.add(present_msg); + if (present_msg) + list.add(msg); + + boolean present_config = true && (isSetConfig()); + list.add(present_config); + if (present_config) + list.add(config); + + boolean present_gui = true && (isSetGui()); + list.add(present_gui); + if (present_gui) + list.add(gui); + + return list.hashCode(); } + @Override public int compareTo(RemoteInterpreterResult other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - RemoteInterpreterResult typedOther = (RemoteInterpreterResult)other; - lastComparison = Boolean.valueOf(isSetCode()).compareTo(typedOther.isSetCode()); + lastComparison = Boolean.valueOf(isSetCode()).compareTo(other.isSetCode()); if (lastComparison != 0) { return lastComparison; } if (isSetCode()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.code, typedOther.code); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.code, other.code); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType()); + lastComparison = Boolean.valueOf(isSetType()).compareTo(other.isSetType()); if (lastComparison != 0) { return lastComparison; } if (isSetType()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, typedOther.type); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetMsg()).compareTo(typedOther.isSetMsg()); + lastComparison = Boolean.valueOf(isSetMsg()).compareTo(other.isSetMsg()); if (lastComparison != 0) { return lastComparison; } if (isSetMsg()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, typedOther.msg); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetConfig()).compareTo(typedOther.isSetConfig()); + lastComparison = Boolean.valueOf(isSetConfig()).compareTo(other.isSetConfig()); if (lastComparison != 0) { return lastComparison; } if (isSetConfig()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.config, typedOther.config); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.config, other.config); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetGui()).compareTo(typedOther.isSetGui()); + lastComparison = Boolean.valueOf(isSetGui()).compareTo(other.isSetGui()); if (lastComparison != 0) { return lastComparison; } if (isSetGui()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gui, typedOther.gui); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gui, other.gui); if (lastComparison != 0) { return lastComparison; } 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 b9a8dae79e4..6e6730ea9be 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 @@ -1,5 +1,22 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -15,6 +32,8 @@ import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -27,9 +46,12 @@ import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-7") public class RemoteInterpreterService { public interface Iface { @@ -66,33 +88,33 @@ public interface Iface { public interface AsyncIface { - public void createInterpreter(String className, Map properties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void createInterpreter(String className, Map 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; + public void open(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void close(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void close(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void interpret(String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void interpret(String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void cancel(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void cancel(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getProgress(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getProgress(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getFormType(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getFormType(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void completion(String className, String buf, int cursor, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void completion(String className, String buf, int cursor, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getStatus(String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getStatus(String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void angularObjectUpdate(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void angularObjectUpdate(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void angularObjectAdd(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void angularObjectAdd(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void angularObjectRemove(String name, String noteId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void angularObjectRemove(String name, String noteId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; } @@ -442,7 +464,7 @@ public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, super(protocolFactory, clientManager, transport); } - public void createInterpreter(String className, Map properties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void createInterpreter(String className, Map 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); this.___currentMethod = method_call; @@ -452,7 +474,7 @@ public void createInterpreter(String className, Map properties, o public static class createInterpreter_call extends org.apache.thrift.async.TAsyncMethodCall { private String className; private Map properties; - public createInterpreter_call(String className, Map 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 className, Map 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.className = className; this.properties = properties; @@ -477,7 +499,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void open(String className, 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 { checkReady(); open_call method_call = new open_call(className, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -486,7 +508,7 @@ public void open(String className, 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 open_call(String className, 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.className = className; } @@ -509,7 +531,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void close(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void close(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); close_call method_call = new close_call(className, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -518,7 +540,7 @@ public void close(String className, org.apache.thrift.async.AsyncMethodCallback< public static class close_call extends org.apache.thrift.async.TAsyncMethodCall { private String className; - public close_call(String className, 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 close_call(String className, 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.className = className; } @@ -541,7 +563,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void interpret(String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void interpret(String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); interpret_call method_call = new interpret_call(className, st, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -552,7 +574,7 @@ public static class interpret_call extends org.apache.thrift.async.TAsyncMethodC private String className; private String st; private RemoteInterpreterContext interpreterContext; - public interpret_call(String className, String st, RemoteInterpreterContext interpreterContext, 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 interpret_call(String className, String st, RemoteInterpreterContext interpreterContext, 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.className = className; this.st = st; @@ -579,7 +601,7 @@ public RemoteInterpreterResult getResult() throws org.apache.thrift.TException { } } - public void cancel(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void cancel(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); cancel_call method_call = new cancel_call(className, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -589,7 +611,7 @@ public void cancel(String className, RemoteInterpreterContext interpreterContext public static class cancel_call extends org.apache.thrift.async.TAsyncMethodCall { private String className; private RemoteInterpreterContext interpreterContext; - public cancel_call(String className, RemoteInterpreterContext interpreterContext, 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 cancel_call(String className, RemoteInterpreterContext interpreterContext, 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.className = className; this.interpreterContext = interpreterContext; @@ -614,7 +636,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void getProgress(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getProgress(String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getProgress_call method_call = new getProgress_call(className, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -624,7 +646,7 @@ public void getProgress(String className, RemoteInterpreterContext interpreterCo public static class getProgress_call extends org.apache.thrift.async.TAsyncMethodCall { private String className; private RemoteInterpreterContext interpreterContext; - public getProgress_call(String className, RemoteInterpreterContext interpreterContext, 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 getProgress_call(String className, RemoteInterpreterContext interpreterContext, 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.className = className; this.interpreterContext = interpreterContext; @@ -649,7 +671,7 @@ public int getResult() throws org.apache.thrift.TException { } } - public void getFormType(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getFormType(String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getFormType_call method_call = new getFormType_call(className, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -658,7 +680,7 @@ public void getFormType(String className, org.apache.thrift.async.AsyncMethodCal public static class getFormType_call extends org.apache.thrift.async.TAsyncMethodCall { private String className; - public getFormType_call(String className, 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 getFormType_call(String className, 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.className = className; } @@ -681,7 +703,7 @@ public String getResult() throws org.apache.thrift.TException { } } - public void completion(String className, String buf, int cursor, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void completion(String className, String buf, int cursor, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); completion_call method_call = new completion_call(className, buf, cursor, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -692,7 +714,7 @@ public static class completion_call extends org.apache.thrift.async.TAsyncMethod private String className; private String buf; private int cursor; - public completion_call(String className, String buf, int cursor, 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 completion_call(String className, String buf, int cursor, 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.className = className; this.buf = buf; @@ -719,7 +741,7 @@ public List getResult() throws org.apache.thrift.TException { } } - public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); shutdown_call method_call = new shutdown_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -727,7 +749,7 @@ public void shutdown(org.apache.thrift.async.AsyncMethodCallback } public static class shutdown_call extends org.apache.thrift.async.TAsyncMethodCall { - public shutdown_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public shutdown_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); } @@ -748,7 +770,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void getStatus(String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getStatus(String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getStatus_call method_call = new getStatus_call(jobId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -757,7 +779,7 @@ public void getStatus(String jobId, org.apache.thrift.async.AsyncMethodCallback< public static class getStatus_call extends org.apache.thrift.async.TAsyncMethodCall { private String jobId; - public getStatus_call(String jobId, 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 getStatus_call(String jobId, 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.jobId = jobId; } @@ -780,7 +802,7 @@ public String getResult() throws org.apache.thrift.TException { } } - public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getEvent_call method_call = new getEvent_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -788,7 +810,7 @@ public void getEvent(org.apache.thrift.async.AsyncMethodCallback } public static class getEvent_call extends org.apache.thrift.async.TAsyncMethodCall { - public getEvent_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public getEvent_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); } @@ -809,7 +831,7 @@ public RemoteInterpreterEvent getResult() throws org.apache.thrift.TException { } } - public void angularObjectUpdate(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void angularObjectUpdate(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); angularObjectUpdate_call method_call = new angularObjectUpdate_call(name, noteId, object, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -820,7 +842,7 @@ public static class angularObjectUpdate_call extends org.apache.thrift.async.TAs private String name; private String noteId; private String object; - public angularObjectUpdate_call(String name, String noteId, String 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 { + public angularObjectUpdate_call(String name, String noteId, String 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.name = name; this.noteId = noteId; @@ -847,7 +869,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void angularObjectAdd(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void angularObjectAdd(String name, String noteId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); angularObjectAdd_call method_call = new angularObjectAdd_call(name, noteId, object, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -858,7 +880,7 @@ public static class angularObjectAdd_call extends org.apache.thrift.async.TAsync private String name; private String noteId; private String object; - public angularObjectAdd_call(String name, String noteId, String 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 { + public angularObjectAdd_call(String name, String noteId, String 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.name = name; this.noteId = noteId; @@ -885,7 +907,7 @@ public void getResult() throws org.apache.thrift.TException { } } - public void angularObjectRemove(String name, String noteId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void angularObjectRemove(String name, String noteId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); angularObjectRemove_call method_call = new angularObjectRemove_call(name, noteId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -895,7 +917,7 @@ public void angularObjectRemove(String name, String noteId, org.apache.thrift.as public static class angularObjectRemove_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; private String noteId; - public angularObjectRemove_call(String name, String noteId, 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 angularObjectRemove_call(String name, String noteId, 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.name = name; this.noteId = noteId; @@ -1233,7 +1255,744 @@ public angularObjectRemove_result getResult(I iface, angularObjectRemove_args ar } - public static class createInterpreter_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class AsyncProcessor extends org.apache.thrift.TBaseAsyncProcessor { + private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName()); + public AsyncProcessor(I iface) { + super(iface, getProcessMap(new HashMap>())); + } + + protected AsyncProcessor(I iface, Map> processMap) { + super(iface, getProcessMap(processMap)); + } + + private static Map> getProcessMap(Map> processMap) { + processMap.put("createInterpreter", new createInterpreter()); + processMap.put("open", new open()); + processMap.put("close", new close()); + processMap.put("interpret", new interpret()); + processMap.put("cancel", new cancel()); + processMap.put("getProgress", new getProgress()); + processMap.put("getFormType", new getFormType()); + processMap.put("completion", new completion()); + processMap.put("shutdown", new shutdown()); + processMap.put("getStatus", new getStatus()); + processMap.put("getEvent", new getEvent()); + processMap.put("angularObjectUpdate", new angularObjectUpdate()); + processMap.put("angularObjectAdd", new angularObjectAdd()); + processMap.put("angularObjectRemove", new angularObjectRemove()); + return processMap; + } + + public static class createInterpreter extends org.apache.thrift.AsyncProcessFunction { + public createInterpreter() { + super("createInterpreter"); + } + + public createInterpreter_args getEmptyArgsInstance() { + return new createInterpreter_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Void o) { + createInterpreter_result result = new createInterpreter_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; + createInterpreter_result result = new createInterpreter_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, createInterpreter_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.createInterpreter(args.className, args.properties,resultHandler); + } + } + + public static class open extends org.apache.thrift.AsyncProcessFunction { + public open() { + super("open"); + } + + public open_args getEmptyArgsInstance() { + return new open_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Void o) { + open_result result = new open_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; + open_result result = new open_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, open_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.open(args.className,resultHandler); + } + } + + public static class close extends org.apache.thrift.AsyncProcessFunction { + public close() { + super("close"); + } + + public close_args getEmptyArgsInstance() { + return new close_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Void o) { + close_result result = new close_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; + close_result result = new close_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, close_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.close(args.className,resultHandler); + } + } + + public static class interpret extends org.apache.thrift.AsyncProcessFunction { + public interpret() { + super("interpret"); + } + + public interpret_args getEmptyArgsInstance() { + return new interpret_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(RemoteInterpreterResult o) { + interpret_result result = new interpret_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; + interpret_result result = new interpret_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, interpret_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.interpret(args.className, args.st, args.interpreterContext,resultHandler); + } + } + + public static class cancel extends org.apache.thrift.AsyncProcessFunction { + public cancel() { + super("cancel"); + } + + public cancel_args getEmptyArgsInstance() { + return new cancel_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Void o) { + cancel_result result = new cancel_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; + cancel_result result = new cancel_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, cancel_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.cancel(args.className, args.interpreterContext,resultHandler); + } + } + + public static class getProgress extends org.apache.thrift.AsyncProcessFunction { + public getProgress() { + super("getProgress"); + } + + public getProgress_args getEmptyArgsInstance() { + return new getProgress_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Integer o) { + getProgress_result result = new getProgress_result(); + result.success = o; + result.setSuccessIsSet(true); + 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; + getProgress_result result = new getProgress_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, getProgress_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getProgress(args.className, args.interpreterContext,resultHandler); + } + } + + public static class getFormType extends org.apache.thrift.AsyncProcessFunction { + public getFormType() { + super("getFormType"); + } + + public getFormType_args getEmptyArgsInstance() { + return new getFormType_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(String o) { + getFormType_result result = new getFormType_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; + getFormType_result result = new getFormType_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, getFormType_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getFormType(args.className,resultHandler); + } + } + + public static class completion extends org.apache.thrift.AsyncProcessFunction> { + public completion() { + super("completion"); + } + + public completion_args getEmptyArgsInstance() { + return new completion_args(); + } + + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback>() { + public void onComplete(List o) { + completion_result result = new completion_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; + completion_result result = new completion_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, completion_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.completion(args.className, args.buf, args.cursor,resultHandler); + } + } + + public static class shutdown extends org.apache.thrift.AsyncProcessFunction { + public shutdown() { + super("shutdown"); + } + + public shutdown_args getEmptyArgsInstance() { + return new shutdown_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(Void o) { + shutdown_result result = new shutdown_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; + shutdown_result result = new shutdown_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, shutdown_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.shutdown(resultHandler); + } + } + + public static class getStatus extends org.apache.thrift.AsyncProcessFunction { + public getStatus() { + super("getStatus"); + } + + public getStatus_args getEmptyArgsInstance() { + return new getStatus_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(String o) { + getStatus_result result = new getStatus_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; + getStatus_result result = new getStatus_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, getStatus_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getStatus(args.jobId,resultHandler); + } + } + + public static class getEvent extends org.apache.thrift.AsyncProcessFunction { + public getEvent() { + super("getEvent"); + } + + public getEvent_args getEmptyArgsInstance() { + return new getEvent_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + public void onComplete(RemoteInterpreterEvent o) { + getEvent_result result = new getEvent_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; + getEvent_result result = new getEvent_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, getEvent_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getEvent(resultHandler); + } + } + + public static class angularObjectUpdate extends org.apache.thrift.AsyncProcessFunction { + public angularObjectUpdate() { + super("angularObjectUpdate"); + } + + public angularObjectUpdate_args getEmptyArgsInstance() { + return new angularObjectUpdate_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + 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 resultHandler) throws TException { + iface.angularObjectUpdate(args.name, args.noteId, args.object,resultHandler); + } + } + + public static class angularObjectAdd extends org.apache.thrift.AsyncProcessFunction { + public angularObjectAdd() { + super("angularObjectAdd"); + } + + public angularObjectAdd_args getEmptyArgsInstance() { + return new angularObjectAdd_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + 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 resultHandler) throws TException { + iface.angularObjectAdd(args.name, args.noteId, args.object,resultHandler); + } + } + + public static class angularObjectRemove extends org.apache.thrift.AsyncProcessFunction { + public angularObjectRemove() { + super("angularObjectRemove"); + } + + public angularObjectRemove_args getEmptyArgsInstance() { + return new angularObjectRemove_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + 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 resultHandler) throws TException { + iface.angularObjectRemove(args.name, args.noteId,resultHandler); + } + } + + } + + public static class createInterpreter_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { 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); @@ -1343,18 +2102,7 @@ public createInterpreter_args(createInterpreter_args other) { this.className = other.className; } if (other.isSetProperties()) { - Map __this__properties = new HashMap(); - for (Map.Entry other_element : other.properties.entrySet()) { - - String other_element_key = other_element.getKey(); - String other_element_value = other_element.getValue(); - - String __this__properties_copy_key = other_element_key; - - String __this__properties_copy_value = other_element_value; - - __this__properties.put(__this__properties_copy_key, __this__properties_copy_value); - } + Map __this__properties = new HashMap(other.properties); this.properties = __this__properties; } } @@ -1512,33 +2260,45 @@ public boolean equals(createInterpreter_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + boolean present_properties = true && (isSetProperties()); + list.add(present_properties); + if (present_properties) + list.add(properties); + + return list.hashCode(); } + @Override public int compareTo(createInterpreter_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - createInterpreter_args typedOther = (createInterpreter_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetProperties()).compareTo(typedOther.isSetProperties()); + lastComparison = Boolean.valueOf(isSetProperties()).compareTo(other.isSetProperties()); if (lastComparison != 0) { return lastComparison; } if (isSetProperties()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.properties, typedOther.properties); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.properties, other.properties); if (lastComparison != 0) { return lastComparison; } @@ -1634,13 +2394,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, createInterpreter_a { org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin(); struct.properties = new HashMap(2*_map0.size); - for (int _i1 = 0; _i1 < _map0.size; ++_i1) + String _key1; + String _val2; + for (int _i3 = 0; _i3 < _map0.size; ++_i3) { - String _key2; // required - String _val3; // required - _key2 = iprot.readString(); - _val3 = iprot.readString(); - struct.properties.put(_key2, _val3); + _key1 = iprot.readString(); + _val2 = iprot.readString(); + struct.properties.put(_key1, _val2); } iprot.readMapEnd(); } @@ -1734,13 +2494,13 @@ public void read(org.apache.thrift.protocol.TProtocol prot, createInterpreter_ar { 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(2*_map6.size); - for (int _i7 = 0; _i7 < _map6.size; ++_i7) + String _key7; + String _val8; + for (int _i9 = 0; _i9 < _map6.size; ++_i9) { - String _key8; // required - String _val9; // required - _key8 = iprot.readString(); - _val9 = iprot.readString(); - struct.properties.put(_key8, _val9); + _key7 = iprot.readString(); + _val8 = iprot.readString(); + struct.properties.put(_key7, _val8); } } struct.setPropertiesIsSet(true); @@ -1750,7 +2510,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, createInterpreter_ar } - public static class createInterpreter_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class createInterpreter_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("createInterpreter_result"); @@ -1880,16 +2640,18 @@ public boolean equals(createInterpreter_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(createInterpreter_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - createInterpreter_result typedOther = (createInterpreter_result)other; return 0; } @@ -1996,7 +2758,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, createInterpreter_re } - public static class open_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class open_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("open_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); @@ -2191,23 +2953,30 @@ public boolean equals(open_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + return list.hashCode(); } + @Override public int compareTo(open_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - open_args typedOther = (open_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } @@ -2350,7 +3119,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, open_args struct) th } - public static class open_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class open_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("open_result"); @@ -2480,16 +3249,18 @@ public boolean equals(open_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(open_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - open_result typedOther = (open_result)other; return 0; } @@ -2596,7 +3367,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, open_result struct) } - public static class close_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class close_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("close_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); @@ -2791,23 +3562,30 @@ public boolean equals(close_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + return list.hashCode(); } + @Override public int compareTo(close_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - close_args typedOther = (close_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } @@ -2950,7 +3728,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, close_args struct) t } - public static class close_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class close_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("close_result"); @@ -3080,16 +3858,18 @@ public boolean equals(close_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(close_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - close_result typedOther = (close_result)other; return 0; } @@ -3196,7 +3976,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, close_result struct) } - public static class interpret_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class interpret_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("interpret_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); @@ -3509,43 +4289,60 @@ public boolean equals(interpret_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + boolean present_st = true && (isSetSt()); + list.add(present_st); + if (present_st) + list.add(st); + + boolean present_interpreterContext = true && (isSetInterpreterContext()); + list.add(present_interpreterContext); + if (present_interpreterContext) + list.add(interpreterContext); + + return list.hashCode(); } + @Override public int compareTo(interpret_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - interpret_args typedOther = (interpret_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetSt()).compareTo(typedOther.isSetSt()); + lastComparison = Boolean.valueOf(isSetSt()).compareTo(other.isSetSt()); if (lastComparison != 0) { return lastComparison; } if (isSetSt()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.st, typedOther.st); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.st, other.st); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetInterpreterContext()).compareTo(typedOther.isSetInterpreterContext()); + lastComparison = Boolean.valueOf(isSetInterpreterContext()).compareTo(other.isSetInterpreterContext()); if (lastComparison != 0) { return lastComparison; } if (isSetInterpreterContext()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.interpreterContext, typedOther.interpreterContext); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.interpreterContext, other.interpreterContext); if (lastComparison != 0) { return lastComparison; } @@ -3755,7 +4552,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, interpret_args struc } - public static class interpret_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class interpret_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("interpret_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); @@ -3950,23 +4747,30 @@ public boolean equals(interpret_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_success = true && (isSetSuccess()); + list.add(present_success); + if (present_success) + list.add(success); + + return list.hashCode(); } + @Override public int compareTo(interpret_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - interpret_result typedOther = (interpret_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -4114,7 +4918,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, interpret_result str } - public static class cancel_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class cancel_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("cancel_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); @@ -4368,33 +5172,45 @@ public boolean equals(cancel_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + boolean present_interpreterContext = true && (isSetInterpreterContext()); + list.add(present_interpreterContext); + if (present_interpreterContext) + list.add(interpreterContext); + + return list.hashCode(); } + @Override public int compareTo(cancel_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - cancel_args typedOther = (cancel_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetInterpreterContext()).compareTo(typedOther.isSetInterpreterContext()); + lastComparison = Boolean.valueOf(isSetInterpreterContext()).compareTo(other.isSetInterpreterContext()); if (lastComparison != 0) { return lastComparison; } if (isSetInterpreterContext()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.interpreterContext, typedOther.interpreterContext); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.interpreterContext, other.interpreterContext); if (lastComparison != 0) { return lastComparison; } @@ -4573,7 +5389,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, cancel_args struct) } - public static class cancel_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class cancel_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("cancel_result"); @@ -4703,16 +5519,18 @@ public boolean equals(cancel_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(cancel_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - cancel_result typedOther = (cancel_result)other; return 0; } @@ -4819,7 +5637,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, cancel_result struct } - public static class getProgress_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getProgress_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getProgress_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); @@ -5073,33 +5891,45 @@ public boolean equals(getProgress_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + boolean present_interpreterContext = true && (isSetInterpreterContext()); + list.add(present_interpreterContext); + if (present_interpreterContext) + list.add(interpreterContext); + + return list.hashCode(); } + @Override public int compareTo(getProgress_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getProgress_args typedOther = (getProgress_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetInterpreterContext()).compareTo(typedOther.isSetInterpreterContext()); + lastComparison = Boolean.valueOf(isSetInterpreterContext()).compareTo(other.isSetInterpreterContext()); if (lastComparison != 0) { return lastComparison; } if (isSetInterpreterContext()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.interpreterContext, typedOther.interpreterContext); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.interpreterContext, other.interpreterContext); if (lastComparison != 0) { return lastComparison; } @@ -5278,7 +6108,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getProgress_args str } - public static class getProgress_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getProgress_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getProgress_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.I32, (short)0); @@ -5475,23 +6305,30 @@ public boolean equals(getProgress_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_success = true; + list.add(present_success); + if (present_success) + list.add(success); + + return list.hashCode(); } + @Override public int compareTo(getProgress_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getProgress_result typedOther = (getProgress_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -5632,7 +6469,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getProgress_result s } - public static class getFormType_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getFormType_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getFormType_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); @@ -5827,23 +6664,30 @@ public boolean equals(getFormType_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + return list.hashCode(); } + @Override public int compareTo(getFormType_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getFormType_args typedOther = (getFormType_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } @@ -5986,7 +6830,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getFormType_args str } - public static class getFormType_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getFormType_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getFormType_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); @@ -6181,23 +7025,30 @@ public boolean equals(getFormType_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_success = true && (isSetSuccess()); + list.add(present_success); + if (present_success) + list.add(success); + + return list.hashCode(); } + @Override public int compareTo(getFormType_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getFormType_result typedOther = (getFormType_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -6340,7 +7191,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getFormType_result s } - public static class completion_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class completion_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("completion_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); @@ -6655,43 +7506,60 @@ public boolean equals(completion_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_className = true && (isSetClassName()); + list.add(present_className); + if (present_className) + list.add(className); + + boolean present_buf = true && (isSetBuf()); + list.add(present_buf); + if (present_buf) + list.add(buf); + + boolean present_cursor = true; + list.add(present_cursor); + if (present_cursor) + list.add(cursor); + + return list.hashCode(); } + @Override public int compareTo(completion_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - completion_args typedOther = (completion_args)other; - lastComparison = Boolean.valueOf(isSetClassName()).compareTo(typedOther.isSetClassName()); + lastComparison = Boolean.valueOf(isSetClassName()).compareTo(other.isSetClassName()); if (lastComparison != 0) { return lastComparison; } if (isSetClassName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, typedOther.className); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.className, other.className); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetBuf()).compareTo(typedOther.isSetBuf()); + lastComparison = Boolean.valueOf(isSetBuf()).compareTo(other.isSetBuf()); if (lastComparison != 0) { return lastComparison; } if (isSetBuf()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.buf, typedOther.buf); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.buf, other.buf); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetCursor()).compareTo(typedOther.isSetCursor()); + lastComparison = Boolean.valueOf(isSetCursor()).compareTo(other.isSetCursor()); if (lastComparison != 0) { return lastComparison; } if (isSetCursor()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cursor, typedOther.cursor); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cursor, other.cursor); if (lastComparison != 0) { return lastComparison; } @@ -6892,7 +7760,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, completion_args stru } - public static class completion_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class completion_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("completion_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); @@ -6989,10 +7857,7 @@ public completion_result( */ public completion_result(completion_result other) { if (other.isSetSuccess()) { - List __this__success = new ArrayList(); - for (String other_element : other.success) { - __this__success.add(other_element); - } + List __this__success = new ArrayList(other.success); this.success = __this__success; } } @@ -7107,23 +7972,30 @@ public boolean equals(completion_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_success = true && (isSetSuccess()); + list.add(present_success); + if (present_success) + list.add(success); + + return list.hashCode(); } + @Override public int compareTo(completion_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - completion_result typedOther = (completion_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -7203,11 +8075,11 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, completion_result s { org.apache.thrift.protocol.TList _list10 = iprot.readListBegin(); struct.success = new ArrayList(_list10.size); - for (int _i11 = 0; _i11 < _list10.size; ++_i11) + String _elem11; + for (int _i12 = 0; _i12 < _list10.size; ++_i12) { - String _elem12; // required - _elem12 = iprot.readString(); - struct.success.add(_elem12); + _elem11 = iprot.readString(); + struct.success.add(_elem11); } iprot.readListEnd(); } @@ -7284,11 +8156,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, completion_result st { org.apache.thrift.protocol.TList _list15 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); struct.success = new ArrayList(_list15.size); - for (int _i16 = 0; _i16 < _list15.size; ++_i16) + String _elem16; + for (int _i17 = 0; _i17 < _list15.size; ++_i17) { - String _elem17; // required - _elem17 = iprot.readString(); - struct.success.add(_elem17); + _elem16 = iprot.readString(); + struct.success.add(_elem16); } } struct.setSuccessIsSet(true); @@ -7298,7 +8170,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, completion_result st } - public static class shutdown_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class shutdown_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("shutdown_args"); @@ -7428,16 +8300,18 @@ public boolean equals(shutdown_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + 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; - shutdown_args typedOther = (shutdown_args)other; return 0; } @@ -7544,7 +8418,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, shutdown_args struct } - public static class shutdown_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class shutdown_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("shutdown_result"); @@ -7674,16 +8548,18 @@ public boolean equals(shutdown_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + 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; - shutdown_result typedOther = (shutdown_result)other; return 0; } @@ -7790,7 +8666,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, shutdown_result stru } - public static class getStatus_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getStatus_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { 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); @@ -7985,23 +8861,30 @@ public boolean equals(getStatus_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + 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; - getStatus_args typedOther = (getStatus_args)other; - lastComparison = Boolean.valueOf(isSetJobId()).compareTo(typedOther.isSetJobId()); + lastComparison = Boolean.valueOf(isSetJobId()).compareTo(other.isSetJobId()); if (lastComparison != 0) { return lastComparison; } if (isSetJobId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobId, typedOther.jobId); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobId, other.jobId); if (lastComparison != 0) { return lastComparison; } @@ -8144,7 +9027,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getStatus_args struc } - public static class getStatus_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getStatus_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { 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); @@ -8339,23 +9222,30 @@ public boolean equals(getStatus_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + 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; - getStatus_result typedOther = (getStatus_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -8498,7 +9388,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getStatus_result str } - public static class getEvent_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getEvent_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getEvent_args"); @@ -8628,16 +9518,18 @@ public boolean equals(getEvent_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(getEvent_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getEvent_args typedOther = (getEvent_args)other; return 0; } @@ -8744,7 +9636,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getEvent_args struct } - public static class getEvent_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class getEvent_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getEvent_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); @@ -8939,23 +9831,30 @@ public boolean equals(getEvent_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_success = true && (isSetSuccess()); + list.add(present_success); + if (present_success) + list.add(success); + + return list.hashCode(); } + @Override public int compareTo(getEvent_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getEvent_result typedOther = (getEvent_result)other; - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); if (lastComparison != 0) { return lastComparison; } if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); if (lastComparison != 0) { return lastComparison; } @@ -9103,7 +10002,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getEvent_result stru } - public static class angularObjectUpdate_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class angularObjectUpdate_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("angularObjectUpdate_args"); private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -9416,43 +10315,60 @@ public boolean equals(angularObjectUpdate_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_name = true && (isSetName()); + list.add(present_name); + if (present_name) + list.add(name); + + boolean present_noteId = true && (isSetNoteId()); + list.add(present_noteId); + if (present_noteId) + list.add(noteId); + + boolean present_object = true && (isSetObject()); + list.add(present_object); + if (present_object) + list.add(object); + + return list.hashCode(); } + @Override public int compareTo(angularObjectUpdate_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - angularObjectUpdate_args typedOther = (angularObjectUpdate_args)other; - lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName()); + lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); if (lastComparison != 0) { return lastComparison; } if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, typedOther.name); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(typedOther.isSetNoteId()); + lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(other.isSetNoteId()); if (lastComparison != 0) { return lastComparison; } if (isSetNoteId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, typedOther.noteId); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, other.noteId); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetObject()).compareTo(typedOther.isSetObject()); + lastComparison = Boolean.valueOf(isSetObject()).compareTo(other.isSetObject()); if (lastComparison != 0) { return lastComparison; } if (isSetObject()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.object, typedOther.object); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.object, other.object); if (lastComparison != 0) { return lastComparison; } @@ -9657,7 +10573,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, angularObjectUpdate_ } - public static class angularObjectUpdate_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class angularObjectUpdate_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("angularObjectUpdate_result"); @@ -9787,16 +10703,18 @@ public boolean equals(angularObjectUpdate_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(angularObjectUpdate_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - angularObjectUpdate_result typedOther = (angularObjectUpdate_result)other; return 0; } @@ -9903,7 +10821,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, angularObjectUpdate_ } - public static class angularObjectAdd_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class angularObjectAdd_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("angularObjectAdd_args"); private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -10216,43 +11134,60 @@ public boolean equals(angularObjectAdd_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_name = true && (isSetName()); + list.add(present_name); + if (present_name) + list.add(name); + + boolean present_noteId = true && (isSetNoteId()); + list.add(present_noteId); + if (present_noteId) + list.add(noteId); + + boolean present_object = true && (isSetObject()); + list.add(present_object); + if (present_object) + list.add(object); + + return list.hashCode(); } + @Override public int compareTo(angularObjectAdd_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - angularObjectAdd_args typedOther = (angularObjectAdd_args)other; - lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName()); + lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); if (lastComparison != 0) { return lastComparison; } if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, typedOther.name); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(typedOther.isSetNoteId()); + lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(other.isSetNoteId()); if (lastComparison != 0) { return lastComparison; } if (isSetNoteId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, typedOther.noteId); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, other.noteId); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetObject()).compareTo(typedOther.isSetObject()); + lastComparison = Boolean.valueOf(isSetObject()).compareTo(other.isSetObject()); if (lastComparison != 0) { return lastComparison; } if (isSetObject()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.object, typedOther.object); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.object, other.object); if (lastComparison != 0) { return lastComparison; } @@ -10457,7 +11392,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, angularObjectAdd_arg } - public static class angularObjectAdd_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class angularObjectAdd_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("angularObjectAdd_result"); @@ -10587,16 +11522,18 @@ public boolean equals(angularObjectAdd_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(angularObjectAdd_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - angularObjectAdd_result typedOther = (angularObjectAdd_result)other; return 0; } @@ -10703,7 +11640,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, angularObjectAdd_res } - public static class angularObjectRemove_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class angularObjectRemove_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("angularObjectRemove_args"); private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -10957,33 +11894,45 @@ public boolean equals(angularObjectRemove_args that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + boolean present_name = true && (isSetName()); + list.add(present_name); + if (present_name) + list.add(name); + + boolean present_noteId = true && (isSetNoteId()); + list.add(present_noteId); + if (present_noteId) + list.add(noteId); + + return list.hashCode(); } + @Override public int compareTo(angularObjectRemove_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - angularObjectRemove_args typedOther = (angularObjectRemove_args)other; - lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName()); + lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); if (lastComparison != 0) { return lastComparison; } if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, typedOther.name); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(typedOther.isSetNoteId()); + lastComparison = Boolean.valueOf(isSetNoteId()).compareTo(other.isSetNoteId()); if (lastComparison != 0) { return lastComparison; } if (isSetNoteId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, typedOther.noteId); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.noteId, other.noteId); if (lastComparison != 0) { return lastComparison; } @@ -11157,7 +12106,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, angularObjectRemove_ } - public static class angularObjectRemove_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + public static class angularObjectRemove_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("angularObjectRemove_result"); @@ -11287,16 +12236,18 @@ public boolean equals(angularObjectRemove_result that) { @Override public int hashCode() { - return 0; + List list = new ArrayList(); + + return list.hashCode(); } + @Override public int compareTo(angularObjectRemove_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - angularObjectRemove_result typedOther = (angularObjectRemove_result)other; return 0; } diff --git a/zeppelin-interpreter/src/main/thrift/genthrift.sh b/zeppelin-interpreter/src/main/thrift/genthrift.sh new file mode 100755 index 00000000000..12c0521d8ff --- /dev/null +++ b/zeppelin-interpreter/src/main/thrift/genthrift.sh @@ -0,0 +1,28 @@ +#!/usr/bin/env bash +#/** +# * Licensed to the Apache Software Foundation (ASF) under one +# * or more contributor license agreements. See the NOTICE file +# * distributed with this work for additional information +# * regarding copyright ownership. The ASF licenses this file +# * to you under the Apache License, Version 2.0 (the +# * "License"); you may not use this file except in compliance +# * with the License. You may obtain a copy of the License at +# * +# * http://www.apache.org/licenses/LICENSE-2.0 +# * +# * Unless required by applicable law or agreed to in writing, software +# * distributed under the License is distributed on an "AS IS" BASIS, +# * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# * See the License for the specific language governing permissions and +# * limitations under the License. +# */ + +rm -rf gen-java +rm -rf ../java/org/apache/zeppelin/interpreter/thrift +thrift --gen java RemoteInterpreterService.thrift +for file in gen-java/org/apache/zeppelin/interpreter/thrift/* ; do + cat java_license_header.txt ${file} > ${file}.tmp + mv -f ${file}.tmp ${file} +done +mv gen-java/org/apache/zeppelin/interpreter/thrift ../java/org/apache/zeppelin/interpreter/thrift +rm -rf gen-java diff --git a/zeppelin-interpreter/src/main/thrift/java_license_header.txt b/zeppelin-interpreter/src/main/thrift/java_license_header.txt new file mode 100644 index 00000000000..5d5f1e35f1a --- /dev/null +++ b/zeppelin-interpreter/src/main/thrift/java_license_header.txt @@ -0,0 +1,17 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ From 7a204dc6537fb8cee3bf503b1b1ca01b6571faf4 Mon Sep 17 00:00:00 2001 From: caofangkun Date: Fri, 7 Aug 2015 10:59:56 +0800 Subject: [PATCH 2/3] ZEPPELIN-206: update libthrift version from 0.9.0 to 0.9.2 --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 9e5f54e7002..956b44b108f 100644 --- a/pom.xml +++ b/pom.xml @@ -104,7 +104,7 @@ 1.7.10 1.2.17 - 0.9.0 + 0.9.2 2.2 15.0 From 347dbf76d0aed285ac82d0698882436a966336aa Mon Sep 17 00:00:00 2001 From: caofangkun Date: Fri, 7 Aug 2015 14:39:13 +0800 Subject: [PATCH 3/3] ZEPPELIN-206: modify pom.xml add relativePath --- angular/pom.xml | 1 + cassandra/pom.xml | 1 + flink/pom.xml | 1 + hive/pom.xml | 1 + ignite/pom.xml | 1 + lens/pom.xml | 1 + markdown/pom.xml | 1 + shell/pom.xml | 1 + spark/pom.xml | 1 + tajo/pom.xml | 1 + zeppelin-distribution/pom.xml | 1 + zeppelin-interpreter/pom.xml | 6 ++++++ zeppelin-server/pom.xml | 1 + zeppelin-web/pom.xml | 1 + zeppelin-zengine/pom.xml | 1 + 15 files changed, 20 insertions(+) diff --git a/angular/pom.xml b/angular/pom.xml index c50867798bd..7aad95d20d6 100644 --- a/angular/pom.xml +++ b/angular/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/cassandra/pom.xml b/cassandra/pom.xml index e12c75012d7..c2b2d58a2a3 100644 --- a/cassandra/pom.xml +++ b/cassandra/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/flink/pom.xml b/flink/pom.xml index b6c790baf36..27d8034f583 100644 --- a/flink/pom.xml +++ b/flink/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/hive/pom.xml b/hive/pom.xml index 9354a95ca0c..7562c5880a4 100644 --- a/hive/pom.xml +++ b/hive/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/ignite/pom.xml b/ignite/pom.xml index a3edfd5e7df..91094a68aeb 100644 --- a/ignite/pom.xml +++ b/ignite/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. zeppelin-ignite diff --git a/lens/pom.xml b/lens/pom.xml index 1426043c0af..12f92a96ca5 100644 --- a/lens/pom.xml +++ b/lens/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/markdown/pom.xml b/markdown/pom.xml index 763120989e9..6004f16f3af 100644 --- a/markdown/pom.xml +++ b/markdown/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/shell/pom.xml b/shell/pom.xml index 118b6cba921..9cc621c0a6e 100644 --- a/shell/pom.xml +++ b/shell/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/spark/pom.xml b/spark/pom.xml index 9b82acbedd5..6bdb63cfeb2 100644 --- a/spark/pom.xml +++ b/spark/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/tajo/pom.xml b/tajo/pom.xml index 1161cc0a4df..c08a0db73a6 100644 --- a/tajo/pom.xml +++ b/tajo/pom.xml @@ -22,6 +22,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/zeppelin-distribution/pom.xml b/zeppelin-distribution/pom.xml index 72d001cc576..6c7b3f0edfd 100644 --- a/zeppelin-distribution/pom.xml +++ b/zeppelin-distribution/pom.xml @@ -24,6 +24,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. zeppelin-distribution diff --git a/zeppelin-interpreter/pom.xml b/zeppelin-interpreter/pom.xml index 8251055395b..bd0bda65c89 100644 --- a/zeppelin-interpreter/pom.xml +++ b/zeppelin-interpreter/pom.xml @@ -25,6 +25,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin @@ -59,6 +60,11 @@ 2.3 + + commons-lang + commons-lang + + org.slf4j slf4j-api diff --git a/zeppelin-server/pom.xml b/zeppelin-server/pom.xml index 2b43e1b0260..cc6df976357 100644 --- a/zeppelin-server/pom.xml +++ b/zeppelin-server/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/zeppelin-web/pom.xml b/zeppelin-web/pom.xml index 316fae738b2..1a9b5f1e658 100644 --- a/zeppelin-web/pom.xml +++ b/zeppelin-web/pom.xml @@ -23,6 +23,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin diff --git a/zeppelin-zengine/pom.xml b/zeppelin-zengine/pom.xml index 76ef04ab75d..e4310891ff0 100644 --- a/zeppelin-zengine/pom.xml +++ b/zeppelin-zengine/pom.xml @@ -24,6 +24,7 @@ zeppelin org.apache.zeppelin 0.6.0-incubating-SNAPSHOT + .. org.apache.zeppelin