http://git-wip-us.apache.org/repos/asf/zeppelin/blob/55f6c91c/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventType.java ---------------------------------------------------------------------- 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 9e5a0b4..4396696 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,33 +1,26 @@ /** - * 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 + * 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 + * <p>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 + * <p>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 + * <p>DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * + * @generated */ package org.apache.zeppelin.interpreter.thrift; - -import java.util.Map; -import java.util.HashMap; -import org.apache.thrift.TEnum; - public enum RemoteInterpreterEventType implements org.apache.thrift.TEnum { NO_OP(1), ANGULAR_OBJECT_ADD(2), @@ -52,18 +45,17 @@ public enum RemoteInterpreterEventType implements org.apache.thrift.TEnum { this.value = value; } - /** - * Get the integer value of this enum value, as defined in the Thrift IDL. - */ + /** Get the integer value of this enum value, as defined in the Thrift IDL. */ public int getValue() { return value; } /** * Find a the enum type by its integer value, as defined in the Thrift IDL. + * * @return null if the value is not found. */ - public static RemoteInterpreterEventType findByValue(int value) { + public static RemoteInterpreterEventType findByValue(int value) { switch (value) { case 1: return NO_OP;
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/55f6c91c/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResult.java ---------------------------------------------------------------------- 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 2c863c2..7e03732 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,67 +1,71 @@ /** - * 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 + * 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 + * <p>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 + * <p>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 + * <p>DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * + * @generated */ package org.apache.zeppelin.interpreter.thrift; +import java.util.ArrayList; +import java.util.BitSet; +import java.util.Collections; +import java.util.EnumMap; +import java.util.EnumSet; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import javax.annotation.Generated; +import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.scheme.IScheme; import org.apache.thrift.scheme.SchemeFactory; import org.apache.thrift.scheme.StandardScheme; - import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -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; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -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 = "2018-8-9") -public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteInterpreterResult, RemoteInterpreterResult._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterResult> { - 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); - private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.LIST, (short)2); - private static final org.apache.thrift.protocol.TField CONFIG_FIELD_DESC = new org.apache.thrift.protocol.TField("config", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField GUI_FIELD_DESC = new org.apache.thrift.protocol.TField("gui", org.apache.thrift.protocol.TType.STRING, (short)4); - private static final org.apache.thrift.protocol.TField NOTE_GUI_FIELD_DESC = new org.apache.thrift.protocol.TField("noteGui", org.apache.thrift.protocol.TType.STRING, (short)5); +public class RemoteInterpreterResult + implements org.apache.thrift.TBase<RemoteInterpreterResult, RemoteInterpreterResult._Fields>, + java.io.Serializable, + Cloneable, + Comparable<RemoteInterpreterResult> { + 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); + private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = + new org.apache.thrift.protocol.TField( + "msg", org.apache.thrift.protocol.TType.LIST, (short) 2); + private static final org.apache.thrift.protocol.TField CONFIG_FIELD_DESC = + new org.apache.thrift.protocol.TField( + "config", org.apache.thrift.protocol.TType.STRING, (short) 3); + private static final org.apache.thrift.protocol.TField GUI_FIELD_DESC = + new org.apache.thrift.protocol.TField( + "gui", org.apache.thrift.protocol.TType.STRING, (short) 4); + private static final org.apache.thrift.protocol.TField NOTE_GUI_FIELD_DESC = + new org.apache.thrift.protocol.TField( + "noteGui", org.apache.thrift.protocol.TType.STRING, (short) 5); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = + new HashMap<Class<? extends IScheme>, SchemeFactory>(); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { schemes.put(StandardScheme.class, new RemoteInterpreterResultStandardSchemeFactory()); schemes.put(TupleScheme.class, new RemoteInterpreterResultTupleSchemeFactory()); @@ -73,13 +77,16 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn public String gui; // required public String noteGui; // required - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + /** + * The set of fields this struct contains, along with convenience methods for finding and + * manipulating them. + */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - CODE((short)1, "code"), - MSG((short)2, "msg"), - CONFIG((short)3, "config"), - GUI((short)4, "gui"), - NOTE_GUI((short)5, "noteGui"); + CODE((short) 1, "code"), + MSG((short) 2, "msg"), + CONFIG((short) 3, "config"), + GUI((short) 4, "gui"), + NOTE_GUI((short) 5, "noteGui"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -89,11 +96,9 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } } - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ + /** Find the _Fields constant that matches fieldId, or null if its not found. */ public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { + switch (fieldId) { case 1: // CODE return CODE; case 2: // MSG @@ -109,19 +114,15 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } } - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ + /** Find the _Fields constant that matches fieldId, throwing an exception if it is not found. */ public static _Fields findByThriftIdOrThrow(int fieldId) { _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + if (fields == null) + throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); return fields; } - /** - * Find the _Fields constant that matches name, or null if its not found. - */ + /** Find the _Fields constant that matches name, or null if its not found. */ public static _Fields findByName(String name) { return byName.get(name); } @@ -145,33 +146,61 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn // isset id assignments public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.CODE, new org.apache.thrift.meta_data.FieldMetaData("code", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, RemoteInterpreterResultMessage.class)))); - tmpMap.put(_Fields.CONFIG, new org.apache.thrift.meta_data.FieldMetaData("config", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.GUI, new org.apache.thrift.meta_data.FieldMetaData("gui", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.NOTE_GUI, new org.apache.thrift.meta_data.FieldMetaData("noteGui", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = + new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put( + _Fields.CODE, + new org.apache.thrift.meta_data.FieldMetaData( + "code", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData( + org.apache.thrift.protocol.TType.STRING))); + tmpMap.put( + _Fields.MSG, + new org.apache.thrift.meta_data.FieldMetaData( + "msg", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.ListMetaData( + org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.StructMetaData( + org.apache.thrift.protocol.TType.STRUCT, + RemoteInterpreterResultMessage.class)))); + tmpMap.put( + _Fields.CONFIG, + new org.apache.thrift.meta_data.FieldMetaData( + "config", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData( + org.apache.thrift.protocol.TType.STRING))); + tmpMap.put( + _Fields.GUI, + new org.apache.thrift.meta_data.FieldMetaData( + "gui", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData( + org.apache.thrift.protocol.TType.STRING))); + tmpMap.put( + _Fields.NOTE_GUI, + new org.apache.thrift.meta_data.FieldMetaData( + "noteGui", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData( + org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(RemoteInterpreterResult.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap( + RemoteInterpreterResult.class, metaDataMap); } - public RemoteInterpreterResult() { - } + public RemoteInterpreterResult() {} public RemoteInterpreterResult( - String code, - List<RemoteInterpreterResultMessage> msg, - String config, - String gui, - String noteGui) - { + String code, + List<RemoteInterpreterResultMessage> msg, + String config, + String gui, + String noteGui) { this(); this.code = code; this.msg = msg; @@ -180,15 +209,14 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn this.noteGui = noteGui; } - /** - * Performs a deep copy on <i>other</i>. - */ + /** Performs a deep copy on <i>other</i>. */ public RemoteInterpreterResult(RemoteInterpreterResult other) { if (other.isSetCode()) { this.code = other.code; } if (other.isSetMsg()) { - List<RemoteInterpreterResultMessage> __this__msg = new ArrayList<RemoteInterpreterResultMessage>(other.msg.size()); + List<RemoteInterpreterResultMessage> __this__msg = + new ArrayList<RemoteInterpreterResultMessage>(other.msg.size()); for (RemoteInterpreterResultMessage other_element : other.msg) { __this__msg.add(new RemoteInterpreterResultMessage(other_element)); } @@ -355,147 +383,135 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn public void setFieldValue(_Fields field, Object value) { switch (field) { - case CODE: - if (value == null) { - unsetCode(); - } else { - setCode((String)value); - } - break; - - case MSG: - if (value == null) { - unsetMsg(); - } else { - setMsg((List<RemoteInterpreterResultMessage>)value); - } - break; + case CODE: + if (value == null) { + unsetCode(); + } else { + setCode((String) value); + } + break; - case CONFIG: - if (value == null) { - unsetConfig(); - } else { - setConfig((String)value); - } - break; + case MSG: + if (value == null) { + unsetMsg(); + } else { + setMsg((List<RemoteInterpreterResultMessage>) value); + } + break; - case GUI: - if (value == null) { - unsetGui(); - } else { - setGui((String)value); - } - break; + case CONFIG: + if (value == null) { + unsetConfig(); + } else { + setConfig((String) value); + } + break; - case NOTE_GUI: - if (value == null) { - unsetNoteGui(); - } else { - setNoteGui((String)value); - } - break; + case GUI: + if (value == null) { + unsetGui(); + } else { + setGui((String) value); + } + break; + case NOTE_GUI: + if (value == null) { + unsetNoteGui(); + } else { + setNoteGui((String) value); + } + break; } } public Object getFieldValue(_Fields field) { switch (field) { - case CODE: - return getCode(); - - case MSG: - return getMsg(); + case CODE: + return getCode(); - case CONFIG: - return getConfig(); + case MSG: + return getMsg(); - case GUI: - return getGui(); + case CONFIG: + return getConfig(); - case NOTE_GUI: - return getNoteGui(); + case GUI: + return getGui(); + case NOTE_GUI: + return getNoteGui(); } throw new IllegalStateException(); } - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + /** + * Returns true if field corresponding to fieldID is set (has been assigned a value) and false + * otherwise + */ public boolean isSet(_Fields field) { if (field == null) { throw new IllegalArgumentException(); } switch (field) { - case CODE: - return isSetCode(); - case MSG: - return isSetMsg(); - case CONFIG: - return isSetConfig(); - case GUI: - return isSetGui(); - case NOTE_GUI: - return isSetNoteGui(); + case CODE: + return isSetCode(); + case MSG: + return isSetMsg(); + case CONFIG: + return isSetConfig(); + case GUI: + return isSetGui(); + case NOTE_GUI: + return isSetNoteGui(); } throw new IllegalStateException(); } @Override public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof RemoteInterpreterResult) - return this.equals((RemoteInterpreterResult)that); + if (that == null) return false; + if (that instanceof RemoteInterpreterResult) return this.equals((RemoteInterpreterResult) that); return false; } public boolean equals(RemoteInterpreterResult that) { - if (that == null) - return false; + if (that == null) return false; boolean this_present_code = true && this.isSetCode(); boolean that_present_code = true && that.isSetCode(); if (this_present_code || that_present_code) { - if (!(this_present_code && that_present_code)) - return false; - if (!this.code.equals(that.code)) - return false; + if (!(this_present_code && that_present_code)) return false; + if (!this.code.equals(that.code)) return false; } boolean this_present_msg = true && this.isSetMsg(); boolean that_present_msg = true && that.isSetMsg(); if (this_present_msg || that_present_msg) { - if (!(this_present_msg && that_present_msg)) - return false; - if (!this.msg.equals(that.msg)) - return false; + if (!(this_present_msg && that_present_msg)) return false; + if (!this.msg.equals(that.msg)) return false; } boolean this_present_config = true && this.isSetConfig(); boolean that_present_config = true && that.isSetConfig(); if (this_present_config || that_present_config) { - if (!(this_present_config && that_present_config)) - return false; - if (!this.config.equals(that.config)) - return false; + if (!(this_present_config && that_present_config)) return false; + if (!this.config.equals(that.config)) return false; } boolean this_present_gui = true && this.isSetGui(); boolean that_present_gui = true && that.isSetGui(); if (this_present_gui || that_present_gui) { - if (!(this_present_gui && that_present_gui)) - return false; - if (!this.gui.equals(that.gui)) - return false; + if (!(this_present_gui && that_present_gui)) return false; + if (!this.gui.equals(that.gui)) return false; } boolean this_present_noteGui = true && this.isSetNoteGui(); boolean that_present_noteGui = true && that.isSetNoteGui(); if (this_present_noteGui || that_present_noteGui) { - if (!(this_present_noteGui && that_present_noteGui)) - return false; - if (!this.noteGui.equals(that.noteGui)) - return false; + if (!(this_present_noteGui && that_present_noteGui)) return false; + if (!this.noteGui.equals(that.noteGui)) return false; } return true; @@ -507,28 +523,23 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn boolean present_code = true && (isSetCode()); list.add(present_code); - if (present_code) - list.add(code); + if (present_code) list.add(code); boolean present_msg = true && (isSetMsg()); list.add(present_msg); - if (present_msg) - list.add(msg); + if (present_msg) list.add(msg); boolean present_config = true && (isSetConfig()); list.add(present_config); - if (present_config) - list.add(config); + if (present_config) list.add(config); boolean present_gui = true && (isSetGui()); list.add(present_gui); - if (present_gui) - list.add(gui); + if (present_gui) list.add(gui); boolean present_noteGui = true && (isSetNoteGui()); list.add(present_noteGui); - if (present_noteGui) - list.add(noteGui); + if (present_noteGui) list.add(noteGui); return list.hashCode(); } @@ -602,7 +613,8 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) + throws org.apache.thrift.TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -661,15 +673,20 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + write( + new org.apache.thrift.protocol.TCompactProtocol( + new org.apache.thrift.transport.TIOStreamTransport(out))); } catch (org.apache.thrift.TException te) { throw new java.io.IOException(te); } } - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + private void readObject(java.io.ObjectInputStream in) + throws java.io.IOException, ClassNotFoundException { try { - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + read( + new org.apache.thrift.protocol.TCompactProtocol( + new org.apache.thrift.transport.TIOStreamTransport(in))); } catch (org.apache.thrift.TException te) { throw new java.io.IOException(te); } @@ -681,15 +698,16 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } } - private static class RemoteInterpreterResultStandardScheme extends StandardScheme<RemoteInterpreterResult> { + private static class RemoteInterpreterResultStandardScheme + extends StandardScheme<RemoteInterpreterResult> { - public void read(org.apache.thrift.protocol.TProtocol iprot, RemoteInterpreterResult struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, RemoteInterpreterResult struct) + throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); - while (true) - { + while (true) { schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { break; } switch (schemeField.id) { @@ -697,7 +715,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.code = iprot.readString(); struct.setCodeIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -707,8 +725,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn org.apache.thrift.protocol.TList _list10 = iprot.readListBegin(); struct.msg = new ArrayList<RemoteInterpreterResultMessage>(_list10.size); RemoteInterpreterResultMessage _elem11; - for (int _i12 = 0; _i12 < _list10.size; ++_i12) - { + for (int _i12 = 0; _i12 < _list10.size; ++_i12) { _elem11 = new RemoteInterpreterResultMessage(); _elem11.read(iprot); struct.msg.add(_elem11); @@ -716,7 +733,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn iprot.readListEnd(); } struct.setMsgIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -724,7 +741,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.config = iprot.readString(); struct.setConfigIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -732,7 +749,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.gui = iprot.readString(); struct.setGuiIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -740,7 +757,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.noteGui = iprot.readString(); struct.setNoteGuiIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -755,7 +772,8 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, RemoteInterpreterResult struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, RemoteInterpreterResult struct) + throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -767,9 +785,10 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn if (struct.msg != null) { oprot.writeFieldBegin(MSG_FIELD_DESC); { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.msg.size())); - for (RemoteInterpreterResultMessage _iter13 : struct.msg) - { + oprot.writeListBegin( + new org.apache.thrift.protocol.TList( + org.apache.thrift.protocol.TType.STRUCT, struct.msg.size())); + for (RemoteInterpreterResultMessage _iter13 : struct.msg) { _iter13.write(oprot); } oprot.writeListEnd(); @@ -794,7 +813,6 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn oprot.writeFieldStop(); oprot.writeStructEnd(); } - } private static class RemoteInterpreterResultTupleSchemeFactory implements SchemeFactory { @@ -803,10 +821,12 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } } - private static class RemoteInterpreterResultTupleScheme extends TupleScheme<RemoteInterpreterResult> { + private static class RemoteInterpreterResultTupleScheme + extends TupleScheme<RemoteInterpreterResult> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResult struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResult struct) + throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetCode()) { @@ -831,8 +851,7 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn if (struct.isSetMsg()) { { oprot.writeI32(struct.msg.size()); - for (RemoteInterpreterResultMessage _iter14 : struct.msg) - { + for (RemoteInterpreterResultMessage _iter14 : struct.msg) { _iter14.write(oprot); } } @@ -849,7 +868,8 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResult struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResult struct) + throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(5); if (incoming.get(0)) { @@ -858,11 +878,12 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list15 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + org.apache.thrift.protocol.TList _list15 = + new org.apache.thrift.protocol.TList( + org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); struct.msg = new ArrayList<RemoteInterpreterResultMessage>(_list15.size); RemoteInterpreterResultMessage _elem16; - for (int _i17 = 0; _i17 < _list15.size; ++_i17) - { + for (int _i17 = 0; _i17 < _list15.size; ++_i17) { _elem16 = new RemoteInterpreterResultMessage(); _elem16.read(iprot); struct.msg.add(_elem16); @@ -884,6 +905,4 @@ public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteIn } } } - } - http://git-wip-us.apache.org/repos/asf/zeppelin/blob/55f6c91c/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResultMessage.java ---------------------------------------------------------------------- diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResultMessage.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResultMessage.java index f88993c..4aa89a4 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResultMessage.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResultMessage.java @@ -1,64 +1,63 @@ /** - * 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 + * 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 + * <p>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 + * <p>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 + * <p>DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * + * @generated */ package org.apache.zeppelin.interpreter.thrift; +import java.util.ArrayList; +import java.util.BitSet; +import java.util.Collections; +import java.util.EnumMap; +import java.util.EnumSet; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import javax.annotation.Generated; +import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.scheme.IScheme; import org.apache.thrift.scheme.SchemeFactory; import org.apache.thrift.scheme.StandardScheme; - import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -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; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -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 = "2018-8-9") -public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<RemoteInterpreterResultMessage, RemoteInterpreterResultMessage._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterResultMessage> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterResultMessage"); - - private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("data", org.apache.thrift.protocol.TType.STRING, (short)2); +public class RemoteInterpreterResultMessage + implements org.apache.thrift.TBase< + RemoteInterpreterResultMessage, RemoteInterpreterResultMessage._Fields>, + java.io.Serializable, + Cloneable, + Comparable<RemoteInterpreterResultMessage> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = + new org.apache.thrift.protocol.TStruct("RemoteInterpreterResultMessage"); + + private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = + new org.apache.thrift.protocol.TField( + "type", org.apache.thrift.protocol.TType.STRING, (short) 1); + private static final org.apache.thrift.protocol.TField DATA_FIELD_DESC = + new org.apache.thrift.protocol.TField( + "data", org.apache.thrift.protocol.TType.STRING, (short) 2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = + new HashMap<Class<? extends IScheme>, SchemeFactory>(); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { schemes.put(StandardScheme.class, new RemoteInterpreterResultMessageStandardSchemeFactory()); schemes.put(TupleScheme.class, new RemoteInterpreterResultMessageTupleSchemeFactory()); @@ -67,10 +66,13 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R public String type; // required public String data; // required - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + /** + * The set of fields this struct contains, along with convenience methods for finding and + * manipulating them. + */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - TYPE((short)1, "type"), - DATA((short)2, "data"); + TYPE((short) 1, "type"), + DATA((short) 2, "data"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -80,11 +82,9 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R } } - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ + /** Find the _Fields constant that matches fieldId, or null if its not found. */ public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { + switch (fieldId) { case 1: // TYPE return TYPE; case 2: // DATA @@ -94,19 +94,15 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R } } - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ + /** Find the _Fields constant that matches fieldId, throwing an exception if it is not found. */ public static _Fields findByThriftIdOrThrow(int fieldId) { _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + if (fields == null) + throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); return fields; } - /** - * Find the _Fields constant that matches name, or null if its not found. - */ + /** Find the _Fields constant that matches name, or null if its not found. */ public static _Fields findByName(String name) { return byName.get(name); } @@ -130,31 +126,38 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R // isset id assignments public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.DATA, new org.apache.thrift.meta_data.FieldMetaData("data", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = + new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put( + _Fields.TYPE, + new org.apache.thrift.meta_data.FieldMetaData( + "type", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData( + org.apache.thrift.protocol.TType.STRING))); + tmpMap.put( + _Fields.DATA, + new org.apache.thrift.meta_data.FieldMetaData( + "data", + org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData( + org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(RemoteInterpreterResultMessage.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap( + RemoteInterpreterResultMessage.class, metaDataMap); } - public RemoteInterpreterResultMessage() { - } + public RemoteInterpreterResultMessage() {} - public RemoteInterpreterResultMessage( - String type, - String data) - { + public RemoteInterpreterResultMessage(String type, String data) { this(); this.type = type; this.data = data; } - /** - * Performs a deep copy on <i>other</i>. - */ + /** Performs a deep copy on <i>other</i>. */ public RemoteInterpreterResultMessage(RemoteInterpreterResultMessage other) { if (other.isSetType()) { this.type = other.type; @@ -224,81 +227,76 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R public void setFieldValue(_Fields field, Object value) { switch (field) { - case TYPE: - if (value == null) { - unsetType(); - } else { - setType((String)value); - } - break; - - case DATA: - if (value == null) { - unsetData(); - } else { - setData((String)value); - } - break; + case TYPE: + if (value == null) { + unsetType(); + } else { + setType((String) value); + } + break; + case DATA: + if (value == null) { + unsetData(); + } else { + setData((String) value); + } + break; } } public Object getFieldValue(_Fields field) { switch (field) { - case TYPE: - return getType(); - - case DATA: - return getData(); + case TYPE: + return getType(); + case DATA: + return getData(); } throw new IllegalStateException(); } - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + /** + * Returns true if field corresponding to fieldID is set (has been assigned a value) and false + * otherwise + */ public boolean isSet(_Fields field) { if (field == null) { throw new IllegalArgumentException(); } switch (field) { - case TYPE: - return isSetType(); - case DATA: - return isSetData(); + case TYPE: + return isSetType(); + case DATA: + return isSetData(); } throw new IllegalStateException(); } @Override public boolean equals(Object that) { - if (that == null) - return false; + if (that == null) return false; if (that instanceof RemoteInterpreterResultMessage) - return this.equals((RemoteInterpreterResultMessage)that); + return this.equals((RemoteInterpreterResultMessage) that); return false; } public boolean equals(RemoteInterpreterResultMessage that) { - if (that == null) - return false; + if (that == null) return false; boolean this_present_type = true && this.isSetType(); boolean that_present_type = true && that.isSetType(); if (this_present_type || that_present_type) { - if (!(this_present_type && that_present_type)) - return false; - if (!this.type.equals(that.type)) - return false; + if (!(this_present_type && that_present_type)) return false; + if (!this.type.equals(that.type)) return false; } boolean this_present_data = true && this.isSetData(); boolean that_present_data = true && that.isSetData(); if (this_present_data || that_present_data) { - if (!(this_present_data && that_present_data)) - return false; - if (!this.data.equals(that.data)) - return false; + if (!(this_present_data && that_present_data)) return false; + if (!this.data.equals(that.data)) return false; } return true; @@ -310,13 +308,11 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R boolean present_type = true && (isSetType()); list.add(present_type); - if (present_type) - list.add(type); + if (present_type) list.add(type); boolean present_data = true && (isSetData()); list.add(present_data); - if (present_data) - list.add(data); + if (present_data) list.add(data); return list.hashCode(); } @@ -360,7 +356,8 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) + throws org.apache.thrift.TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -395,35 +392,43 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + write( + new org.apache.thrift.protocol.TCompactProtocol( + new org.apache.thrift.transport.TIOStreamTransport(out))); } catch (org.apache.thrift.TException te) { throw new java.io.IOException(te); } } - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + private void readObject(java.io.ObjectInputStream in) + throws java.io.IOException, ClassNotFoundException { try { - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + read( + new org.apache.thrift.protocol.TCompactProtocol( + new org.apache.thrift.transport.TIOStreamTransport(in))); } catch (org.apache.thrift.TException te) { throw new java.io.IOException(te); } } - private static class RemoteInterpreterResultMessageStandardSchemeFactory implements SchemeFactory { + private static class RemoteInterpreterResultMessageStandardSchemeFactory + implements SchemeFactory { public RemoteInterpreterResultMessageStandardScheme getScheme() { return new RemoteInterpreterResultMessageStandardScheme(); } } - private static class RemoteInterpreterResultMessageStandardScheme extends StandardScheme<RemoteInterpreterResultMessage> { + private static class RemoteInterpreterResultMessageStandardScheme + extends StandardScheme<RemoteInterpreterResultMessage> { - public void read(org.apache.thrift.protocol.TProtocol iprot, RemoteInterpreterResultMessage struct) throws org.apache.thrift.TException { + public void read( + org.apache.thrift.protocol.TProtocol iprot, RemoteInterpreterResultMessage struct) + throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); - while (true) - { + while (true) { schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { break; } switch (schemeField.id) { @@ -431,7 +436,7 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.type = iprot.readString(); struct.setTypeIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -439,7 +444,7 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.data = iprot.readString(); struct.setDataIsSet(true); - } else { + } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; @@ -454,7 +459,9 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, RemoteInterpreterResultMessage struct) throws org.apache.thrift.TException { + public void write( + org.apache.thrift.protocol.TProtocol oprot, RemoteInterpreterResultMessage struct) + throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -471,7 +478,6 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R oprot.writeFieldStop(); oprot.writeStructEnd(); } - } private static class RemoteInterpreterResultMessageTupleSchemeFactory implements SchemeFactory { @@ -480,10 +486,13 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R } } - private static class RemoteInterpreterResultMessageTupleScheme extends TupleScheme<RemoteInterpreterResultMessage> { + private static class RemoteInterpreterResultMessageTupleScheme + extends TupleScheme<RemoteInterpreterResultMessage> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResultMessage struct) throws org.apache.thrift.TException { + public void write( + org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResultMessage struct) + throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetType()) { @@ -502,7 +511,9 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResultMessage struct) throws org.apache.thrift.TException { + public void read( + org.apache.thrift.protocol.TProtocol prot, RemoteInterpreterResultMessage struct) + throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -515,6 +526,4 @@ public class RemoteInterpreterResultMessage implements org.apache.thrift.TBase<R } } } - } -
