You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2019/01/29 14:46:49 UTC
[09/11] hive git commit: HIVE-21079: Replicate column statistics for
partitions of partitioned table (Ashutosh Bapat, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java
new file mode 100644
index 0000000..91199e5
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java
@@ -0,0 +1,752 @@
+/**
+ * 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)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class GetPartitionsByNamesRequest implements org.apache.thrift.TBase<GetPartitionsByNamesRequest, GetPartitionsByNamesRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetPartitionsByNamesRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPartitionsByNamesRequest");
+
+ private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("names", org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField GET_COL_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("get_col_stats", org.apache.thrift.protocol.TType.BOOL, (short)4);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetPartitionsByNamesRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetPartitionsByNamesRequestTupleSchemeFactory());
+ }
+
+ private String db_name; // required
+ private String tbl_name; // required
+ private List<String> names; // optional
+ private boolean get_col_stats; // optional
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ DB_NAME((short)1, "db_name"),
+ TBL_NAME((short)2, "tbl_name"),
+ NAMES((short)3, "names"),
+ GET_COL_STATS((short)4, "get_col_stats");
+
+ 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: // DB_NAME
+ return DB_NAME;
+ case 2: // TBL_NAME
+ return TBL_NAME;
+ case 3: // NAMES
+ return NAMES;
+ case 4: // GET_COL_STATS
+ return GET_COL_STATS;
+ 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 __GET_COL_STATS_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.NAMES,_Fields.GET_COL_STATS};
+ 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.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.NAMES, new org.apache.thrift.meta_data.FieldMetaData("names", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ 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.GET_COL_STATS, new org.apache.thrift.meta_data.FieldMetaData("get_col_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetPartitionsByNamesRequest.class, metaDataMap);
+ }
+
+ public GetPartitionsByNamesRequest() {
+ }
+
+ public GetPartitionsByNamesRequest(
+ String db_name,
+ String tbl_name)
+ {
+ this();
+ this.db_name = db_name;
+ this.tbl_name = tbl_name;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetPartitionsByNamesRequest(GetPartitionsByNamesRequest other) {
+ __isset_bitfield = other.__isset_bitfield;
+ if (other.isSetDb_name()) {
+ this.db_name = other.db_name;
+ }
+ if (other.isSetTbl_name()) {
+ this.tbl_name = other.tbl_name;
+ }
+ if (other.isSetNames()) {
+ List<String> __this__names = new ArrayList<String>(other.names);
+ this.names = __this__names;
+ }
+ this.get_col_stats = other.get_col_stats;
+ }
+
+ public GetPartitionsByNamesRequest deepCopy() {
+ return new GetPartitionsByNamesRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ this.db_name = null;
+ this.tbl_name = null;
+ this.names = null;
+ setGet_col_statsIsSet(false);
+ this.get_col_stats = false;
+ }
+
+ public String getDb_name() {
+ return this.db_name;
+ }
+
+ public void setDb_name(String db_name) {
+ this.db_name = db_name;
+ }
+
+ public void unsetDb_name() {
+ this.db_name = null;
+ }
+
+ /** Returns true if field db_name is set (has been assigned a value) and false otherwise */
+ public boolean isSetDb_name() {
+ return this.db_name != null;
+ }
+
+ public void setDb_nameIsSet(boolean value) {
+ if (!value) {
+ this.db_name = null;
+ }
+ }
+
+ public String getTbl_name() {
+ return this.tbl_name;
+ }
+
+ public void setTbl_name(String tbl_name) {
+ this.tbl_name = tbl_name;
+ }
+
+ public void unsetTbl_name() {
+ this.tbl_name = null;
+ }
+
+ /** Returns true if field tbl_name is set (has been assigned a value) and false otherwise */
+ public boolean isSetTbl_name() {
+ return this.tbl_name != null;
+ }
+
+ public void setTbl_nameIsSet(boolean value) {
+ if (!value) {
+ this.tbl_name = null;
+ }
+ }
+
+ public int getNamesSize() {
+ return (this.names == null) ? 0 : this.names.size();
+ }
+
+ public java.util.Iterator<String> getNamesIterator() {
+ return (this.names == null) ? null : this.names.iterator();
+ }
+
+ public void addToNames(String elem) {
+ if (this.names == null) {
+ this.names = new ArrayList<String>();
+ }
+ this.names.add(elem);
+ }
+
+ public List<String> getNames() {
+ return this.names;
+ }
+
+ public void setNames(List<String> names) {
+ this.names = names;
+ }
+
+ public void unsetNames() {
+ this.names = null;
+ }
+
+ /** Returns true if field names is set (has been assigned a value) and false otherwise */
+ public boolean isSetNames() {
+ return this.names != null;
+ }
+
+ public void setNamesIsSet(boolean value) {
+ if (!value) {
+ this.names = null;
+ }
+ }
+
+ public boolean isGet_col_stats() {
+ return this.get_col_stats;
+ }
+
+ public void setGet_col_stats(boolean get_col_stats) {
+ this.get_col_stats = get_col_stats;
+ setGet_col_statsIsSet(true);
+ }
+
+ public void unsetGet_col_stats() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __GET_COL_STATS_ISSET_ID);
+ }
+
+ /** Returns true if field get_col_stats is set (has been assigned a value) and false otherwise */
+ public boolean isSetGet_col_stats() {
+ return EncodingUtils.testBit(__isset_bitfield, __GET_COL_STATS_ISSET_ID);
+ }
+
+ public void setGet_col_statsIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __GET_COL_STATS_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case DB_NAME:
+ if (value == null) {
+ unsetDb_name();
+ } else {
+ setDb_name((String)value);
+ }
+ break;
+
+ case TBL_NAME:
+ if (value == null) {
+ unsetTbl_name();
+ } else {
+ setTbl_name((String)value);
+ }
+ break;
+
+ case NAMES:
+ if (value == null) {
+ unsetNames();
+ } else {
+ setNames((List<String>)value);
+ }
+ break;
+
+ case GET_COL_STATS:
+ if (value == null) {
+ unsetGet_col_stats();
+ } else {
+ setGet_col_stats((Boolean)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case DB_NAME:
+ return getDb_name();
+
+ case TBL_NAME:
+ return getTbl_name();
+
+ case NAMES:
+ return getNames();
+
+ case GET_COL_STATS:
+ return isGet_col_stats();
+
+ }
+ 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 DB_NAME:
+ return isSetDb_name();
+ case TBL_NAME:
+ return isSetTbl_name();
+ case NAMES:
+ return isSetNames();
+ case GET_COL_STATS:
+ return isSetGet_col_stats();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetPartitionsByNamesRequest)
+ return this.equals((GetPartitionsByNamesRequest)that);
+ return false;
+ }
+
+ public boolean equals(GetPartitionsByNamesRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_db_name = true && this.isSetDb_name();
+ boolean that_present_db_name = true && that.isSetDb_name();
+ if (this_present_db_name || that_present_db_name) {
+ if (!(this_present_db_name && that_present_db_name))
+ return false;
+ if (!this.db_name.equals(that.db_name))
+ return false;
+ }
+
+ boolean this_present_tbl_name = true && this.isSetTbl_name();
+ boolean that_present_tbl_name = true && that.isSetTbl_name();
+ if (this_present_tbl_name || that_present_tbl_name) {
+ if (!(this_present_tbl_name && that_present_tbl_name))
+ return false;
+ if (!this.tbl_name.equals(that.tbl_name))
+ return false;
+ }
+
+ boolean this_present_names = true && this.isSetNames();
+ boolean that_present_names = true && that.isSetNames();
+ if (this_present_names || that_present_names) {
+ if (!(this_present_names && that_present_names))
+ return false;
+ if (!this.names.equals(that.names))
+ return false;
+ }
+
+ boolean this_present_get_col_stats = true && this.isSetGet_col_stats();
+ boolean that_present_get_col_stats = true && that.isSetGet_col_stats();
+ if (this_present_get_col_stats || that_present_get_col_stats) {
+ if (!(this_present_get_col_stats && that_present_get_col_stats))
+ return false;
+ if (this.get_col_stats != that.get_col_stats)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_db_name = true && (isSetDb_name());
+ list.add(present_db_name);
+ if (present_db_name)
+ list.add(db_name);
+
+ boolean present_tbl_name = true && (isSetTbl_name());
+ list.add(present_tbl_name);
+ if (present_tbl_name)
+ list.add(tbl_name);
+
+ boolean present_names = true && (isSetNames());
+ list.add(present_names);
+ if (present_names)
+ list.add(names);
+
+ boolean present_get_col_stats = true && (isSetGet_col_stats());
+ list.add(present_get_col_stats);
+ if (present_get_col_stats)
+ list.add(get_col_stats);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetPartitionsByNamesRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetDb_name()).compareTo(other.isSetDb_name());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDb_name()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_name, other.db_name);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTbl_name()).compareTo(other.isSetTbl_name());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTbl_name()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tbl_name, other.tbl_name);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetNames()).compareTo(other.isSetNames());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetNames()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.names, other.names);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetGet_col_stats()).compareTo(other.isSetGet_col_stats());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetGet_col_stats()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.get_col_stats, other.get_col_stats);
+ 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("GetPartitionsByNamesRequest(");
+ boolean first = true;
+
+ sb.append("db_name:");
+ if (this.db_name == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.db_name);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("tbl_name:");
+ if (this.tbl_name == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tbl_name);
+ }
+ first = false;
+ if (isSetNames()) {
+ if (!first) sb.append(", ");
+ sb.append("names:");
+ if (this.names == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.names);
+ }
+ first = false;
+ }
+ if (isSetGet_col_stats()) {
+ if (!first) sb.append(", ");
+ sb.append("get_col_stats:");
+ sb.append(this.get_col_stats);
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetDb_name()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'db_name' is unset! Struct:" + toString());
+ }
+
+ if (!isSetTbl_name()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'tbl_name' 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 GetPartitionsByNamesRequestStandardSchemeFactory implements SchemeFactory {
+ public GetPartitionsByNamesRequestStandardScheme getScheme() {
+ return new GetPartitionsByNamesRequestStandardScheme();
+ }
+ }
+
+ private static class GetPartitionsByNamesRequestStandardScheme extends StandardScheme<GetPartitionsByNamesRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetPartitionsByNamesRequest 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: // DB_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.db_name = iprot.readString();
+ struct.setDb_nameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // TBL_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.tbl_name = iprot.readString();
+ struct.setTbl_nameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NAMES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list554 = iprot.readListBegin();
+ struct.names = new ArrayList<String>(_list554.size);
+ String _elem555;
+ for (int _i556 = 0; _i556 < _list554.size; ++_i556)
+ {
+ _elem555 = iprot.readString();
+ struct.names.add(_elem555);
+ }
+ iprot.readListEnd();
+ }
+ struct.setNamesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // GET_COL_STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.get_col_stats = iprot.readBool();
+ struct.setGet_col_statsIsSet(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, GetPartitionsByNamesRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.db_name != null) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.db_name);
+ oprot.writeFieldEnd();
+ }
+ if (struct.tbl_name != null) {
+ oprot.writeFieldBegin(TBL_NAME_FIELD_DESC);
+ oprot.writeString(struct.tbl_name);
+ oprot.writeFieldEnd();
+ }
+ if (struct.names != null) {
+ if (struct.isSetNames()) {
+ oprot.writeFieldBegin(NAMES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.names.size()));
+ for (String _iter557 : struct.names)
+ {
+ oprot.writeString(_iter557);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.isSetGet_col_stats()) {
+ oprot.writeFieldBegin(GET_COL_STATS_FIELD_DESC);
+ oprot.writeBool(struct.get_col_stats);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetPartitionsByNamesRequestTupleSchemeFactory implements SchemeFactory {
+ public GetPartitionsByNamesRequestTupleScheme getScheme() {
+ return new GetPartitionsByNamesRequestTupleScheme();
+ }
+ }
+
+ private static class GetPartitionsByNamesRequestTupleScheme extends TupleScheme<GetPartitionsByNamesRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeString(struct.db_name);
+ oprot.writeString(struct.tbl_name);
+ BitSet optionals = new BitSet();
+ if (struct.isSetNames()) {
+ optionals.set(0);
+ }
+ if (struct.isSetGet_col_stats()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetNames()) {
+ {
+ oprot.writeI32(struct.names.size());
+ for (String _iter558 : struct.names)
+ {
+ oprot.writeString(_iter558);
+ }
+ }
+ }
+ if (struct.isSetGet_col_stats()) {
+ oprot.writeBool(struct.get_col_stats);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.db_name = iprot.readString();
+ struct.setDb_nameIsSet(true);
+ struct.tbl_name = iprot.readString();
+ struct.setTbl_nameIsSet(true);
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list559 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.names = new ArrayList<String>(_list559.size);
+ String _elem560;
+ for (int _i561 = 0; _i561 < _list559.size; ++_i561)
+ {
+ _elem560 = iprot.readString();
+ struct.names.add(_elem560);
+ }
+ }
+ struct.setNamesIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.get_col_stats = iprot.readBool();
+ struct.setGet_col_statsIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java
new file mode 100644
index 0000000..d32e4c2
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java
@@ -0,0 +1,443 @@
+/**
+ * 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)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class GetPartitionsByNamesResult implements org.apache.thrift.TBase<GetPartitionsByNamesResult, GetPartitionsByNamesResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetPartitionsByNamesResult> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPartitionsByNamesResult");
+
+ private static final org.apache.thrift.protocol.TField PARTITIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("partitions", org.apache.thrift.protocol.TType.LIST, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetPartitionsByNamesResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetPartitionsByNamesResultTupleSchemeFactory());
+ }
+
+ private List<Partition> partitions; // 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 {
+ PARTITIONS((short)1, "partitions");
+
+ 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: // PARTITIONS
+ return PARTITIONS;
+ 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.PARTITIONS, new org.apache.thrift.meta_data.FieldMetaData("partitions", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Partition.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetPartitionsByNamesResult.class, metaDataMap);
+ }
+
+ public GetPartitionsByNamesResult() {
+ }
+
+ public GetPartitionsByNamesResult(
+ List<Partition> partitions)
+ {
+ this();
+ this.partitions = partitions;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetPartitionsByNamesResult(GetPartitionsByNamesResult other) {
+ if (other.isSetPartitions()) {
+ List<Partition> __this__partitions = new ArrayList<Partition>(other.partitions.size());
+ for (Partition other_element : other.partitions) {
+ __this__partitions.add(new Partition(other_element));
+ }
+ this.partitions = __this__partitions;
+ }
+ }
+
+ public GetPartitionsByNamesResult deepCopy() {
+ return new GetPartitionsByNamesResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.partitions = null;
+ }
+
+ public int getPartitionsSize() {
+ return (this.partitions == null) ? 0 : this.partitions.size();
+ }
+
+ public java.util.Iterator<Partition> getPartitionsIterator() {
+ return (this.partitions == null) ? null : this.partitions.iterator();
+ }
+
+ public void addToPartitions(Partition elem) {
+ if (this.partitions == null) {
+ this.partitions = new ArrayList<Partition>();
+ }
+ this.partitions.add(elem);
+ }
+
+ public List<Partition> getPartitions() {
+ return this.partitions;
+ }
+
+ public void setPartitions(List<Partition> partitions) {
+ this.partitions = partitions;
+ }
+
+ public void unsetPartitions() {
+ this.partitions = null;
+ }
+
+ /** Returns true if field partitions is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartitions() {
+ return this.partitions != null;
+ }
+
+ public void setPartitionsIsSet(boolean value) {
+ if (!value) {
+ this.partitions = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case PARTITIONS:
+ if (value == null) {
+ unsetPartitions();
+ } else {
+ setPartitions((List<Partition>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case PARTITIONS:
+ return getPartitions();
+
+ }
+ 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 PARTITIONS:
+ return isSetPartitions();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetPartitionsByNamesResult)
+ return this.equals((GetPartitionsByNamesResult)that);
+ return false;
+ }
+
+ public boolean equals(GetPartitionsByNamesResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_partitions = true && this.isSetPartitions();
+ boolean that_present_partitions = true && that.isSetPartitions();
+ if (this_present_partitions || that_present_partitions) {
+ if (!(this_present_partitions && that_present_partitions))
+ return false;
+ if (!this.partitions.equals(that.partitions))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_partitions = true && (isSetPartitions());
+ list.add(present_partitions);
+ if (present_partitions)
+ list.add(partitions);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetPartitionsByNamesResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetPartitions()).compareTo(other.isSetPartitions());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartitions()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitions, other.partitions);
+ 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("GetPartitionsByNamesResult(");
+ boolean first = true;
+
+ sb.append("partitions:");
+ if (this.partitions == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partitions);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetPartitions()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'partitions' 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 GetPartitionsByNamesResultStandardSchemeFactory implements SchemeFactory {
+ public GetPartitionsByNamesResultStandardScheme getScheme() {
+ return new GetPartitionsByNamesResultStandardScheme();
+ }
+ }
+
+ private static class GetPartitionsByNamesResultStandardScheme extends StandardScheme<GetPartitionsByNamesResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetPartitionsByNamesResult 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: // PARTITIONS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list562 = iprot.readListBegin();
+ struct.partitions = new ArrayList<Partition>(_list562.size);
+ Partition _elem563;
+ for (int _i564 = 0; _i564 < _list562.size; ++_i564)
+ {
+ _elem563 = new Partition();
+ _elem563.read(iprot);
+ struct.partitions.add(_elem563);
+ }
+ iprot.readListEnd();
+ }
+ struct.setPartitionsIsSet(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, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.partitions != null) {
+ oprot.writeFieldBegin(PARTITIONS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size()));
+ for (Partition _iter565 : struct.partitions)
+ {
+ _iter565.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetPartitionsByNamesResultTupleSchemeFactory implements SchemeFactory {
+ public GetPartitionsByNamesResultTupleScheme getScheme() {
+ return new GetPartitionsByNamesResultTupleScheme();
+ }
+ }
+
+ private static class GetPartitionsByNamesResultTupleScheme extends TupleScheme<GetPartitionsByNamesResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.partitions.size());
+ for (Partition _iter566 : struct.partitions)
+ {
+ _iter566.write(oprot);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list567 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.partitions = new ArrayList<Partition>(_list567.size);
+ Partition _elem568;
+ for (int _i569 = 0; _i569 < _list567.size; ++_i569)
+ {
+ _elem568 = new Partition();
+ _elem568.read(iprot);
+ struct.partitions.add(_elem568);
+ }
+ }
+ struct.setPartitionsIsSet(true);
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java
index b5a2b68..27c81f7 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java
@@ -444,13 +444,13 @@ import org.slf4j.LoggerFactory;
case 8: // FILTERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list992 = iprot.readListBegin();
- struct.filters = new ArrayList<String>(_list992.size);
- String _elem993;
- for (int _i994 = 0; _i994 < _list992.size; ++_i994)
+ org.apache.thrift.protocol.TList _list1008 = iprot.readListBegin();
+ struct.filters = new ArrayList<String>(_list1008.size);
+ String _elem1009;
+ for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010)
{
- _elem993 = iprot.readString();
- struct.filters.add(_elem993);
+ _elem1009 = iprot.readString();
+ struct.filters.add(_elem1009);
}
iprot.readListEnd();
}
@@ -484,9 +484,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILTERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filters.size()));
- for (String _iter995 : struct.filters)
+ for (String _iter1011 : struct.filters)
{
- oprot.writeString(_iter995);
+ oprot.writeString(_iter1011);
}
oprot.writeListEnd();
}
@@ -524,9 +524,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFilters()) {
{
oprot.writeI32(struct.filters.size());
- for (String _iter996 : struct.filters)
+ for (String _iter1012 : struct.filters)
{
- oprot.writeString(_iter996);
+ oprot.writeString(_iter1012);
}
}
}
@@ -542,13 +542,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list997 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filters = new ArrayList<String>(_list997.size);
- String _elem998;
- for (int _i999 = 0; _i999 < _list997.size; ++_i999)
+ org.apache.thrift.protocol.TList _list1013 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filters = new ArrayList<String>(_list1013.size);
+ String _elem1014;
+ for (int _i1015 = 0; _i1015 < _list1013.size; ++_i1015)
{
- _elem998 = iprot.readString();
- struct.filters.add(_elem998);
+ _elem1014 = iprot.readString();
+ struct.filters.add(_elem1014);
}
}
struct.setFiltersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java
index e6c9c06..30bae47 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java
@@ -509,13 +509,13 @@ import org.slf4j.LoggerFactory;
case 1: // FIELD_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list984 = iprot.readListBegin();
- struct.fieldList = new ArrayList<String>(_list984.size);
- String _elem985;
- for (int _i986 = 0; _i986 < _list984.size; ++_i986)
+ org.apache.thrift.protocol.TList _list1000 = iprot.readListBegin();
+ struct.fieldList = new ArrayList<String>(_list1000.size);
+ String _elem1001;
+ for (int _i1002 = 0; _i1002 < _list1000.size; ++_i1002)
{
- _elem985 = iprot.readString();
- struct.fieldList.add(_elem985);
+ _elem1001 = iprot.readString();
+ struct.fieldList.add(_elem1001);
}
iprot.readListEnd();
}
@@ -557,9 +557,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FIELD_LIST_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fieldList.size()));
- for (String _iter987 : struct.fieldList)
+ for (String _iter1003 : struct.fieldList)
{
- oprot.writeString(_iter987);
+ oprot.writeString(_iter1003);
}
oprot.writeListEnd();
}
@@ -606,9 +606,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFieldList()) {
{
oprot.writeI32(struct.fieldList.size());
- for (String _iter988 : struct.fieldList)
+ for (String _iter1004 : struct.fieldList)
{
- oprot.writeString(_iter988);
+ oprot.writeString(_iter1004);
}
}
}
@@ -626,13 +626,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list989 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.fieldList = new ArrayList<String>(_list989.size);
- String _elem990;
- for (int _i991 = 0; _i991 < _list989.size; ++_i991)
+ org.apache.thrift.protocol.TList _list1005 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.fieldList = new ArrayList<String>(_list1005.size);
+ String _elem1006;
+ for (int _i1007 = 0; _i1007 < _list1005.size; ++_i1007)
{
- _elem990 = iprot.readString();
- struct.fieldList.add(_elem990);
+ _elem1006 = iprot.readString();
+ struct.fieldList.add(_elem1006);
}
}
struct.setFieldListIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java
index 7ec107e..97e24f8 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java
@@ -960,13 +960,13 @@ import org.slf4j.LoggerFactory;
case 6: // GROUP_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1008 = iprot.readListBegin();
- struct.groupNames = new ArrayList<String>(_list1008.size);
- String _elem1009;
- for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010)
+ org.apache.thrift.protocol.TList _list1024 = iprot.readListBegin();
+ struct.groupNames = new ArrayList<String>(_list1024.size);
+ String _elem1025;
+ for (int _i1026 = 0; _i1026 < _list1024.size; ++_i1026)
{
- _elem1009 = iprot.readString();
- struct.groupNames.add(_elem1009);
+ _elem1025 = iprot.readString();
+ struct.groupNames.add(_elem1025);
}
iprot.readListEnd();
}
@@ -1040,9 +1040,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(GROUP_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.groupNames.size()));
- for (String _iter1011 : struct.groupNames)
+ for (String _iter1027 : struct.groupNames)
{
- oprot.writeString(_iter1011);
+ oprot.writeString(_iter1027);
}
oprot.writeListEnd();
}
@@ -1120,9 +1120,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetGroupNames()) {
{
oprot.writeI32(struct.groupNames.size());
- for (String _iter1012 : struct.groupNames)
+ for (String _iter1028 : struct.groupNames)
{
- oprot.writeString(_iter1012);
+ oprot.writeString(_iter1028);
}
}
}
@@ -1160,13 +1160,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TList _list1013 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.groupNames = new ArrayList<String>(_list1013.size);
- String _elem1014;
- for (int _i1015 = 0; _i1015 < _list1013.size; ++_i1015)
+ org.apache.thrift.protocol.TList _list1029 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.groupNames = new ArrayList<String>(_list1029.size);
+ String _elem1030;
+ for (int _i1031 = 0; _i1031 < _list1029.size; ++_i1031)
{
- _elem1014 = iprot.readString();
- struct.groupNames.add(_elem1014);
+ _elem1030 = iprot.readString();
+ struct.groupNames.add(_elem1030);
}
}
struct.setGroupNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java
index faac848..b8216c8 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java
@@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory;
case 1: // PARTITION_SPEC
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1000 = iprot.readListBegin();
- struct.partitionSpec = new ArrayList<PartitionSpec>(_list1000.size);
- PartitionSpec _elem1001;
- for (int _i1002 = 0; _i1002 < _list1000.size; ++_i1002)
+ org.apache.thrift.protocol.TList _list1016 = iprot.readListBegin();
+ struct.partitionSpec = new ArrayList<PartitionSpec>(_list1016.size);
+ PartitionSpec _elem1017;
+ for (int _i1018 = 0; _i1018 < _list1016.size; ++_i1018)
{
- _elem1001 = new PartitionSpec();
- _elem1001.read(iprot);
- struct.partitionSpec.add(_elem1001);
+ _elem1017 = new PartitionSpec();
+ _elem1017.read(iprot);
+ struct.partitionSpec.add(_elem1017);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITION_SPEC_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitionSpec.size()));
- for (PartitionSpec _iter1003 : struct.partitionSpec)
+ for (PartitionSpec _iter1019 : struct.partitionSpec)
{
- _iter1003.write(oprot);
+ _iter1019.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionSpec()) {
{
oprot.writeI32(struct.partitionSpec.size());
- for (PartitionSpec _iter1004 : struct.partitionSpec)
+ for (PartitionSpec _iter1020 : struct.partitionSpec)
{
- _iter1004.write(oprot);
+ _iter1020.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1005 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.partitionSpec = new ArrayList<PartitionSpec>(_list1005.size);
- PartitionSpec _elem1006;
- for (int _i1007 = 0; _i1007 < _list1005.size; ++_i1007)
+ org.apache.thrift.protocol.TList _list1021 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.partitionSpec = new ArrayList<PartitionSpec>(_list1021.size);
+ PartitionSpec _elem1022;
+ for (int _i1023 = 0; _i1023 < _list1021.size; ++_i1023)
{
- _elem1006 = new PartitionSpec();
- _elem1006.read(iprot);
- struct.partitionSpec.add(_elem1006);
+ _elem1022 = new PartitionSpec();
+ _elem1022.read(iprot);
+ struct.partitionSpec.add(_elem1022);
}
}
struct.setPartitionSpecIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
index da36157..ed9b709 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
@@ -606,13 +606,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list872 = iprot.readListBegin();
- struct.tblNames = new ArrayList<String>(_list872.size);
- String _elem873;
- for (int _i874 = 0; _i874 < _list872.size; ++_i874)
+ org.apache.thrift.protocol.TList _list888 = iprot.readListBegin();
+ struct.tblNames = new ArrayList<String>(_list888.size);
+ String _elem889;
+ for (int _i890 = 0; _i890 < _list888.size; ++_i890)
{
- _elem873 = iprot.readString();
- struct.tblNames.add(_elem873);
+ _elem889 = iprot.readString();
+ struct.tblNames.add(_elem889);
}
iprot.readListEnd();
}
@@ -661,9 +661,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tblNames.size()));
- for (String _iter875 : struct.tblNames)
+ for (String _iter891 : struct.tblNames)
{
- oprot.writeString(_iter875);
+ oprot.writeString(_iter891);
}
oprot.writeListEnd();
}
@@ -716,9 +716,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTblNames()) {
{
oprot.writeI32(struct.tblNames.size());
- for (String _iter876 : struct.tblNames)
+ for (String _iter892 : struct.tblNames)
{
- oprot.writeString(_iter876);
+ oprot.writeString(_iter892);
}
}
}
@@ -738,13 +738,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tblNames = new ArrayList<String>(_list877.size);
- String _elem878;
- for (int _i879 = 0; _i879 < _list877.size; ++_i879)
+ org.apache.thrift.protocol.TList _list893 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tblNames = new ArrayList<String>(_list893.size);
+ String _elem894;
+ for (int _i895 = 0; _i895 < _list893.size; ++_i895)
{
- _elem878 = iprot.readString();
- struct.tblNames.add(_elem878);
+ _elem894 = iprot.readString();
+ struct.tblNames.add(_elem894);
}
}
struct.setTblNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
index b3cfc88..31584b0 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TABLES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list880 = iprot.readListBegin();
- struct.tables = new ArrayList<Table>(_list880.size);
- Table _elem881;
- for (int _i882 = 0; _i882 < _list880.size; ++_i882)
+ org.apache.thrift.protocol.TList _list896 = iprot.readListBegin();
+ struct.tables = new ArrayList<Table>(_list896.size);
+ Table _elem897;
+ for (int _i898 = 0; _i898 < _list896.size; ++_i898)
{
- _elem881 = new Table();
- _elem881.read(iprot);
- struct.tables.add(_elem881);
+ _elem897 = new Table();
+ _elem897.read(iprot);
+ struct.tables.add(_elem897);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tables.size()));
- for (Table _iter883 : struct.tables)
+ for (Table _iter899 : struct.tables)
{
- _iter883.write(oprot);
+ _iter899.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tables.size());
- for (Table _iter884 : struct.tables)
+ for (Table _iter900 : struct.tables)
{
- _iter884.write(oprot);
+ _iter900.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list885 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tables = new ArrayList<Table>(_list885.size);
- Table _elem886;
- for (int _i887 = 0; _i887 < _list885.size; ++_i887)
+ org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tables = new ArrayList<Table>(_list901.size);
+ Table _elem902;
+ for (int _i903 = 0; _i903 < _list901.size; ++_i903)
{
- _elem886 = new Table();
- _elem886.read(iprot);
- struct.tables.add(_elem886);
+ _elem902 = new Table();
+ _elem902.read(iprot);
+ struct.tables.add(_elem902);
}
}
struct.setTablesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
index 1be6d23..70bfbd2 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
@@ -513,13 +513,13 @@ import org.slf4j.LoggerFactory;
case 1: // FULL_TABLE_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
- struct.fullTableNames = new ArrayList<String>(_list626.size);
- String _elem627;
- for (int _i628 = 0; _i628 < _list626.size; ++_i628)
+ org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
+ struct.fullTableNames = new ArrayList<String>(_list642.size);
+ String _elem643;
+ for (int _i644 = 0; _i644 < _list642.size; ++_i644)
{
- _elem627 = iprot.readString();
- struct.fullTableNames.add(_elem627);
+ _elem643 = iprot.readString();
+ struct.fullTableNames.add(_elem643);
}
iprot.readListEnd();
}
@@ -561,9 +561,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FULL_TABLE_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fullTableNames.size()));
- for (String _iter629 : struct.fullTableNames)
+ for (String _iter645 : struct.fullTableNames)
{
- oprot.writeString(_iter629);
+ oprot.writeString(_iter645);
}
oprot.writeListEnd();
}
@@ -600,9 +600,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fullTableNames.size());
- for (String _iter630 : struct.fullTableNames)
+ for (String _iter646 : struct.fullTableNames)
{
- oprot.writeString(_iter630);
+ oprot.writeString(_iter646);
}
}
BitSet optionals = new BitSet();
@@ -625,13 +625,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.fullTableNames = new ArrayList<String>(_list631.size);
- String _elem632;
- for (int _i633 = 0; _i633 < _list631.size; ++_i633)
+ org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.fullTableNames = new ArrayList<String>(_list647.size);
+ String _elem648;
+ for (int _i649 = 0; _i649 < _list647.size; ++_i649)
{
- _elem632 = iprot.readString();
- struct.fullTableNames.add(_elem632);
+ _elem648 = iprot.readString();
+ struct.fullTableNames.add(_elem648);
}
}
struct.setFullTableNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
index 6c3617e..fc94183 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TBL_VALID_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list642.size);
- TableValidWriteIds _elem643;
- for (int _i644 = 0; _i644 < _list642.size; ++_i644)
+ org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list658.size);
+ TableValidWriteIds _elem659;
+ for (int _i660 = 0; _i660 < _list658.size; ++_i660)
{
- _elem643 = new TableValidWriteIds();
- _elem643.read(iprot);
- struct.tblValidWriteIds.add(_elem643);
+ _elem659 = new TableValidWriteIds();
+ _elem659.read(iprot);
+ struct.tblValidWriteIds.add(_elem659);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_VALID_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tblValidWriteIds.size()));
- for (TableValidWriteIds _iter645 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter661 : struct.tblValidWriteIds)
{
- _iter645.write(oprot);
+ _iter661.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tblValidWriteIds.size());
- for (TableValidWriteIds _iter646 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter662 : struct.tblValidWriteIds)
{
- _iter646.write(oprot);
+ _iter662.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list647.size);
- TableValidWriteIds _elem648;
- for (int _i649 = 0; _i649 < _list647.size; ++_i649)
+ org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list663.size);
+ TableValidWriteIds _elem664;
+ for (int _i665 = 0; _i665 < _list663.size; ++_i665)
{
- _elem648 = new TableValidWriteIds();
- _elem648.read(iprot);
- struct.tblValidWriteIds.add(_elem648);
+ _elem664 = new TableValidWriteIds();
+ _elem664.read(iprot);
+ struct.tblValidWriteIds.add(_elem664);
}
}
struct.setTblValidWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
index 761ddb3..cfc8740 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
@@ -453,13 +453,13 @@ import org.slf4j.LoggerFactory;
case 1: // ABORTED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set690 = iprot.readSetBegin();
- struct.aborted = new HashSet<Long>(2*_set690.size);
- long _elem691;
- for (int _i692 = 0; _i692 < _set690.size; ++_i692)
+ org.apache.thrift.protocol.TSet _set706 = iprot.readSetBegin();
+ struct.aborted = new HashSet<Long>(2*_set706.size);
+ long _elem707;
+ for (int _i708 = 0; _i708 < _set706.size; ++_i708)
{
- _elem691 = iprot.readI64();
- struct.aborted.add(_elem691);
+ _elem707 = iprot.readI64();
+ struct.aborted.add(_elem707);
}
iprot.readSetEnd();
}
@@ -471,13 +471,13 @@ import org.slf4j.LoggerFactory;
case 2: // NOSUCH
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set693 = iprot.readSetBegin();
- struct.nosuch = new HashSet<Long>(2*_set693.size);
- long _elem694;
- for (int _i695 = 0; _i695 < _set693.size; ++_i695)
+ org.apache.thrift.protocol.TSet _set709 = iprot.readSetBegin();
+ struct.nosuch = new HashSet<Long>(2*_set709.size);
+ long _elem710;
+ for (int _i711 = 0; _i711 < _set709.size; ++_i711)
{
- _elem694 = iprot.readI64();
- struct.nosuch.add(_elem694);
+ _elem710 = iprot.readI64();
+ struct.nosuch.add(_elem710);
}
iprot.readSetEnd();
}
@@ -503,9 +503,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(ABORTED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size()));
- for (long _iter696 : struct.aborted)
+ for (long _iter712 : struct.aborted)
{
- oprot.writeI64(_iter696);
+ oprot.writeI64(_iter712);
}
oprot.writeSetEnd();
}
@@ -515,9 +515,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOSUCH_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size()));
- for (long _iter697 : struct.nosuch)
+ for (long _iter713 : struct.nosuch)
{
- oprot.writeI64(_iter697);
+ oprot.writeI64(_iter713);
}
oprot.writeSetEnd();
}
@@ -542,16 +542,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.aborted.size());
- for (long _iter698 : struct.aborted)
+ for (long _iter714 : struct.aborted)
{
- oprot.writeI64(_iter698);
+ oprot.writeI64(_iter714);
}
}
{
oprot.writeI32(struct.nosuch.size());
- for (long _iter699 : struct.nosuch)
+ for (long _iter715 : struct.nosuch)
{
- oprot.writeI64(_iter699);
+ oprot.writeI64(_iter715);
}
}
}
@@ -560,24 +560,24 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TSet _set700 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.aborted = new HashSet<Long>(2*_set700.size);
- long _elem701;
- for (int _i702 = 0; _i702 < _set700.size; ++_i702)
+ org.apache.thrift.protocol.TSet _set716 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.aborted = new HashSet<Long>(2*_set716.size);
+ long _elem717;
+ for (int _i718 = 0; _i718 < _set716.size; ++_i718)
{
- _elem701 = iprot.readI64();
- struct.aborted.add(_elem701);
+ _elem717 = iprot.readI64();
+ struct.aborted.add(_elem717);
}
}
struct.setAbortedIsSet(true);
{
- org.apache.thrift.protocol.TSet _set703 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.nosuch = new HashSet<Long>(2*_set703.size);
- long _elem704;
- for (int _i705 = 0; _i705 < _set703.size; ++_i705)
+ org.apache.thrift.protocol.TSet _set719 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.nosuch = new HashSet<Long>(2*_set719.size);
+ long _elem720;
+ for (int _i721 = 0; _i721 < _set719.size; ++_i721)
{
- _elem704 = iprot.readI64();
- struct.nosuch.add(_elem704);
+ _elem720 = iprot.readI64();
+ struct.nosuch.add(_elem720);
}
}
struct.setNosuchIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index f1ba643..0279ee1 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -636,13 +636,13 @@ import org.slf4j.LoggerFactory;
case 2: // FILES_ADDED
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list756.size);
- String _elem757;
- for (int _i758 = 0; _i758 < _list756.size; ++_i758)
+ org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list772.size);
+ String _elem773;
+ for (int _i774 = 0; _i774 < _list772.size; ++_i774)
{
- _elem757 = iprot.readString();
- struct.filesAdded.add(_elem757);
+ _elem773 = iprot.readString();
+ struct.filesAdded.add(_elem773);
}
iprot.readListEnd();
}
@@ -654,13 +654,13 @@ import org.slf4j.LoggerFactory;
case 3: // FILES_ADDED_CHECKSUM
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list759 = iprot.readListBegin();
- struct.filesAddedChecksum = new ArrayList<String>(_list759.size);
- String _elem760;
- for (int _i761 = 0; _i761 < _list759.size; ++_i761)
+ org.apache.thrift.protocol.TList _list775 = iprot.readListBegin();
+ struct.filesAddedChecksum = new ArrayList<String>(_list775.size);
+ String _elem776;
+ for (int _i777 = 0; _i777 < _list775.size; ++_i777)
{
- _elem760 = iprot.readString();
- struct.filesAddedChecksum.add(_elem760);
+ _elem776 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem776);
}
iprot.readListEnd();
}
@@ -672,13 +672,13 @@ import org.slf4j.LoggerFactory;
case 4: // SUB_DIRECTORY_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list762 = iprot.readListBegin();
- struct.subDirectoryList = new ArrayList<String>(_list762.size);
- String _elem763;
- for (int _i764 = 0; _i764 < _list762.size; ++_i764)
+ org.apache.thrift.protocol.TList _list778 = iprot.readListBegin();
+ struct.subDirectoryList = new ArrayList<String>(_list778.size);
+ String _elem779;
+ for (int _i780 = 0; _i780 < _list778.size; ++_i780)
{
- _elem763 = iprot.readString();
- struct.subDirectoryList.add(_elem763);
+ _elem779 = iprot.readString();
+ struct.subDirectoryList.add(_elem779);
}
iprot.readListEnd();
}
@@ -709,9 +709,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size()));
- for (String _iter765 : struct.filesAdded)
+ for (String _iter781 : struct.filesAdded)
{
- oprot.writeString(_iter765);
+ oprot.writeString(_iter781);
}
oprot.writeListEnd();
}
@@ -722,9 +722,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILES_ADDED_CHECKSUM_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAddedChecksum.size()));
- for (String _iter766 : struct.filesAddedChecksum)
+ for (String _iter782 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter766);
+ oprot.writeString(_iter782);
}
oprot.writeListEnd();
}
@@ -736,9 +736,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUB_DIRECTORY_LIST_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.subDirectoryList.size()));
- for (String _iter767 : struct.subDirectoryList)
+ for (String _iter783 : struct.subDirectoryList)
{
- oprot.writeString(_iter767);
+ oprot.writeString(_iter783);
}
oprot.writeListEnd();
}
@@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter768 : struct.filesAdded)
+ for (String _iter784 : struct.filesAdded)
{
- oprot.writeString(_iter768);
+ oprot.writeString(_iter784);
}
}
BitSet optionals = new BitSet();
@@ -786,18 +786,18 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFilesAddedChecksum()) {
{
oprot.writeI32(struct.filesAddedChecksum.size());
- for (String _iter769 : struct.filesAddedChecksum)
+ for (String _iter785 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter769);
+ oprot.writeString(_iter785);
}
}
}
if (struct.isSetSubDirectoryList()) {
{
oprot.writeI32(struct.subDirectoryList.size());
- for (String _iter770 : struct.subDirectoryList)
+ for (String _iter786 : struct.subDirectoryList)
{
- oprot.writeString(_iter770);
+ oprot.writeString(_iter786);
}
}
}
@@ -807,13 +807,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list771 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list771.size);
- String _elem772;
- for (int _i773 = 0; _i773 < _list771.size; ++_i773)
+ org.apache.thrift.protocol.TList _list787 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list787.size);
+ String _elem788;
+ for (int _i789 = 0; _i789 < _list787.size; ++_i789)
{
- _elem772 = iprot.readString();
- struct.filesAdded.add(_elem772);
+ _elem788 = iprot.readString();
+ struct.filesAdded.add(_elem788);
}
}
struct.setFilesAddedIsSet(true);
@@ -824,26 +824,26 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list774 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAddedChecksum = new ArrayList<String>(_list774.size);
- String _elem775;
- for (int _i776 = 0; _i776 < _list774.size; ++_i776)
+ org.apache.thrift.protocol.TList _list790 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAddedChecksum = new ArrayList<String>(_list790.size);
+ String _elem791;
+ for (int _i792 = 0; _i792 < _list790.size; ++_i792)
{
- _elem775 = iprot.readString();
- struct.filesAddedChecksum.add(_elem775);
+ _elem791 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem791);
}
}
struct.setFilesAddedChecksumIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.subDirectoryList = new ArrayList<String>(_list777.size);
- String _elem778;
- for (int _i779 = 0; _i779 < _list777.size; ++_i779)
+ org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.subDirectoryList = new ArrayList<String>(_list793.size);
+ String _elem794;
+ for (int _i795 = 0; _i795 < _list793.size; ++_i795)
{
- _elem778 = iprot.readString();
- struct.subDirectoryList.add(_elem778);
+ _elem794 = iprot.readString();
+ struct.subDirectoryList.add(_elem794);
}
}
struct.setSubDirectoryListIsSet(true);