http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/KeyAlreadyExistsException.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/KeyAlreadyExistsException.java b/storm-core/src/jvm/backtype/storm/generated/KeyAlreadyExistsException.java new file mode 100644 index 0000000..fe1a8d0 --- /dev/null +++ b/storm-core/src/jvm/backtype/storm/generated/KeyAlreadyExistsException.java @@ -0,0 +1,406 @@ +/** + * 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.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package backtype.storm.generated; + +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.3)") +public class KeyAlreadyExistsException extends TException implements org.apache.thrift.TBase<KeyAlreadyExistsException, KeyAlreadyExistsException._Fields>, java.io.Serializable, Cloneable, Comparable<KeyAlreadyExistsException> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("KeyAlreadyExistsException"); + + private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.STRING, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new KeyAlreadyExistsExceptionStandardSchemeFactory()); + schemes.put(TupleScheme.class, new KeyAlreadyExistsExceptionTupleSchemeFactory()); + } + + private String msg; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + MSG((short)1, "msg"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // MSG + return MSG; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(KeyAlreadyExistsException.class, metaDataMap); + } + + public KeyAlreadyExistsException() { + } + + public KeyAlreadyExistsException( + String msg) + { + this(); + this.msg = msg; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public KeyAlreadyExistsException(KeyAlreadyExistsException other) { + if (other.is_set_msg()) { + this.msg = other.msg; + } + } + + public KeyAlreadyExistsException deepCopy() { + return new KeyAlreadyExistsException(this); + } + + @Override + public void clear() { + this.msg = null; + } + + public String get_msg() { + return this.msg; + } + + public void set_msg(String msg) { + this.msg = msg; + } + + public void unset_msg() { + this.msg = null; + } + + /** Returns true if field msg is set (has been assigned a value) and false otherwise */ + public boolean is_set_msg() { + return this.msg != null; + } + + public void set_msg_isSet(boolean value) { + if (!value) { + this.msg = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case MSG: + if (value == null) { + unset_msg(); + } else { + set_msg((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case MSG: + return get_msg(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case MSG: + return is_set_msg(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof KeyAlreadyExistsException) + return this.equals((KeyAlreadyExistsException)that); + return false; + } + + public boolean equals(KeyAlreadyExistsException that) { + if (that == null) + return false; + + boolean this_present_msg = true && this.is_set_msg(); + boolean that_present_msg = true && that.is_set_msg(); + if (this_present_msg || that_present_msg) { + if (!(this_present_msg && that_present_msg)) + return false; + if (!this.msg.equals(that.msg)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_msg = true && (is_set_msg()); + list.add(present_msg); + if (present_msg) + list.add(msg); + + return list.hashCode(); + } + + @Override + public int compareTo(KeyAlreadyExistsException other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(is_set_msg()).compareTo(other.is_set_msg()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_msg()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("KeyAlreadyExistsException("); + boolean first = true; + + sb.append("msg:"); + if (this.msg == null) { + sb.append("null"); + } else { + sb.append(this.msg); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!is_set_msg()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'msg' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class KeyAlreadyExistsExceptionStandardSchemeFactory implements SchemeFactory { + public KeyAlreadyExistsExceptionStandardScheme getScheme() { + return new KeyAlreadyExistsExceptionStandardScheme(); + } + } + + private static class KeyAlreadyExistsExceptionStandardScheme extends StandardScheme<KeyAlreadyExistsException> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, KeyAlreadyExistsException struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // MSG + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.msg = iprot.readString(); + struct.set_msg_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, KeyAlreadyExistsException struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.msg != null) { + oprot.writeFieldBegin(MSG_FIELD_DESC); + oprot.writeString(struct.msg); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class KeyAlreadyExistsExceptionTupleSchemeFactory implements SchemeFactory { + public KeyAlreadyExistsExceptionTupleScheme getScheme() { + return new KeyAlreadyExistsExceptionTupleScheme(); + } + } + + private static class KeyAlreadyExistsExceptionTupleScheme extends TupleScheme<KeyAlreadyExistsException> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, KeyAlreadyExistsException struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.msg); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, KeyAlreadyExistsException struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.msg = iprot.readString(); + struct.set_msg_isSet(true); + } + } + +} +
http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/KeyNotFoundException.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/KeyNotFoundException.java b/storm-core/src/jvm/backtype/storm/generated/KeyNotFoundException.java new file mode 100644 index 0000000..d3d6ee7 --- /dev/null +++ b/storm-core/src/jvm/backtype/storm/generated/KeyNotFoundException.java @@ -0,0 +1,406 @@ +/** + * 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.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package backtype.storm.generated; + +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.3)") +public class KeyNotFoundException extends TException implements org.apache.thrift.TBase<KeyNotFoundException, KeyNotFoundException._Fields>, java.io.Serializable, Cloneable, Comparable<KeyNotFoundException> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("KeyNotFoundException"); + + private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.STRING, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new KeyNotFoundExceptionStandardSchemeFactory()); + schemes.put(TupleScheme.class, new KeyNotFoundExceptionTupleSchemeFactory()); + } + + private String msg; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + MSG((short)1, "msg"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // MSG + return MSG; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(KeyNotFoundException.class, metaDataMap); + } + + public KeyNotFoundException() { + } + + public KeyNotFoundException( + String msg) + { + this(); + this.msg = msg; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public KeyNotFoundException(KeyNotFoundException other) { + if (other.is_set_msg()) { + this.msg = other.msg; + } + } + + public KeyNotFoundException deepCopy() { + return new KeyNotFoundException(this); + } + + @Override + public void clear() { + this.msg = null; + } + + public String get_msg() { + return this.msg; + } + + public void set_msg(String msg) { + this.msg = msg; + } + + public void unset_msg() { + this.msg = null; + } + + /** Returns true if field msg is set (has been assigned a value) and false otherwise */ + public boolean is_set_msg() { + return this.msg != null; + } + + public void set_msg_isSet(boolean value) { + if (!value) { + this.msg = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case MSG: + if (value == null) { + unset_msg(); + } else { + set_msg((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case MSG: + return get_msg(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case MSG: + return is_set_msg(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof KeyNotFoundException) + return this.equals((KeyNotFoundException)that); + return false; + } + + public boolean equals(KeyNotFoundException that) { + if (that == null) + return false; + + boolean this_present_msg = true && this.is_set_msg(); + boolean that_present_msg = true && that.is_set_msg(); + if (this_present_msg || that_present_msg) { + if (!(this_present_msg && that_present_msg)) + return false; + if (!this.msg.equals(that.msg)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_msg = true && (is_set_msg()); + list.add(present_msg); + if (present_msg) + list.add(msg); + + return list.hashCode(); + } + + @Override + public int compareTo(KeyNotFoundException other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(is_set_msg()).compareTo(other.is_set_msg()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_msg()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("KeyNotFoundException("); + boolean first = true; + + sb.append("msg:"); + if (this.msg == null) { + sb.append("null"); + } else { + sb.append(this.msg); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!is_set_msg()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'msg' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class KeyNotFoundExceptionStandardSchemeFactory implements SchemeFactory { + public KeyNotFoundExceptionStandardScheme getScheme() { + return new KeyNotFoundExceptionStandardScheme(); + } + } + + private static class KeyNotFoundExceptionStandardScheme extends StandardScheme<KeyNotFoundException> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, KeyNotFoundException struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // MSG + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.msg = iprot.readString(); + struct.set_msg_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, KeyNotFoundException struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.msg != null) { + oprot.writeFieldBegin(MSG_FIELD_DESC); + oprot.writeString(struct.msg); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class KeyNotFoundExceptionTupleSchemeFactory implements SchemeFactory { + public KeyNotFoundExceptionTupleScheme getScheme() { + return new KeyNotFoundExceptionTupleScheme(); + } + } + + private static class KeyNotFoundExceptionTupleScheme extends TupleScheme<KeyNotFoundException> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, KeyNotFoundException struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.msg); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, KeyNotFoundException struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.msg = iprot.readString(); + struct.set_msg_isSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java b/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java index 20f0d10..7ff3c74 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java +++ b/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java @@ -365,15 +365,15 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork case 1: // APPROVED_WORKERS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map636 = iprot.readMapBegin(); - struct.approved_workers = new HashMap<String,Integer>(2*_map636.size); - String _key637; - int _val638; - for (int _i639 = 0; _i639 < _map636.size; ++_i639) + org.apache.thrift.protocol.TMap _map652 = iprot.readMapBegin(); + struct.approved_workers = new HashMap<String,Integer>(2*_map652.size); + String _key653; + int _val654; + for (int _i655 = 0; _i655 < _map652.size; ++_i655) { - _key637 = iprot.readString(); - _val638 = iprot.readI32(); - struct.approved_workers.put(_key637, _val638); + _key653 = iprot.readString(); + _val654 = iprot.readI32(); + struct.approved_workers.put(_key653, _val654); } iprot.readMapEnd(); } @@ -399,10 +399,10 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork oprot.writeFieldBegin(APPROVED_WORKERS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.approved_workers.size())); - for (Map.Entry<String, Integer> _iter640 : struct.approved_workers.entrySet()) + for (Map.Entry<String, Integer> _iter656 : struct.approved_workers.entrySet()) { - oprot.writeString(_iter640.getKey()); - oprot.writeI32(_iter640.getValue()); + oprot.writeString(_iter656.getKey()); + oprot.writeI32(_iter656.getValue()); } oprot.writeMapEnd(); } @@ -427,10 +427,10 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.approved_workers.size()); - for (Map.Entry<String, Integer> _iter641 : struct.approved_workers.entrySet()) + for (Map.Entry<String, Integer> _iter657 : struct.approved_workers.entrySet()) { - oprot.writeString(_iter641.getKey()); - oprot.writeI32(_iter641.getValue()); + oprot.writeString(_iter657.getKey()); + oprot.writeI32(_iter657.getValue()); } } } @@ -439,15 +439,15 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork public void read(org.apache.thrift.protocol.TProtocol prot, LSApprovedWorkers struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map642 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32()); - struct.approved_workers = new HashMap<String,Integer>(2*_map642.size); - String _key643; - int _val644; - for (int _i645 = 0; _i645 < _map642.size; ++_i645) + org.apache.thrift.protocol.TMap _map658 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32()); + struct.approved_workers = new HashMap<String,Integer>(2*_map658.size); + String _key659; + int _val660; + for (int _i661 = 0; _i661 < _map658.size; ++_i661) { - _key643 = iprot.readString(); - _val644 = iprot.readI32(); - struct.approved_workers.put(_key643, _val644); + _key659 = iprot.readString(); + _val660 = iprot.readI32(); + struct.approved_workers.put(_key659, _val660); } } struct.set_approved_workers_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java index de4c803..d655d04 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java +++ b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java @@ -376,16 +376,16 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv case 1: // ASSIGNMENTS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map646 = iprot.readMapBegin(); - struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map646.size); - int _key647; - LocalAssignment _val648; - for (int _i649 = 0; _i649 < _map646.size; ++_i649) + org.apache.thrift.protocol.TMap _map662 = iprot.readMapBegin(); + struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map662.size); + int _key663; + LocalAssignment _val664; + for (int _i665 = 0; _i665 < _map662.size; ++_i665) { - _key647 = iprot.readI32(); - _val648 = new LocalAssignment(); - _val648.read(iprot); - struct.assignments.put(_key647, _val648); + _key663 = iprot.readI32(); + _val664 = new LocalAssignment(); + _val664.read(iprot); + struct.assignments.put(_key663, _val664); } iprot.readMapEnd(); } @@ -411,10 +411,10 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv oprot.writeFieldBegin(ASSIGNMENTS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, struct.assignments.size())); - for (Map.Entry<Integer, LocalAssignment> _iter650 : struct.assignments.entrySet()) + for (Map.Entry<Integer, LocalAssignment> _iter666 : struct.assignments.entrySet()) { - oprot.writeI32(_iter650.getKey()); - _iter650.getValue().write(oprot); + oprot.writeI32(_iter666.getKey()); + _iter666.getValue().write(oprot); } oprot.writeMapEnd(); } @@ -439,10 +439,10 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.assignments.size()); - for (Map.Entry<Integer, LocalAssignment> _iter651 : struct.assignments.entrySet()) + for (Map.Entry<Integer, LocalAssignment> _iter667 : struct.assignments.entrySet()) { - oprot.writeI32(_iter651.getKey()); - _iter651.getValue().write(oprot); + oprot.writeI32(_iter667.getKey()); + _iter667.getValue().write(oprot); } } } @@ -451,16 +451,16 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv public void read(org.apache.thrift.protocol.TProtocol prot, LSSupervisorAssignments struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map652 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map652.size); - int _key653; - LocalAssignment _val654; - for (int _i655 = 0; _i655 < _map652.size; ++_i655) + org.apache.thrift.protocol.TMap _map668 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map668.size); + int _key669; + LocalAssignment _val670; + for (int _i671 = 0; _i671 < _map668.size; ++_i671) { - _key653 = iprot.readI32(); - _val654 = new LocalAssignment(); - _val654.read(iprot); - struct.assignments.put(_key653, _val654); + _key669 = iprot.readI32(); + _val670 = new LocalAssignment(); + _val670.read(iprot); + struct.assignments.put(_key669, _val670); } } struct.set_assignments_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java index 79fea1e..ec2931f 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java +++ b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java @@ -656,13 +656,13 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST case 3: // USERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list664 = iprot.readListBegin(); - struct.users = new ArrayList<String>(_list664.size); - String _elem665; - for (int _i666 = 0; _i666 < _list664.size; ++_i666) + org.apache.thrift.protocol.TList _list680 = iprot.readListBegin(); + struct.users = new ArrayList<String>(_list680.size); + String _elem681; + for (int _i682 = 0; _i682 < _list680.size; ++_i682) { - _elem665 = iprot.readString(); - struct.users.add(_elem665); + _elem681 = iprot.readString(); + struct.users.add(_elem681); } iprot.readListEnd(); } @@ -674,13 +674,13 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST case 4: // GROUPS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list667 = iprot.readListBegin(); - struct.groups = new ArrayList<String>(_list667.size); - String _elem668; - for (int _i669 = 0; _i669 < _list667.size; ++_i669) + org.apache.thrift.protocol.TList _list683 = iprot.readListBegin(); + struct.groups = new ArrayList<String>(_list683.size); + String _elem684; + for (int _i685 = 0; _i685 < _list683.size; ++_i685) { - _elem668 = iprot.readString(); - struct.groups.add(_elem668); + _elem684 = iprot.readString(); + struct.groups.add(_elem684); } iprot.readListEnd(); } @@ -714,9 +714,9 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST oprot.writeFieldBegin(USERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.users.size())); - for (String _iter670 : struct.users) + for (String _iter686 : struct.users) { - oprot.writeString(_iter670); + oprot.writeString(_iter686); } oprot.writeListEnd(); } @@ -726,9 +726,9 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST oprot.writeFieldBegin(GROUPS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.groups.size())); - for (String _iter671 : struct.groups) + for (String _iter687 : struct.groups) { - oprot.writeString(_iter671); + oprot.writeString(_iter687); } oprot.writeListEnd(); } @@ -755,16 +755,16 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST oprot.writeI64(struct.time_stamp); { oprot.writeI32(struct.users.size()); - for (String _iter672 : struct.users) + for (String _iter688 : struct.users) { - oprot.writeString(_iter672); + oprot.writeString(_iter688); } } { oprot.writeI32(struct.groups.size()); - for (String _iter673 : struct.groups) + for (String _iter689 : struct.groups) { - oprot.writeString(_iter673); + oprot.writeString(_iter689); } } } @@ -777,24 +777,24 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST struct.time_stamp = iprot.readI64(); struct.set_time_stamp_isSet(true); { - org.apache.thrift.protocol.TList _list674 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.users = new ArrayList<String>(_list674.size); - String _elem675; - for (int _i676 = 0; _i676 < _list674.size; ++_i676) + org.apache.thrift.protocol.TList _list690 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.users = new ArrayList<String>(_list690.size); + String _elem691; + for (int _i692 = 0; _i692 < _list690.size; ++_i692) { - _elem675 = iprot.readString(); - struct.users.add(_elem675); + _elem691 = iprot.readString(); + struct.users.add(_elem691); } } struct.set_users_isSet(true); { - org.apache.thrift.protocol.TList _list677 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.groups = new ArrayList<String>(_list677.size); - String _elem678; - for (int _i679 = 0; _i679 < _list677.size; ++_i679) + org.apache.thrift.protocol.TList _list693 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.groups = new ArrayList<String>(_list693.size); + String _elem694; + for (int _i695 = 0; _i695 < _list693.size; ++_i695) { - _elem678 = iprot.readString(); - struct.groups.add(_elem678); + _elem694 = iprot.readString(); + struct.groups.add(_elem694); } } struct.set_groups_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java index 962ece6..a386cf5 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java +++ b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java @@ -371,14 +371,14 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL case 1: // TOPO_HISTORY if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list680 = iprot.readListBegin(); - struct.topo_history = new ArrayList<LSTopoHistory>(_list680.size); - LSTopoHistory _elem681; - for (int _i682 = 0; _i682 < _list680.size; ++_i682) + org.apache.thrift.protocol.TList _list696 = iprot.readListBegin(); + struct.topo_history = new ArrayList<LSTopoHistory>(_list696.size); + LSTopoHistory _elem697; + for (int _i698 = 0; _i698 < _list696.size; ++_i698) { - _elem681 = new LSTopoHistory(); - _elem681.read(iprot); - struct.topo_history.add(_elem681); + _elem697 = new LSTopoHistory(); + _elem697.read(iprot); + struct.topo_history.add(_elem697); } iprot.readListEnd(); } @@ -404,9 +404,9 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL oprot.writeFieldBegin(TOPO_HISTORY_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.topo_history.size())); - for (LSTopoHistory _iter683 : struct.topo_history) + for (LSTopoHistory _iter699 : struct.topo_history) { - _iter683.write(oprot); + _iter699.write(oprot); } oprot.writeListEnd(); } @@ -431,9 +431,9 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.topo_history.size()); - for (LSTopoHistory _iter684 : struct.topo_history) + for (LSTopoHistory _iter700 : struct.topo_history) { - _iter684.write(oprot); + _iter700.write(oprot); } } } @@ -442,14 +442,14 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL public void read(org.apache.thrift.protocol.TProtocol prot, LSTopoHistoryList struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list685 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.topo_history = new ArrayList<LSTopoHistory>(_list685.size); - LSTopoHistory _elem686; - for (int _i687 = 0; _i687 < _list685.size; ++_i687) + org.apache.thrift.protocol.TList _list701 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.topo_history = new ArrayList<LSTopoHistory>(_list701.size); + LSTopoHistory _elem702; + for (int _i703 = 0; _i703 < _list701.size; ++_i703) { - _elem686 = new LSTopoHistory(); - _elem686.read(iprot); - struct.topo_history.add(_elem686); + _elem702 = new LSTopoHistory(); + _elem702.read(iprot); + struct.topo_history.add(_elem702); } } struct.set_topo_history_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java b/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java index d6e7c36..9252270 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java +++ b/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java @@ -638,14 +638,14 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb case 3: // EXECUTORS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list656 = iprot.readListBegin(); - struct.executors = new ArrayList<ExecutorInfo>(_list656.size); - ExecutorInfo _elem657; - for (int _i658 = 0; _i658 < _list656.size; ++_i658) + org.apache.thrift.protocol.TList _list672 = iprot.readListBegin(); + struct.executors = new ArrayList<ExecutorInfo>(_list672.size); + ExecutorInfo _elem673; + for (int _i674 = 0; _i674 < _list672.size; ++_i674) { - _elem657 = new ExecutorInfo(); - _elem657.read(iprot); - struct.executors.add(_elem657); + _elem673 = new ExecutorInfo(); + _elem673.read(iprot); + struct.executors.add(_elem673); } iprot.readListEnd(); } @@ -687,9 +687,9 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb oprot.writeFieldBegin(EXECUTORS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.executors.size())); - for (ExecutorInfo _iter659 : struct.executors) + for (ExecutorInfo _iter675 : struct.executors) { - _iter659.write(oprot); + _iter675.write(oprot); } oprot.writeListEnd(); } @@ -719,9 +719,9 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb oprot.writeString(struct.topology_id); { oprot.writeI32(struct.executors.size()); - for (ExecutorInfo _iter660 : struct.executors) + for (ExecutorInfo _iter676 : struct.executors) { - _iter660.write(oprot); + _iter676.write(oprot); } } oprot.writeI32(struct.port); @@ -735,14 +735,14 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb struct.topology_id = iprot.readString(); struct.set_topology_id_isSet(true); { - org.apache.thrift.protocol.TList _list661 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executors = new ArrayList<ExecutorInfo>(_list661.size); - ExecutorInfo _elem662; - for (int _i663 = 0; _i663 < _list661.size; ++_i663) + org.apache.thrift.protocol.TList _list677 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.executors = new ArrayList<ExecutorInfo>(_list677.size); + ExecutorInfo _elem678; + for (int _i679 = 0; _i679 < _list677.size; ++_i679) { - _elem662 = new ExecutorInfo(); - _elem662.read(iprot); - struct.executors.add(_elem662); + _elem678 = new ExecutorInfo(); + _elem678.read(iprot); + struct.executors.add(_elem678); } } struct.set_executors_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/ListBlobsResult.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/ListBlobsResult.java b/storm-core/src/jvm/backtype/storm/generated/ListBlobsResult.java new file mode 100644 index 0000000..94b27f8 --- /dev/null +++ b/storm-core/src/jvm/backtype/storm/generated/ListBlobsResult.java @@ -0,0 +1,556 @@ +/** + * 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.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package backtype.storm.generated; + +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.3)") +public class ListBlobsResult implements org.apache.thrift.TBase<ListBlobsResult, ListBlobsResult._Fields>, java.io.Serializable, Cloneable, Comparable<ListBlobsResult> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ListBlobsResult"); + + private static final org.apache.thrift.protocol.TField KEYS_FIELD_DESC = new org.apache.thrift.protocol.TField("keys", org.apache.thrift.protocol.TType.LIST, (short)1); + private static final org.apache.thrift.protocol.TField SESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("session", org.apache.thrift.protocol.TType.STRING, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ListBlobsResultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ListBlobsResultTupleSchemeFactory()); + } + + private List<String> keys; // required + private String session; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + KEYS((short)1, "keys"), + SESSION((short)2, "session"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // KEYS + return KEYS; + case 2: // SESSION + return SESSION; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.KEYS, new org.apache.thrift.meta_data.FieldMetaData("keys", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + tmpMap.put(_Fields.SESSION, new org.apache.thrift.meta_data.FieldMetaData("session", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ListBlobsResult.class, metaDataMap); + } + + public ListBlobsResult() { + } + + public ListBlobsResult( + List<String> keys, + String session) + { + this(); + this.keys = keys; + this.session = session; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public ListBlobsResult(ListBlobsResult other) { + if (other.is_set_keys()) { + List<String> __this__keys = new ArrayList<String>(other.keys); + this.keys = __this__keys; + } + if (other.is_set_session()) { + this.session = other.session; + } + } + + public ListBlobsResult deepCopy() { + return new ListBlobsResult(this); + } + + @Override + public void clear() { + this.keys = null; + this.session = null; + } + + public int get_keys_size() { + return (this.keys == null) ? 0 : this.keys.size(); + } + + public java.util.Iterator<String> get_keys_iterator() { + return (this.keys == null) ? null : this.keys.iterator(); + } + + public void add_to_keys(String elem) { + if (this.keys == null) { + this.keys = new ArrayList<String>(); + } + this.keys.add(elem); + } + + public List<String> get_keys() { + return this.keys; + } + + public void set_keys(List<String> keys) { + this.keys = keys; + } + + public void unset_keys() { + this.keys = null; + } + + /** Returns true if field keys is set (has been assigned a value) and false otherwise */ + public boolean is_set_keys() { + return this.keys != null; + } + + public void set_keys_isSet(boolean value) { + if (!value) { + this.keys = null; + } + } + + public String get_session() { + return this.session; + } + + public void set_session(String session) { + this.session = session; + } + + public void unset_session() { + this.session = null; + } + + /** Returns true if field session is set (has been assigned a value) and false otherwise */ + public boolean is_set_session() { + return this.session != null; + } + + public void set_session_isSet(boolean value) { + if (!value) { + this.session = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case KEYS: + if (value == null) { + unset_keys(); + } else { + set_keys((List<String>)value); + } + break; + + case SESSION: + if (value == null) { + unset_session(); + } else { + set_session((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case KEYS: + return get_keys(); + + case SESSION: + return get_session(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case KEYS: + return is_set_keys(); + case SESSION: + return is_set_session(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof ListBlobsResult) + return this.equals((ListBlobsResult)that); + return false; + } + + public boolean equals(ListBlobsResult that) { + if (that == null) + return false; + + boolean this_present_keys = true && this.is_set_keys(); + boolean that_present_keys = true && that.is_set_keys(); + if (this_present_keys || that_present_keys) { + if (!(this_present_keys && that_present_keys)) + return false; + if (!this.keys.equals(that.keys)) + return false; + } + + boolean this_present_session = true && this.is_set_session(); + boolean that_present_session = true && that.is_set_session(); + if (this_present_session || that_present_session) { + if (!(this_present_session && that_present_session)) + return false; + if (!this.session.equals(that.session)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_keys = true && (is_set_keys()); + list.add(present_keys); + if (present_keys) + list.add(keys); + + boolean present_session = true && (is_set_session()); + list.add(present_session); + if (present_session) + list.add(session); + + return list.hashCode(); + } + + @Override + public int compareTo(ListBlobsResult other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(is_set_keys()).compareTo(other.is_set_keys()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_keys()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.keys, other.keys); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(is_set_session()).compareTo(other.is_set_session()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_session()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, other.session); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("ListBlobsResult("); + boolean first = true; + + sb.append("keys:"); + if (this.keys == null) { + sb.append("null"); + } else { + sb.append(this.keys); + } + first = false; + if (!first) sb.append(", "); + sb.append("session:"); + if (this.session == null) { + sb.append("null"); + } else { + sb.append(this.session); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!is_set_keys()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'keys' is unset! Struct:" + toString()); + } + + if (!is_set_session()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'session' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class ListBlobsResultStandardSchemeFactory implements SchemeFactory { + public ListBlobsResultStandardScheme getScheme() { + return new ListBlobsResultStandardScheme(); + } + } + + private static class ListBlobsResultStandardScheme extends StandardScheme<ListBlobsResult> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, ListBlobsResult struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // KEYS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list496 = iprot.readListBegin(); + struct.keys = new ArrayList<String>(_list496.size); + String _elem497; + for (int _i498 = 0; _i498 < _list496.size; ++_i498) + { + _elem497 = iprot.readString(); + struct.keys.add(_elem497); + } + iprot.readListEnd(); + } + struct.set_keys_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // SESSION + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.session = iprot.readString(); + struct.set_session_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, ListBlobsResult struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.keys != null) { + oprot.writeFieldBegin(KEYS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.keys.size())); + for (String _iter499 : struct.keys) + { + oprot.writeString(_iter499); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.session != null) { + oprot.writeFieldBegin(SESSION_FIELD_DESC); + oprot.writeString(struct.session); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ListBlobsResultTupleSchemeFactory implements SchemeFactory { + public ListBlobsResultTupleScheme getScheme() { + return new ListBlobsResultTupleScheme(); + } + } + + private static class ListBlobsResultTupleScheme extends TupleScheme<ListBlobsResult> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, ListBlobsResult struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.keys.size()); + for (String _iter500 : struct.keys) + { + oprot.writeString(_iter500); + } + } + oprot.writeString(struct.session); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, ListBlobsResult struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list501 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.keys = new ArrayList<String>(_list501.size); + String _elem502; + for (int _i503 = 0; _i503 < _list501.size; ++_i503) + { + _elem502 = iprot.readString(); + struct.keys.add(_elem502); + } + } + struct.set_keys_isSet(true); + struct.session = iprot.readString(); + struct.set_session_isSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java b/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java index a36e654..68bdd1d 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java +++ b/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java @@ -549,14 +549,14 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment, case 2: // EXECUTORS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list628 = iprot.readListBegin(); - struct.executors = new ArrayList<ExecutorInfo>(_list628.size); - ExecutorInfo _elem629; - for (int _i630 = 0; _i630 < _list628.size; ++_i630) + org.apache.thrift.protocol.TList _list644 = iprot.readListBegin(); + struct.executors = new ArrayList<ExecutorInfo>(_list644.size); + ExecutorInfo _elem645; + for (int _i646 = 0; _i646 < _list644.size; ++_i646) { - _elem629 = new ExecutorInfo(); - _elem629.read(iprot); - struct.executors.add(_elem629); + _elem645 = new ExecutorInfo(); + _elem645.read(iprot); + struct.executors.add(_elem645); } iprot.readListEnd(); } @@ -596,9 +596,9 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment, oprot.writeFieldBegin(EXECUTORS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.executors.size())); - for (ExecutorInfo _iter631 : struct.executors) + for (ExecutorInfo _iter647 : struct.executors) { - _iter631.write(oprot); + _iter647.write(oprot); } oprot.writeListEnd(); } @@ -631,9 +631,9 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment, oprot.writeString(struct.topology_id); { oprot.writeI32(struct.executors.size()); - for (ExecutorInfo _iter632 : struct.executors) + for (ExecutorInfo _iter648 : struct.executors) { - _iter632.write(oprot); + _iter648.write(oprot); } } BitSet optionals = new BitSet(); @@ -652,14 +652,14 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment, struct.topology_id = iprot.readString(); struct.set_topology_id_isSet(true); { - org.apache.thrift.protocol.TList _list633 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executors = new ArrayList<ExecutorInfo>(_list633.size); - ExecutorInfo _elem634; - for (int _i635 = 0; _i635 < _list633.size; ++_i635) + org.apache.thrift.protocol.TList _list649 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.executors = new ArrayList<ExecutorInfo>(_list649.size); + ExecutorInfo _elem650; + for (int _i651 = 0; _i651 < _list649.size; ++_i651) { - _elem634 = new ExecutorInfo(); - _elem634.read(iprot); - struct.executors.add(_elem634); + _elem650 = new ExecutorInfo(); + _elem650.read(iprot); + struct.executors.add(_elem650); } } struct.set_executors_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java b/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java index 7340926..538018c 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java +++ b/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java @@ -376,16 +376,16 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L case 1: // SERIALIZED_PARTS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map618 = iprot.readMapBegin(); - struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map618.size); - String _key619; - ThriftSerializedObject _val620; - for (int _i621 = 0; _i621 < _map618.size; ++_i621) + org.apache.thrift.protocol.TMap _map634 = iprot.readMapBegin(); + struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map634.size); + String _key635; + ThriftSerializedObject _val636; + for (int _i637 = 0; _i637 < _map634.size; ++_i637) { - _key619 = iprot.readString(); - _val620 = new ThriftSerializedObject(); - _val620.read(iprot); - struct.serialized_parts.put(_key619, _val620); + _key635 = iprot.readString(); + _val636 = new ThriftSerializedObject(); + _val636.read(iprot); + struct.serialized_parts.put(_key635, _val636); } iprot.readMapEnd(); } @@ -411,10 +411,10 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L oprot.writeFieldBegin(SERIALIZED_PARTS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.serialized_parts.size())); - for (Map.Entry<String, ThriftSerializedObject> _iter622 : struct.serialized_parts.entrySet()) + for (Map.Entry<String, ThriftSerializedObject> _iter638 : struct.serialized_parts.entrySet()) { - oprot.writeString(_iter622.getKey()); - _iter622.getValue().write(oprot); + oprot.writeString(_iter638.getKey()); + _iter638.getValue().write(oprot); } oprot.writeMapEnd(); } @@ -439,10 +439,10 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.serialized_parts.size()); - for (Map.Entry<String, ThriftSerializedObject> _iter623 : struct.serialized_parts.entrySet()) + for (Map.Entry<String, ThriftSerializedObject> _iter639 : struct.serialized_parts.entrySet()) { - oprot.writeString(_iter623.getKey()); - _iter623.getValue().write(oprot); + oprot.writeString(_iter639.getKey()); + _iter639.getValue().write(oprot); } } } @@ -451,16 +451,16 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L public void read(org.apache.thrift.protocol.TProtocol prot, LocalStateData struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map624 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map624.size); - String _key625; - ThriftSerializedObject _val626; - for (int _i627 = 0; _i627 < _map624.size; ++_i627) + org.apache.thrift.protocol.TMap _map640 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map640.size); + String _key641; + ThriftSerializedObject _val642; + for (int _i643 = 0; _i643 < _map640.size; ++_i643) { - _key625 = iprot.readString(); - _val626 = new ThriftSerializedObject(); - _val626.read(iprot); - struct.serialized_parts.put(_key625, _val626); + _key641 = iprot.readString(); + _val642 = new ThriftSerializedObject(); + _val642.read(iprot); + struct.serialized_parts.put(_key641, _val642); } } struct.set_serialized_parts_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7029aee5/storm-core/src/jvm/backtype/storm/generated/LogConfig.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/LogConfig.java b/storm-core/src/jvm/backtype/storm/generated/LogConfig.java index 53bc326..36090f7 100644 --- a/storm-core/src/jvm/backtype/storm/generated/LogConfig.java +++ b/storm-core/src/jvm/backtype/storm/generated/LogConfig.java @@ -368,16 +368,16 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._ case 2: // NAMED_LOGGER_LEVEL if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map688 = iprot.readMapBegin(); - struct.named_logger_level = new HashMap<String,LogLevel>(2*_map688.size); - String _key689; - LogLevel _val690; - for (int _i691 = 0; _i691 < _map688.size; ++_i691) + org.apache.thrift.protocol.TMap _map704 = iprot.readMapBegin(); + struct.named_logger_level = new HashMap<String,LogLevel>(2*_map704.size); + String _key705; + LogLevel _val706; + for (int _i707 = 0; _i707 < _map704.size; ++_i707) { - _key689 = iprot.readString(); - _val690 = new LogLevel(); - _val690.read(iprot); - struct.named_logger_level.put(_key689, _val690); + _key705 = iprot.readString(); + _val706 = new LogLevel(); + _val706.read(iprot); + struct.named_logger_level.put(_key705, _val706); } iprot.readMapEnd(); } @@ -404,10 +404,10 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._ oprot.writeFieldBegin(NAMED_LOGGER_LEVEL_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.named_logger_level.size())); - for (Map.Entry<String, LogLevel> _iter692 : struct.named_logger_level.entrySet()) + for (Map.Entry<String, LogLevel> _iter708 : struct.named_logger_level.entrySet()) { - oprot.writeString(_iter692.getKey()); - _iter692.getValue().write(oprot); + oprot.writeString(_iter708.getKey()); + _iter708.getValue().write(oprot); } oprot.writeMapEnd(); } @@ -439,10 +439,10 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._ if (struct.is_set_named_logger_level()) { { oprot.writeI32(struct.named_logger_level.size()); - for (Map.Entry<String, LogLevel> _iter693 : struct.named_logger_level.entrySet()) + for (Map.Entry<String, LogLevel> _iter709 : struct.named_logger_level.entrySet()) { - oprot.writeString(_iter693.getKey()); - _iter693.getValue().write(oprot); + oprot.writeString(_iter709.getKey()); + _iter709.getValue().write(oprot); } } } @@ -454,16 +454,16 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._ BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TMap _map694 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.named_logger_level = new HashMap<String,LogLevel>(2*_map694.size); - String _key695; - LogLevel _val696; - for (int _i697 = 0; _i697 < _map694.size; ++_i697) + org.apache.thrift.protocol.TMap _map710 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.named_logger_level = new HashMap<String,LogLevel>(2*_map710.size); + String _key711; + LogLevel _val712; + for (int _i713 = 0; _i713 < _map710.size; ++_i713) { - _key695 = iprot.readString(); - _val696 = new LogLevel(); - _val696.read(iprot); - struct.named_logger_level.put(_key695, _val696); + _key711 = iprot.readString(); + _val712 = new LogLevel(); + _val712.read(iprot); + struct.named_logger_level.put(_key711, _val712); } } struct.set_named_logger_level_isSet(true);
