http://git-wip-us.apache.org/repos/asf/hive/blob/0a328f03/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnsSnapshot.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnsSnapshot.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnsSnapshot.java deleted file mode 100644 index 5600bda..0000000 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnsSnapshot.java +++ /dev/null @@ -1,537 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.hadoop.hive.metastore.api; - -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)") [email protected] @org.apache.hadoop.classification.InterfaceStability.Stable public class TxnsSnapshot implements org.apache.thrift.TBase<TxnsSnapshot, TxnsSnapshot._Fields>, java.io.Serializable, Cloneable, Comparable<TxnsSnapshot> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnsSnapshot"); - - private static final org.apache.thrift.protocol.TField TXN_HIGH_WATER_MARK_FIELD_DESC = new org.apache.thrift.protocol.TField("txn_high_water_mark", org.apache.thrift.protocol.TType.I64, (short)1); - private static final org.apache.thrift.protocol.TField OPEN_TXNS_FIELD_DESC = new org.apache.thrift.protocol.TField("open_txns", org.apache.thrift.protocol.TType.LIST, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new TxnsSnapshotStandardSchemeFactory()); - schemes.put(TupleScheme.class, new TxnsSnapshotTupleSchemeFactory()); - } - - private long txn_high_water_mark; // required - private List<Long> open_txns; // 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 { - TXN_HIGH_WATER_MARK((short)1, "txn_high_water_mark"), - OPEN_TXNS((short)2, "open_txns"); - - 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: // TXN_HIGH_WATER_MARK - return TXN_HIGH_WATER_MARK; - case 2: // OPEN_TXNS - return OPEN_TXNS; - 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 - private static final int __TXN_HIGH_WATER_MARK_ISSET_ID = 0; - private byte __isset_bitfield = 0; - 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.TXN_HIGH_WATER_MARK, new org.apache.thrift.meta_data.FieldMetaData("txn_high_water_mark", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.OPEN_TXNS, new org.apache.thrift.meta_data.FieldMetaData("open_txns", 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.I64)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TxnsSnapshot.class, metaDataMap); - } - - public TxnsSnapshot() { - } - - public TxnsSnapshot( - long txn_high_water_mark, - List<Long> open_txns) - { - this(); - this.txn_high_water_mark = txn_high_water_mark; - setTxn_high_water_markIsSet(true); - this.open_txns = open_txns; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public TxnsSnapshot(TxnsSnapshot other) { - __isset_bitfield = other.__isset_bitfield; - this.txn_high_water_mark = other.txn_high_water_mark; - if (other.isSetOpen_txns()) { - List<Long> __this__open_txns = new ArrayList<Long>(other.open_txns); - this.open_txns = __this__open_txns; - } - } - - public TxnsSnapshot deepCopy() { - return new TxnsSnapshot(this); - } - - @Override - public void clear() { - setTxn_high_water_markIsSet(false); - this.txn_high_water_mark = 0; - this.open_txns = null; - } - - public long getTxn_high_water_mark() { - return this.txn_high_water_mark; - } - - public void setTxn_high_water_mark(long txn_high_water_mark) { - this.txn_high_water_mark = txn_high_water_mark; - setTxn_high_water_markIsSet(true); - } - - public void unsetTxn_high_water_mark() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TXN_HIGH_WATER_MARK_ISSET_ID); - } - - /** Returns true if field txn_high_water_mark is set (has been assigned a value) and false otherwise */ - public boolean isSetTxn_high_water_mark() { - return EncodingUtils.testBit(__isset_bitfield, __TXN_HIGH_WATER_MARK_ISSET_ID); - } - - public void setTxn_high_water_markIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXN_HIGH_WATER_MARK_ISSET_ID, value); - } - - public int getOpen_txnsSize() { - return (this.open_txns == null) ? 0 : this.open_txns.size(); - } - - public java.util.Iterator<Long> getOpen_txnsIterator() { - return (this.open_txns == null) ? null : this.open_txns.iterator(); - } - - public void addToOpen_txns(long elem) { - if (this.open_txns == null) { - this.open_txns = new ArrayList<Long>(); - } - this.open_txns.add(elem); - } - - public List<Long> getOpen_txns() { - return this.open_txns; - } - - public void setOpen_txns(List<Long> open_txns) { - this.open_txns = open_txns; - } - - public void unsetOpen_txns() { - this.open_txns = null; - } - - /** Returns true if field open_txns is set (has been assigned a value) and false otherwise */ - public boolean isSetOpen_txns() { - return this.open_txns != null; - } - - public void setOpen_txnsIsSet(boolean value) { - if (!value) { - this.open_txns = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TXN_HIGH_WATER_MARK: - if (value == null) { - unsetTxn_high_water_mark(); - } else { - setTxn_high_water_mark((Long)value); - } - break; - - case OPEN_TXNS: - if (value == null) { - unsetOpen_txns(); - } else { - setOpen_txns((List<Long>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TXN_HIGH_WATER_MARK: - return getTxn_high_water_mark(); - - case OPEN_TXNS: - return getOpen_txns(); - - } - 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 TXN_HIGH_WATER_MARK: - return isSetTxn_high_water_mark(); - case OPEN_TXNS: - return isSetOpen_txns(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof TxnsSnapshot) - return this.equals((TxnsSnapshot)that); - return false; - } - - public boolean equals(TxnsSnapshot that) { - if (that == null) - return false; - - boolean this_present_txn_high_water_mark = true; - boolean that_present_txn_high_water_mark = true; - if (this_present_txn_high_water_mark || that_present_txn_high_water_mark) { - if (!(this_present_txn_high_water_mark && that_present_txn_high_water_mark)) - return false; - if (this.txn_high_water_mark != that.txn_high_water_mark) - return false; - } - - boolean this_present_open_txns = true && this.isSetOpen_txns(); - boolean that_present_open_txns = true && that.isSetOpen_txns(); - if (this_present_open_txns || that_present_open_txns) { - if (!(this_present_open_txns && that_present_open_txns)) - return false; - if (!this.open_txns.equals(that.open_txns)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_txn_high_water_mark = true; - list.add(present_txn_high_water_mark); - if (present_txn_high_water_mark) - list.add(txn_high_water_mark); - - boolean present_open_txns = true && (isSetOpen_txns()); - list.add(present_open_txns); - if (present_open_txns) - list.add(open_txns); - - return list.hashCode(); - } - - @Override - public int compareTo(TxnsSnapshot other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetTxn_high_water_mark()).compareTo(other.isSetTxn_high_water_mark()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTxn_high_water_mark()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txn_high_water_mark, other.txn_high_water_mark); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetOpen_txns()).compareTo(other.isSetOpen_txns()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetOpen_txns()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.open_txns, other.open_txns); - 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("TxnsSnapshot("); - boolean first = true; - - sb.append("txn_high_water_mark:"); - sb.append(this.txn_high_water_mark); - first = false; - if (!first) sb.append(", "); - sb.append("open_txns:"); - if (this.open_txns == null) { - sb.append("null"); - } else { - sb.append(this.open_txns); - } - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!isSetTxn_high_water_mark()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'txn_high_water_mark' is unset! Struct:" + toString()); - } - - if (!isSetOpen_txns()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'open_txns' 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 { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - 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 TxnsSnapshotStandardSchemeFactory implements SchemeFactory { - public TxnsSnapshotStandardScheme getScheme() { - return new TxnsSnapshotStandardScheme(); - } - } - - private static class TxnsSnapshotStandardScheme extends StandardScheme<TxnsSnapshot> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, TxnsSnapshot 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: // TXN_HIGH_WATER_MARK - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.txn_high_water_mark = iprot.readI64(); - struct.setTxn_high_water_markIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // OPEN_TXNS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list624 = iprot.readListBegin(); - struct.open_txns = new ArrayList<Long>(_list624.size); - long _elem625; - for (int _i626 = 0; _i626 < _list624.size; ++_i626) - { - _elem625 = iprot.readI64(); - struct.open_txns.add(_elem625); - } - iprot.readListEnd(); - } - struct.setOpen_txnsIsSet(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, TxnsSnapshot struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - oprot.writeFieldBegin(TXN_HIGH_WATER_MARK_FIELD_DESC); - oprot.writeI64(struct.txn_high_water_mark); - oprot.writeFieldEnd(); - if (struct.open_txns != null) { - oprot.writeFieldBegin(OPEN_TXNS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.open_txns.size())); - for (long _iter627 : struct.open_txns) - { - oprot.writeI64(_iter627); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class TxnsSnapshotTupleSchemeFactory implements SchemeFactory { - public TxnsSnapshotTupleScheme getScheme() { - return new TxnsSnapshotTupleScheme(); - } - } - - private static class TxnsSnapshotTupleScheme extends TupleScheme<TxnsSnapshot> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, TxnsSnapshot struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeI64(struct.txn_high_water_mark); - { - oprot.writeI32(struct.open_txns.size()); - for (long _iter628 : struct.open_txns) - { - oprot.writeI64(_iter628); - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, TxnsSnapshot struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.txn_high_water_mark = iprot.readI64(); - struct.setTxn_high_water_markIsSet(true); - { - org.apache.thrift.protocol.TList _list629 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.open_txns = new ArrayList<Long>(_list629.size); - long _elem630; - for (int _i631 = 0; _i631 < _list629.size; ++_i631) - { - _elem630 = iprot.readI64(); - struct.open_txns.add(_elem630); - } - } - struct.setOpen_txnsIsSet(true); - } - } - -} -
http://git-wip-us.apache.org/repos/asf/hive/blob/0a328f03/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java index 342e6b0..d545e66 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // UNIQUE_CONSTRAINTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list348 = iprot.readListBegin(); - struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list348.size); - SQLUniqueConstraint _elem349; - for (int _i350 = 0; _i350 < _list348.size; ++_i350) + org.apache.thrift.protocol.TList _list338 = iprot.readListBegin(); + struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list338.size); + SQLUniqueConstraint _elem339; + for (int _i340 = 0; _i340 < _list338.size; ++_i340) { - _elem349 = new SQLUniqueConstraint(); - _elem349.read(iprot); - struct.uniqueConstraints.add(_elem349); + _elem339 = new SQLUniqueConstraint(); + _elem339.read(iprot); + struct.uniqueConstraints.add(_elem339); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(UNIQUE_CONSTRAINTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraints.size())); - for (SQLUniqueConstraint _iter351 : struct.uniqueConstraints) + for (SQLUniqueConstraint _iter341 : struct.uniqueConstraints) { - _iter351.write(oprot); + _iter341.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.uniqueConstraints.size()); - for (SQLUniqueConstraint _iter352 : struct.uniqueConstraints) + for (SQLUniqueConstraint _iter342 : struct.uniqueConstraints) { - _iter352.write(oprot); + _iter342.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list353 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list353.size); - SQLUniqueConstraint _elem354; - for (int _i355 = 0; _i355 < _list353.size; ++_i355) + org.apache.thrift.protocol.TList _list343 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list343.size); + SQLUniqueConstraint _elem344; + for (int _i345 = 0; _i345 < _list343.size; ++_i345) { - _elem354 = new SQLUniqueConstraint(); - _elem354.read(iprot); - struct.uniqueConstraints.add(_elem354); + _elem344 = new SQLUniqueConstraint(); + _elem344.read(iprot); + struct.uniqueConstraints.add(_elem344); } } struct.setUniqueConstraintsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/0a328f03/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java index c9988c0..01654c7 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java @@ -755,14 +755,14 @@ import org.slf4j.LoggerFactory; case 2: // POOLS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list764 = iprot.readListBegin(); - struct.pools = new ArrayList<WMPool>(_list764.size); - WMPool _elem765; - for (int _i766 = 0; _i766 < _list764.size; ++_i766) + org.apache.thrift.protocol.TList _list754 = iprot.readListBegin(); + struct.pools = new ArrayList<WMPool>(_list754.size); + WMPool _elem755; + for (int _i756 = 0; _i756 < _list754.size; ++_i756) { - _elem765 = new WMPool(); - _elem765.read(iprot); - struct.pools.add(_elem765); + _elem755 = new WMPool(); + _elem755.read(iprot); + struct.pools.add(_elem755); } iprot.readListEnd(); } @@ -774,14 +774,14 @@ import org.slf4j.LoggerFactory; case 3: // MAPPINGS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list767 = iprot.readListBegin(); - struct.mappings = new ArrayList<WMMapping>(_list767.size); - WMMapping _elem768; - for (int _i769 = 0; _i769 < _list767.size; ++_i769) + org.apache.thrift.protocol.TList _list757 = iprot.readListBegin(); + struct.mappings = new ArrayList<WMMapping>(_list757.size); + WMMapping _elem758; + for (int _i759 = 0; _i759 < _list757.size; ++_i759) { - _elem768 = new WMMapping(); - _elem768.read(iprot); - struct.mappings.add(_elem768); + _elem758 = new WMMapping(); + _elem758.read(iprot); + struct.mappings.add(_elem758); } iprot.readListEnd(); } @@ -793,14 +793,14 @@ import org.slf4j.LoggerFactory; case 4: // TRIGGERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list770 = iprot.readListBegin(); - struct.triggers = new ArrayList<WMTrigger>(_list770.size); - WMTrigger _elem771; - for (int _i772 = 0; _i772 < _list770.size; ++_i772) + org.apache.thrift.protocol.TList _list760 = iprot.readListBegin(); + struct.triggers = new ArrayList<WMTrigger>(_list760.size); + WMTrigger _elem761; + for (int _i762 = 0; _i762 < _list760.size; ++_i762) { - _elem771 = new WMTrigger(); - _elem771.read(iprot); - struct.triggers.add(_elem771); + _elem761 = new WMTrigger(); + _elem761.read(iprot); + struct.triggers.add(_elem761); } iprot.readListEnd(); } @@ -812,14 +812,14 @@ import org.slf4j.LoggerFactory; case 5: // POOL_TRIGGERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list773 = iprot.readListBegin(); - struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list773.size); - WMPoolTrigger _elem774; - for (int _i775 = 0; _i775 < _list773.size; ++_i775) + org.apache.thrift.protocol.TList _list763 = iprot.readListBegin(); + struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list763.size); + WMPoolTrigger _elem764; + for (int _i765 = 0; _i765 < _list763.size; ++_i765) { - _elem774 = new WMPoolTrigger(); - _elem774.read(iprot); - struct.poolTriggers.add(_elem774); + _elem764 = new WMPoolTrigger(); + _elem764.read(iprot); + struct.poolTriggers.add(_elem764); } iprot.readListEnd(); } @@ -850,9 +850,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(POOLS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.pools.size())); - for (WMPool _iter776 : struct.pools) + for (WMPool _iter766 : struct.pools) { - _iter776.write(oprot); + _iter766.write(oprot); } oprot.writeListEnd(); } @@ -863,9 +863,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(MAPPINGS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mappings.size())); - for (WMMapping _iter777 : struct.mappings) + for (WMMapping _iter767 : struct.mappings) { - _iter777.write(oprot); + _iter767.write(oprot); } oprot.writeListEnd(); } @@ -877,9 +877,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TRIGGERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size())); - for (WMTrigger _iter778 : struct.triggers) + for (WMTrigger _iter768 : struct.triggers) { - _iter778.write(oprot); + _iter768.write(oprot); } oprot.writeListEnd(); } @@ -891,9 +891,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(POOL_TRIGGERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.poolTriggers.size())); - for (WMPoolTrigger _iter779 : struct.poolTriggers) + for (WMPoolTrigger _iter769 : struct.poolTriggers) { - _iter779.write(oprot); + _iter769.write(oprot); } oprot.writeListEnd(); } @@ -920,9 +920,9 @@ import org.slf4j.LoggerFactory; struct.plan.write(oprot); { oprot.writeI32(struct.pools.size()); - for (WMPool _iter780 : struct.pools) + for (WMPool _iter770 : struct.pools) { - _iter780.write(oprot); + _iter770.write(oprot); } } BitSet optionals = new BitSet(); @@ -939,27 +939,27 @@ import org.slf4j.LoggerFactory; if (struct.isSetMappings()) { { oprot.writeI32(struct.mappings.size()); - for (WMMapping _iter781 : struct.mappings) + for (WMMapping _iter771 : struct.mappings) { - _iter781.write(oprot); + _iter771.write(oprot); } } } if (struct.isSetTriggers()) { { oprot.writeI32(struct.triggers.size()); - for (WMTrigger _iter782 : struct.triggers) + for (WMTrigger _iter772 : struct.triggers) { - _iter782.write(oprot); + _iter772.write(oprot); } } } if (struct.isSetPoolTriggers()) { { oprot.writeI32(struct.poolTriggers.size()); - for (WMPoolTrigger _iter783 : struct.poolTriggers) + for (WMPoolTrigger _iter773 : struct.poolTriggers) { - _iter783.write(oprot); + _iter773.write(oprot); } } } @@ -972,56 +972,56 @@ import org.slf4j.LoggerFactory; struct.plan.read(iprot); struct.setPlanIsSet(true); { - org.apache.thrift.protocol.TList _list784 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.pools = new ArrayList<WMPool>(_list784.size); - WMPool _elem785; - for (int _i786 = 0; _i786 < _list784.size; ++_i786) + org.apache.thrift.protocol.TList _list774 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.pools = new ArrayList<WMPool>(_list774.size); + WMPool _elem775; + for (int _i776 = 0; _i776 < _list774.size; ++_i776) { - _elem785 = new WMPool(); - _elem785.read(iprot); - struct.pools.add(_elem785); + _elem775 = new WMPool(); + _elem775.read(iprot); + struct.pools.add(_elem775); } } struct.setPoolsIsSet(true); BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list787 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.mappings = new ArrayList<WMMapping>(_list787.size); - WMMapping _elem788; - for (int _i789 = 0; _i789 < _list787.size; ++_i789) + org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.mappings = new ArrayList<WMMapping>(_list777.size); + WMMapping _elem778; + for (int _i779 = 0; _i779 < _list777.size; ++_i779) { - _elem788 = new WMMapping(); - _elem788.read(iprot); - struct.mappings.add(_elem788); + _elem778 = new WMMapping(); + _elem778.read(iprot); + struct.mappings.add(_elem778); } } struct.setMappingsIsSet(true); } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list790 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.triggers = new ArrayList<WMTrigger>(_list790.size); - WMTrigger _elem791; - for (int _i792 = 0; _i792 < _list790.size; ++_i792) + org.apache.thrift.protocol.TList _list780 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.triggers = new ArrayList<WMTrigger>(_list780.size); + WMTrigger _elem781; + for (int _i782 = 0; _i782 < _list780.size; ++_i782) { - _elem791 = new WMTrigger(); - _elem791.read(iprot); - struct.triggers.add(_elem791); + _elem781 = new WMTrigger(); + _elem781.read(iprot); + struct.triggers.add(_elem781); } } struct.setTriggersIsSet(true); } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list793.size); - WMPoolTrigger _elem794; - for (int _i795 = 0; _i795 < _list793.size; ++_i795) + org.apache.thrift.protocol.TList _list783 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list783.size); + WMPoolTrigger _elem784; + for (int _i785 = 0; _i785 < _list783.size; ++_i785) { - _elem794 = new WMPoolTrigger(); - _elem794.read(iprot); - struct.poolTriggers.add(_elem794); + _elem784 = new WMPoolTrigger(); + _elem784.read(iprot); + struct.poolTriggers.add(_elem784); } } struct.setPoolTriggersIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/0a328f03/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java index fb96ad9..69ccf53 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java @@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory; case 1: // RESOURCE_PLANS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list796 = iprot.readListBegin(); - struct.resourcePlans = new ArrayList<WMResourcePlan>(_list796.size); - WMResourcePlan _elem797; - for (int _i798 = 0; _i798 < _list796.size; ++_i798) + org.apache.thrift.protocol.TList _list786 = iprot.readListBegin(); + struct.resourcePlans = new ArrayList<WMResourcePlan>(_list786.size); + WMResourcePlan _elem787; + for (int _i788 = 0; _i788 < _list786.size; ++_i788) { - _elem797 = new WMResourcePlan(); - _elem797.read(iprot); - struct.resourcePlans.add(_elem797); + _elem787 = new WMResourcePlan(); + _elem787.read(iprot); + struct.resourcePlans.add(_elem787); } iprot.readListEnd(); } @@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(RESOURCE_PLANS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.resourcePlans.size())); - for (WMResourcePlan _iter799 : struct.resourcePlans) + for (WMResourcePlan _iter789 : struct.resourcePlans) { - _iter799.write(oprot); + _iter789.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetResourcePlans()) { { oprot.writeI32(struct.resourcePlans.size()); - for (WMResourcePlan _iter800 : struct.resourcePlans) + for (WMResourcePlan _iter790 : struct.resourcePlans) { - _iter800.write(oprot); + _iter790.write(oprot); } } } @@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.resourcePlans = new ArrayList<WMResourcePlan>(_list801.size); - WMResourcePlan _elem802; - for (int _i803 = 0; _i803 < _list801.size; ++_i803) + org.apache.thrift.protocol.TList _list791 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.resourcePlans = new ArrayList<WMResourcePlan>(_list791.size); + WMResourcePlan _elem792; + for (int _i793 = 0; _i793 < _list791.size; ++_i793) { - _elem802 = new WMResourcePlan(); - _elem802.read(iprot); - struct.resourcePlans.add(_elem802); + _elem792 = new WMResourcePlan(); + _elem792.read(iprot); + struct.resourcePlans.add(_elem792); } } struct.setResourcePlansIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/0a328f03/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java index 4d4894a..ee30063 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java @@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory; case 1: // TRIGGERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list820 = iprot.readListBegin(); - struct.triggers = new ArrayList<WMTrigger>(_list820.size); - WMTrigger _elem821; - for (int _i822 = 0; _i822 < _list820.size; ++_i822) + org.apache.thrift.protocol.TList _list810 = iprot.readListBegin(); + struct.triggers = new ArrayList<WMTrigger>(_list810.size); + WMTrigger _elem811; + for (int _i812 = 0; _i812 < _list810.size; ++_i812) { - _elem821 = new WMTrigger(); - _elem821.read(iprot); - struct.triggers.add(_elem821); + _elem811 = new WMTrigger(); + _elem811.read(iprot); + struct.triggers.add(_elem811); } iprot.readListEnd(); } @@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TRIGGERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size())); - for (WMTrigger _iter823 : struct.triggers) + for (WMTrigger _iter813 : struct.triggers) { - _iter823.write(oprot); + _iter813.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetTriggers()) { { oprot.writeI32(struct.triggers.size()); - for (WMTrigger _iter824 : struct.triggers) + for (WMTrigger _iter814 : struct.triggers) { - _iter824.write(oprot); + _iter814.write(oprot); } } } @@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list825 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.triggers = new ArrayList<WMTrigger>(_list825.size); - WMTrigger _elem826; - for (int _i827 = 0; _i827 < _list825.size; ++_i827) + org.apache.thrift.protocol.TList _list815 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.triggers = new ArrayList<WMTrigger>(_list815.size); + WMTrigger _elem816; + for (int _i817 = 0; _i817 < _list815.size; ++_i817) { - _elem826 = new WMTrigger(); - _elem826.read(iprot); - struct.triggers.add(_elem826); + _elem816 = new WMTrigger(); + _elem816.read(iprot); + struct.triggers.add(_elem816); } } struct.setTriggersIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/0a328f03/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java index ea8f3aa..5caf586 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java @@ -441,13 +441,13 @@ import org.slf4j.LoggerFactory; case 1: // ERRORS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list804 = iprot.readListBegin(); - struct.errors = new ArrayList<String>(_list804.size); - String _elem805; - for (int _i806 = 0; _i806 < _list804.size; ++_i806) + org.apache.thrift.protocol.TList _list794 = iprot.readListBegin(); + struct.errors = new ArrayList<String>(_list794.size); + String _elem795; + for (int _i796 = 0; _i796 < _list794.size; ++_i796) { - _elem805 = iprot.readString(); - struct.errors.add(_elem805); + _elem795 = iprot.readString(); + struct.errors.add(_elem795); } iprot.readListEnd(); } @@ -459,13 +459,13 @@ import org.slf4j.LoggerFactory; case 2: // WARNINGS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list807 = iprot.readListBegin(); - struct.warnings = new ArrayList<String>(_list807.size); - String _elem808; - for (int _i809 = 0; _i809 < _list807.size; ++_i809) + org.apache.thrift.protocol.TList _list797 = iprot.readListBegin(); + struct.warnings = new ArrayList<String>(_list797.size); + String _elem798; + for (int _i799 = 0; _i799 < _list797.size; ++_i799) { - _elem808 = iprot.readString(); - struct.warnings.add(_elem808); + _elem798 = iprot.readString(); + struct.warnings.add(_elem798); } iprot.readListEnd(); } @@ -492,9 +492,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(ERRORS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.errors.size())); - for (String _iter810 : struct.errors) + for (String _iter800 : struct.errors) { - oprot.writeString(_iter810); + oprot.writeString(_iter800); } oprot.writeListEnd(); } @@ -506,9 +506,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(WARNINGS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.warnings.size())); - for (String _iter811 : struct.warnings) + for (String _iter801 : struct.warnings) { - oprot.writeString(_iter811); + oprot.writeString(_iter801); } oprot.writeListEnd(); } @@ -543,18 +543,18 @@ import org.slf4j.LoggerFactory; if (struct.isSetErrors()) { { oprot.writeI32(struct.errors.size()); - for (String _iter812 : struct.errors) + for (String _iter802 : struct.errors) { - oprot.writeString(_iter812); + oprot.writeString(_iter802); } } } if (struct.isSetWarnings()) { { oprot.writeI32(struct.warnings.size()); - for (String _iter813 : struct.warnings) + for (String _iter803 : struct.warnings) { - oprot.writeString(_iter813); + oprot.writeString(_iter803); } } } @@ -566,26 +566,26 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list814 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.errors = new ArrayList<String>(_list814.size); - String _elem815; - for (int _i816 = 0; _i816 < _list814.size; ++_i816) + org.apache.thrift.protocol.TList _list804 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.errors = new ArrayList<String>(_list804.size); + String _elem805; + for (int _i806 = 0; _i806 < _list804.size; ++_i806) { - _elem815 = iprot.readString(); - struct.errors.add(_elem815); + _elem805 = iprot.readString(); + struct.errors.add(_elem805); } } struct.setErrorsIsSet(true); } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list817 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.warnings = new ArrayList<String>(_list817.size); - String _elem818; - for (int _i819 = 0; _i819 < _list817.size; ++_i819) + org.apache.thrift.protocol.TList _list807 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.warnings = new ArrayList<String>(_list807.size); + String _elem808; + for (int _i809 = 0; _i809 < _list807.size; ++_i809) { - _elem818 = iprot.readString(); - struct.warnings.add(_elem818); + _elem808 = iprot.readString(); + struct.warnings.add(_elem808); } } struct.setWarningsIsSet(true);
