You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/14 01:53:35 UTC
[13/20] hive git commit: HIVE-19820 : add ACID stats support to
background stats updater and fix bunch of edge cases found in SU tests
(Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsResponse.java
new file mode 100644
index 0000000..17ce69d
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsResponse.java
@@ -0,0 +1,387 @@
+/**
+ * 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 SetPartitionsStatsResponse implements org.apache.thrift.TBase<SetPartitionsStatsResponse, SetPartitionsStatsResponse._Fields>, java.io.Serializable, Cloneable, Comparable<SetPartitionsStatsResponse> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SetPartitionsStatsResponse");
+
+ private static final org.apache.thrift.protocol.TField RESULT_FIELD_DESC = new org.apache.thrift.protocol.TField("result", org.apache.thrift.protocol.TType.BOOL, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new SetPartitionsStatsResponseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new SetPartitionsStatsResponseTupleSchemeFactory());
+ }
+
+ private boolean result; // 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 {
+ RESULT((short)1, "result");
+
+ 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: // RESULT
+ return RESULT;
+ 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 __RESULT_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.RESULT, new org.apache.thrift.meta_data.FieldMetaData("result", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SetPartitionsStatsResponse.class, metaDataMap);
+ }
+
+ public SetPartitionsStatsResponse() {
+ }
+
+ public SetPartitionsStatsResponse(
+ boolean result)
+ {
+ this();
+ this.result = result;
+ setResultIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public SetPartitionsStatsResponse(SetPartitionsStatsResponse other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.result = other.result;
+ }
+
+ public SetPartitionsStatsResponse deepCopy() {
+ return new SetPartitionsStatsResponse(this);
+ }
+
+ @Override
+ public void clear() {
+ setResultIsSet(false);
+ this.result = false;
+ }
+
+ public boolean isResult() {
+ return this.result;
+ }
+
+ public void setResult(boolean result) {
+ this.result = result;
+ setResultIsSet(true);
+ }
+
+ public void unsetResult() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __RESULT_ISSET_ID);
+ }
+
+ /** Returns true if field result is set (has been assigned a value) and false otherwise */
+ public boolean isSetResult() {
+ return EncodingUtils.testBit(__isset_bitfield, __RESULT_ISSET_ID);
+ }
+
+ public void setResultIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __RESULT_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case RESULT:
+ if (value == null) {
+ unsetResult();
+ } else {
+ setResult((Boolean)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case RESULT:
+ return isResult();
+
+ }
+ 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 RESULT:
+ return isSetResult();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof SetPartitionsStatsResponse)
+ return this.equals((SetPartitionsStatsResponse)that);
+ return false;
+ }
+
+ public boolean equals(SetPartitionsStatsResponse that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_result = true;
+ boolean that_present_result = true;
+ if (this_present_result || that_present_result) {
+ if (!(this_present_result && that_present_result))
+ return false;
+ if (this.result != that.result)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_result = true;
+ list.add(present_result);
+ if (present_result)
+ list.add(result);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(SetPartitionsStatsResponse other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetResult()).compareTo(other.isSetResult());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetResult()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.result, other.result);
+ 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("SetPartitionsStatsResponse(");
+ boolean first = true;
+
+ sb.append("result:");
+ sb.append(this.result);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetResult()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'result' 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 SetPartitionsStatsResponseStandardSchemeFactory implements SchemeFactory {
+ public SetPartitionsStatsResponseStandardScheme getScheme() {
+ return new SetPartitionsStatsResponseStandardScheme();
+ }
+ }
+
+ private static class SetPartitionsStatsResponseStandardScheme extends StandardScheme<SetPartitionsStatsResponse> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, SetPartitionsStatsResponse 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: // RESULT
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.result = iprot.readBool();
+ struct.setResultIsSet(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, SetPartitionsStatsResponse struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(RESULT_FIELD_DESC);
+ oprot.writeBool(struct.result);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class SetPartitionsStatsResponseTupleSchemeFactory implements SchemeFactory {
+ public SetPartitionsStatsResponseTupleScheme getScheme() {
+ return new SetPartitionsStatsResponseTupleScheme();
+ }
+ }
+
+ private static class SetPartitionsStatsResponseTupleScheme extends TupleScheme<SetPartitionsStatsResponse> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, SetPartitionsStatsResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeBool(struct.result);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, SetPartitionsStatsResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.result = iprot.readBool();
+ struct.setResultIsSet(true);
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
index 9fb037f..c58885f 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // COMPACTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list700 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list700.size);
- ShowCompactResponseElement _elem701;
- for (int _i702 = 0; _i702 < _list700.size; ++_i702)
+ org.apache.thrift.protocol.TList _list708 = iprot.readListBegin();
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list708.size);
+ ShowCompactResponseElement _elem709;
+ for (int _i710 = 0; _i710 < _list708.size; ++_i710)
{
- _elem701 = new ShowCompactResponseElement();
- _elem701.read(iprot);
- struct.compacts.add(_elem701);
+ _elem709 = new ShowCompactResponseElement();
+ _elem709.read(iprot);
+ struct.compacts.add(_elem709);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COMPACTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size()));
- for (ShowCompactResponseElement _iter703 : struct.compacts)
+ for (ShowCompactResponseElement _iter711 : struct.compacts)
{
- _iter703.write(oprot);
+ _iter711.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter704 : struct.compacts)
+ for (ShowCompactResponseElement _iter712 : struct.compacts)
{
- _iter704.write(oprot);
+ _iter712.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list705 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list705.size);
- ShowCompactResponseElement _elem706;
- for (int _i707 = 0; _i707 < _list705.size; ++_i707)
+ org.apache.thrift.protocol.TList _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list713.size);
+ ShowCompactResponseElement _elem714;
+ for (int _i715 = 0; _i715 < _list713.size; ++_i715)
{
- _elem706 = new ShowCompactResponseElement();
- _elem706.read(iprot);
- struct.compacts.add(_elem706);
+ _elem714 = new ShowCompactResponseElement();
+ _elem714.read(iprot);
+ struct.compacts.add(_elem714);
}
}
struct.setCompactsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
index e0db2f7..4bbc8e7 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
@@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory;
case 1: // LOCKS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list666.size);
- ShowLocksResponseElement _elem667;
- for (int _i668 = 0; _i668 < _list666.size; ++_i668)
+ org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list674.size);
+ ShowLocksResponseElement _elem675;
+ for (int _i676 = 0; _i676 < _list674.size; ++_i676)
{
- _elem667 = new ShowLocksResponseElement();
- _elem667.read(iprot);
- struct.locks.add(_elem667);
+ _elem675 = new ShowLocksResponseElement();
+ _elem675.read(iprot);
+ struct.locks.add(_elem675);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(LOCKS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size()));
- for (ShowLocksResponseElement _iter669 : struct.locks)
+ for (ShowLocksResponseElement _iter677 : struct.locks)
{
- _iter669.write(oprot);
+ _iter677.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLocks()) {
{
oprot.writeI32(struct.locks.size());
- for (ShowLocksResponseElement _iter670 : struct.locks)
+ for (ShowLocksResponseElement _iter678 : struct.locks)
{
- _iter670.write(oprot);
+ _iter678.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list671.size);
- ShowLocksResponseElement _elem672;
- for (int _i673 = 0; _i673 < _list671.size; ++_i673)
+ org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list679.size);
+ ShowLocksResponseElement _elem680;
+ for (int _i681 = 0; _i681 < _list679.size; ++_i681)
{
- _elem672 = new ShowLocksResponseElement();
- _elem672.read(iprot);
- struct.locks.add(_elem672);
+ _elem680 = new ShowLocksResponseElement();
+ _elem680.read(iprot);
+ struct.locks.add(_elem680);
}
}
struct.setLocksIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
index 89fe49a..0bef251 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
@@ -557,13 +557,13 @@ import org.slf4j.LoggerFactory;
case 1: // SKEWED_COL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list122 = iprot.readListBegin();
- struct.skewedColNames = new ArrayList<String>(_list122.size);
- String _elem123;
- for (int _i124 = 0; _i124 < _list122.size; ++_i124)
+ org.apache.thrift.protocol.TList _list130 = iprot.readListBegin();
+ struct.skewedColNames = new ArrayList<String>(_list130.size);
+ String _elem131;
+ for (int _i132 = 0; _i132 < _list130.size; ++_i132)
{
- _elem123 = iprot.readString();
- struct.skewedColNames.add(_elem123);
+ _elem131 = iprot.readString();
+ struct.skewedColNames.add(_elem131);
}
iprot.readListEnd();
}
@@ -575,23 +575,23 @@ import org.slf4j.LoggerFactory;
case 2: // SKEWED_COL_VALUES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list125 = iprot.readListBegin();
- struct.skewedColValues = new ArrayList<List<String>>(_list125.size);
- List<String> _elem126;
- for (int _i127 = 0; _i127 < _list125.size; ++_i127)
+ org.apache.thrift.protocol.TList _list133 = iprot.readListBegin();
+ struct.skewedColValues = new ArrayList<List<String>>(_list133.size);
+ List<String> _elem134;
+ for (int _i135 = 0; _i135 < _list133.size; ++_i135)
{
{
- org.apache.thrift.protocol.TList _list128 = iprot.readListBegin();
- _elem126 = new ArrayList<String>(_list128.size);
- String _elem129;
- for (int _i130 = 0; _i130 < _list128.size; ++_i130)
+ org.apache.thrift.protocol.TList _list136 = iprot.readListBegin();
+ _elem134 = new ArrayList<String>(_list136.size);
+ String _elem137;
+ for (int _i138 = 0; _i138 < _list136.size; ++_i138)
{
- _elem129 = iprot.readString();
- _elem126.add(_elem129);
+ _elem137 = iprot.readString();
+ _elem134.add(_elem137);
}
iprot.readListEnd();
}
- struct.skewedColValues.add(_elem126);
+ struct.skewedColValues.add(_elem134);
}
iprot.readListEnd();
}
@@ -603,25 +603,25 @@ import org.slf4j.LoggerFactory;
case 3: // SKEWED_COL_VALUE_LOCATION_MAPS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map131 = iprot.readMapBegin();
- struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map131.size);
- List<String> _key132;
- String _val133;
- for (int _i134 = 0; _i134 < _map131.size; ++_i134)
+ org.apache.thrift.protocol.TMap _map139 = iprot.readMapBegin();
+ struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map139.size);
+ List<String> _key140;
+ String _val141;
+ for (int _i142 = 0; _i142 < _map139.size; ++_i142)
{
{
- org.apache.thrift.protocol.TList _list135 = iprot.readListBegin();
- _key132 = new ArrayList<String>(_list135.size);
- String _elem136;
- for (int _i137 = 0; _i137 < _list135.size; ++_i137)
+ org.apache.thrift.protocol.TList _list143 = iprot.readListBegin();
+ _key140 = new ArrayList<String>(_list143.size);
+ String _elem144;
+ for (int _i145 = 0; _i145 < _list143.size; ++_i145)
{
- _elem136 = iprot.readString();
- _key132.add(_elem136);
+ _elem144 = iprot.readString();
+ _key140.add(_elem144);
}
iprot.readListEnd();
}
- _val133 = iprot.readString();
- struct.skewedColValueLocationMaps.put(_key132, _val133);
+ _val141 = iprot.readString();
+ struct.skewedColValueLocationMaps.put(_key140, _val141);
}
iprot.readMapEnd();
}
@@ -647,9 +647,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SKEWED_COL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.skewedColNames.size()));
- for (String _iter138 : struct.skewedColNames)
+ for (String _iter146 : struct.skewedColNames)
{
- oprot.writeString(_iter138);
+ oprot.writeString(_iter146);
}
oprot.writeListEnd();
}
@@ -659,13 +659,13 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SKEWED_COL_VALUES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, struct.skewedColValues.size()));
- for (List<String> _iter139 : struct.skewedColValues)
+ for (List<String> _iter147 : struct.skewedColValues)
{
{
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter139.size()));
- for (String _iter140 : _iter139)
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter147.size()));
+ for (String _iter148 : _iter147)
{
- oprot.writeString(_iter140);
+ oprot.writeString(_iter148);
}
oprot.writeListEnd();
}
@@ -678,17 +678,17 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SKEWED_COL_VALUE_LOCATION_MAPS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, struct.skewedColValueLocationMaps.size()));
- for (Map.Entry<List<String>, String> _iter141 : struct.skewedColValueLocationMaps.entrySet())
+ for (Map.Entry<List<String>, String> _iter149 : struct.skewedColValueLocationMaps.entrySet())
{
{
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter141.getKey().size()));
- for (String _iter142 : _iter141.getKey())
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter149.getKey().size()));
+ for (String _iter150 : _iter149.getKey())
{
- oprot.writeString(_iter142);
+ oprot.writeString(_iter150);
}
oprot.writeListEnd();
}
- oprot.writeString(_iter141.getValue());
+ oprot.writeString(_iter149.getValue());
}
oprot.writeMapEnd();
}
@@ -725,22 +725,22 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSkewedColNames()) {
{
oprot.writeI32(struct.skewedColNames.size());
- for (String _iter143 : struct.skewedColNames)
+ for (String _iter151 : struct.skewedColNames)
{
- oprot.writeString(_iter143);
+ oprot.writeString(_iter151);
}
}
}
if (struct.isSetSkewedColValues()) {
{
oprot.writeI32(struct.skewedColValues.size());
- for (List<String> _iter144 : struct.skewedColValues)
+ for (List<String> _iter152 : struct.skewedColValues)
{
{
- oprot.writeI32(_iter144.size());
- for (String _iter145 : _iter144)
+ oprot.writeI32(_iter152.size());
+ for (String _iter153 : _iter152)
{
- oprot.writeString(_iter145);
+ oprot.writeString(_iter153);
}
}
}
@@ -749,16 +749,16 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSkewedColValueLocationMaps()) {
{
oprot.writeI32(struct.skewedColValueLocationMaps.size());
- for (Map.Entry<List<String>, String> _iter146 : struct.skewedColValueLocationMaps.entrySet())
+ for (Map.Entry<List<String>, String> _iter154 : struct.skewedColValueLocationMaps.entrySet())
{
{
- oprot.writeI32(_iter146.getKey().size());
- for (String _iter147 : _iter146.getKey())
+ oprot.writeI32(_iter154.getKey().size());
+ for (String _iter155 : _iter154.getKey())
{
- oprot.writeString(_iter147);
+ oprot.writeString(_iter155);
}
}
- oprot.writeString(_iter146.getValue());
+ oprot.writeString(_iter154.getValue());
}
}
}
@@ -770,59 +770,59 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list148 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.skewedColNames = new ArrayList<String>(_list148.size);
- String _elem149;
- for (int _i150 = 0; _i150 < _list148.size; ++_i150)
+ org.apache.thrift.protocol.TList _list156 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.skewedColNames = new ArrayList<String>(_list156.size);
+ String _elem157;
+ for (int _i158 = 0; _i158 < _list156.size; ++_i158)
{
- _elem149 = iprot.readString();
- struct.skewedColNames.add(_elem149);
+ _elem157 = iprot.readString();
+ struct.skewedColNames.add(_elem157);
}
}
struct.setSkewedColNamesIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list151 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32());
- struct.skewedColValues = new ArrayList<List<String>>(_list151.size);
- List<String> _elem152;
- for (int _i153 = 0; _i153 < _list151.size; ++_i153)
+ org.apache.thrift.protocol.TList _list159 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32());
+ struct.skewedColValues = new ArrayList<List<String>>(_list159.size);
+ List<String> _elem160;
+ for (int _i161 = 0; _i161 < _list159.size; ++_i161)
{
{
- org.apache.thrift.protocol.TList _list154 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _elem152 = new ArrayList<String>(_list154.size);
- String _elem155;
- for (int _i156 = 0; _i156 < _list154.size; ++_i156)
+ org.apache.thrift.protocol.TList _list162 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ _elem160 = new ArrayList<String>(_list162.size);
+ String _elem163;
+ for (int _i164 = 0; _i164 < _list162.size; ++_i164)
{
- _elem155 = iprot.readString();
- _elem152.add(_elem155);
+ _elem163 = iprot.readString();
+ _elem160.add(_elem163);
}
}
- struct.skewedColValues.add(_elem152);
+ struct.skewedColValues.add(_elem160);
}
}
struct.setSkewedColValuesIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map157 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map157.size);
- List<String> _key158;
- String _val159;
- for (int _i160 = 0; _i160 < _map157.size; ++_i160)
+ org.apache.thrift.protocol.TMap _map165 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map165.size);
+ List<String> _key166;
+ String _val167;
+ for (int _i168 = 0; _i168 < _map165.size; ++_i168)
{
{
- org.apache.thrift.protocol.TList _list161 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- _key158 = new ArrayList<String>(_list161.size);
- String _elem162;
- for (int _i163 = 0; _i163 < _list161.size; ++_i163)
+ org.apache.thrift.protocol.TList _list169 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ _key166 = new ArrayList<String>(_list169.size);
+ String _elem170;
+ for (int _i171 = 0; _i171 < _list169.size; ++_i171)
{
- _elem162 = iprot.readString();
- _key158.add(_elem162);
+ _elem170 = iprot.readString();
+ _key166.add(_elem170);
}
}
- _val159 = iprot.readString();
- struct.skewedColValueLocationMaps.put(_key158, _val159);
+ _val167 = iprot.readString();
+ struct.skewedColValueLocationMaps.put(_key166, _val167);
}
}
struct.setSkewedColValueLocationMapsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
index 3cfa765..0d8957d 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
@@ -1290,14 +1290,14 @@ import org.slf4j.LoggerFactory;
case 1: // COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list164 = iprot.readListBegin();
- struct.cols = new ArrayList<FieldSchema>(_list164.size);
- FieldSchema _elem165;
- for (int _i166 = 0; _i166 < _list164.size; ++_i166)
+ org.apache.thrift.protocol.TList _list172 = iprot.readListBegin();
+ struct.cols = new ArrayList<FieldSchema>(_list172.size);
+ FieldSchema _elem173;
+ for (int _i174 = 0; _i174 < _list172.size; ++_i174)
{
- _elem165 = new FieldSchema();
- _elem165.read(iprot);
- struct.cols.add(_elem165);
+ _elem173 = new FieldSchema();
+ _elem173.read(iprot);
+ struct.cols.add(_elem173);
}
iprot.readListEnd();
}
@@ -1358,13 +1358,13 @@ import org.slf4j.LoggerFactory;
case 8: // BUCKET_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list167 = iprot.readListBegin();
- struct.bucketCols = new ArrayList<String>(_list167.size);
- String _elem168;
- for (int _i169 = 0; _i169 < _list167.size; ++_i169)
+ org.apache.thrift.protocol.TList _list175 = iprot.readListBegin();
+ struct.bucketCols = new ArrayList<String>(_list175.size);
+ String _elem176;
+ for (int _i177 = 0; _i177 < _list175.size; ++_i177)
{
- _elem168 = iprot.readString();
- struct.bucketCols.add(_elem168);
+ _elem176 = iprot.readString();
+ struct.bucketCols.add(_elem176);
}
iprot.readListEnd();
}
@@ -1376,14 +1376,14 @@ import org.slf4j.LoggerFactory;
case 9: // SORT_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list170 = iprot.readListBegin();
- struct.sortCols = new ArrayList<Order>(_list170.size);
- Order _elem171;
- for (int _i172 = 0; _i172 < _list170.size; ++_i172)
+ org.apache.thrift.protocol.TList _list178 = iprot.readListBegin();
+ struct.sortCols = new ArrayList<Order>(_list178.size);
+ Order _elem179;
+ for (int _i180 = 0; _i180 < _list178.size; ++_i180)
{
- _elem171 = new Order();
- _elem171.read(iprot);
- struct.sortCols.add(_elem171);
+ _elem179 = new Order();
+ _elem179.read(iprot);
+ struct.sortCols.add(_elem179);
}
iprot.readListEnd();
}
@@ -1395,15 +1395,15 @@ import org.slf4j.LoggerFactory;
case 10: // PARAMETERS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map173 = iprot.readMapBegin();
- struct.parameters = new HashMap<String,String>(2*_map173.size);
- String _key174;
- String _val175;
- for (int _i176 = 0; _i176 < _map173.size; ++_i176)
+ org.apache.thrift.protocol.TMap _map181 = iprot.readMapBegin();
+ struct.parameters = new HashMap<String,String>(2*_map181.size);
+ String _key182;
+ String _val183;
+ for (int _i184 = 0; _i184 < _map181.size; ++_i184)
{
- _key174 = iprot.readString();
- _val175 = iprot.readString();
- struct.parameters.put(_key174, _val175);
+ _key182 = iprot.readString();
+ _val183 = iprot.readString();
+ struct.parameters.put(_key182, _val183);
}
iprot.readMapEnd();
}
@@ -1446,9 +1446,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.cols.size()));
- for (FieldSchema _iter177 : struct.cols)
+ for (FieldSchema _iter185 : struct.cols)
{
- _iter177.write(oprot);
+ _iter185.write(oprot);
}
oprot.writeListEnd();
}
@@ -1484,9 +1484,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(BUCKET_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.bucketCols.size()));
- for (String _iter178 : struct.bucketCols)
+ for (String _iter186 : struct.bucketCols)
{
- oprot.writeString(_iter178);
+ oprot.writeString(_iter186);
}
oprot.writeListEnd();
}
@@ -1496,9 +1496,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SORT_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.sortCols.size()));
- for (Order _iter179 : struct.sortCols)
+ for (Order _iter187 : struct.sortCols)
{
- _iter179.write(oprot);
+ _iter187.write(oprot);
}
oprot.writeListEnd();
}
@@ -1508,10 +1508,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARAMETERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size()));
- for (Map.Entry<String, String> _iter180 : struct.parameters.entrySet())
+ for (Map.Entry<String, String> _iter188 : struct.parameters.entrySet())
{
- oprot.writeString(_iter180.getKey());
- oprot.writeString(_iter180.getValue());
+ oprot.writeString(_iter188.getKey());
+ oprot.writeString(_iter188.getValue());
}
oprot.writeMapEnd();
}
@@ -1587,9 +1587,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetCols()) {
{
oprot.writeI32(struct.cols.size());
- for (FieldSchema _iter181 : struct.cols)
+ for (FieldSchema _iter189 : struct.cols)
{
- _iter181.write(oprot);
+ _iter189.write(oprot);
}
}
}
@@ -1614,28 +1614,28 @@ import org.slf4j.LoggerFactory;
if (struct.isSetBucketCols()) {
{
oprot.writeI32(struct.bucketCols.size());
- for (String _iter182 : struct.bucketCols)
+ for (String _iter190 : struct.bucketCols)
{
- oprot.writeString(_iter182);
+ oprot.writeString(_iter190);
}
}
}
if (struct.isSetSortCols()) {
{
oprot.writeI32(struct.sortCols.size());
- for (Order _iter183 : struct.sortCols)
+ for (Order _iter191 : struct.sortCols)
{
- _iter183.write(oprot);
+ _iter191.write(oprot);
}
}
}
if (struct.isSetParameters()) {
{
oprot.writeI32(struct.parameters.size());
- for (Map.Entry<String, String> _iter184 : struct.parameters.entrySet())
+ for (Map.Entry<String, String> _iter192 : struct.parameters.entrySet())
{
- oprot.writeString(_iter184.getKey());
- oprot.writeString(_iter184.getValue());
+ oprot.writeString(_iter192.getKey());
+ oprot.writeString(_iter192.getValue());
}
}
}
@@ -1653,14 +1653,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(12);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list185 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.cols = new ArrayList<FieldSchema>(_list185.size);
- FieldSchema _elem186;
- for (int _i187 = 0; _i187 < _list185.size; ++_i187)
+ org.apache.thrift.protocol.TList _list193 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.cols = new ArrayList<FieldSchema>(_list193.size);
+ FieldSchema _elem194;
+ for (int _i195 = 0; _i195 < _list193.size; ++_i195)
{
- _elem186 = new FieldSchema();
- _elem186.read(iprot);
- struct.cols.add(_elem186);
+ _elem194 = new FieldSchema();
+ _elem194.read(iprot);
+ struct.cols.add(_elem194);
}
}
struct.setColsIsSet(true);
@@ -1692,42 +1692,42 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(7)) {
{
- org.apache.thrift.protocol.TList _list188 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.bucketCols = new ArrayList<String>(_list188.size);
- String _elem189;
- for (int _i190 = 0; _i190 < _list188.size; ++_i190)
+ org.apache.thrift.protocol.TList _list196 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.bucketCols = new ArrayList<String>(_list196.size);
+ String _elem197;
+ for (int _i198 = 0; _i198 < _list196.size; ++_i198)
{
- _elem189 = iprot.readString();
- struct.bucketCols.add(_elem189);
+ _elem197 = iprot.readString();
+ struct.bucketCols.add(_elem197);
}
}
struct.bucketCols = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.bucketCols); struct.setBucketColsIsSet(true);
}
if (incoming.get(8)) {
{
- org.apache.thrift.protocol.TList _list191 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.sortCols = new ArrayList<Order>(_list191.size);
- Order _elem192;
- for (int _i193 = 0; _i193 < _list191.size; ++_i193)
+ org.apache.thrift.protocol.TList _list199 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.sortCols = new ArrayList<Order>(_list199.size);
+ Order _elem200;
+ for (int _i201 = 0; _i201 < _list199.size; ++_i201)
{
- _elem192 = new Order();
- _elem192.read(iprot);
- struct.sortCols.add(_elem192);
+ _elem200 = new Order();
+ _elem200.read(iprot);
+ struct.sortCols.add(_elem200);
}
}
struct.setSortColsIsSet(true);
}
if (incoming.get(9)) {
{
- org.apache.thrift.protocol.TMap _map194 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.parameters = new HashMap<String,String>(2*_map194.size);
- String _key195;
- String _val196;
- for (int _i197 = 0; _i197 < _map194.size; ++_i197)
+ org.apache.thrift.protocol.TMap _map202 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.parameters = new HashMap<String,String>(2*_map202.size);
+ String _key203;
+ String _val204;
+ for (int _i205 = 0; _i205 < _map202.size; ++_i205)
{
- _key195 = iprot.readString();
- _val196 = iprot.readString();
- struct.parameters.put(_key195, _val196);
+ _key203 = iprot.readString();
+ _val204 = iprot.readString();
+ struct.parameters.put(_key203, _val204);
}
}
struct.parameters = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.parameters); struct.setParametersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
index f9d48c8..78ac909 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
@@ -1958,14 +1958,14 @@ import org.slf4j.LoggerFactory;
case 8: // PARTITION_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list198 = iprot.readListBegin();
- struct.partitionKeys = new ArrayList<FieldSchema>(_list198.size);
- FieldSchema _elem199;
- for (int _i200 = 0; _i200 < _list198.size; ++_i200)
+ org.apache.thrift.protocol.TList _list206 = iprot.readListBegin();
+ struct.partitionKeys = new ArrayList<FieldSchema>(_list206.size);
+ FieldSchema _elem207;
+ for (int _i208 = 0; _i208 < _list206.size; ++_i208)
{
- _elem199 = new FieldSchema();
- _elem199.read(iprot);
- struct.partitionKeys.add(_elem199);
+ _elem207 = new FieldSchema();
+ _elem207.read(iprot);
+ struct.partitionKeys.add(_elem207);
}
iprot.readListEnd();
}
@@ -1977,15 +1977,15 @@ import org.slf4j.LoggerFactory;
case 9: // PARAMETERS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map201 = iprot.readMapBegin();
- struct.parameters = new HashMap<String,String>(2*_map201.size);
- String _key202;
- String _val203;
- for (int _i204 = 0; _i204 < _map201.size; ++_i204)
+ org.apache.thrift.protocol.TMap _map209 = iprot.readMapBegin();
+ struct.parameters = new HashMap<String,String>(2*_map209.size);
+ String _key210;
+ String _val211;
+ for (int _i212 = 0; _i212 < _map209.size; ++_i212)
{
- _key202 = iprot.readString();
- _val203 = iprot.readString();
- struct.parameters.put(_key202, _val203);
+ _key210 = iprot.readString();
+ _val211 = iprot.readString();
+ struct.parameters.put(_key210, _val211);
}
iprot.readMapEnd();
}
@@ -2130,9 +2130,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITION_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitionKeys.size()));
- for (FieldSchema _iter205 : struct.partitionKeys)
+ for (FieldSchema _iter213 : struct.partitionKeys)
{
- _iter205.write(oprot);
+ _iter213.write(oprot);
}
oprot.writeListEnd();
}
@@ -2142,10 +2142,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARAMETERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size()));
- for (Map.Entry<String, String> _iter206 : struct.parameters.entrySet())
+ for (Map.Entry<String, String> _iter214 : struct.parameters.entrySet())
{
- oprot.writeString(_iter206.getKey());
- oprot.writeString(_iter206.getValue());
+ oprot.writeString(_iter214.getKey());
+ oprot.writeString(_iter214.getValue());
}
oprot.writeMapEnd();
}
@@ -2317,19 +2317,19 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionKeys()) {
{
oprot.writeI32(struct.partitionKeys.size());
- for (FieldSchema _iter207 : struct.partitionKeys)
+ for (FieldSchema _iter215 : struct.partitionKeys)
{
- _iter207.write(oprot);
+ _iter215.write(oprot);
}
}
}
if (struct.isSetParameters()) {
{
oprot.writeI32(struct.parameters.size());
- for (Map.Entry<String, String> _iter208 : struct.parameters.entrySet())
+ for (Map.Entry<String, String> _iter216 : struct.parameters.entrySet())
{
- oprot.writeString(_iter208.getKey());
- oprot.writeString(_iter208.getValue());
+ oprot.writeString(_iter216.getKey());
+ oprot.writeString(_iter216.getValue());
}
}
}
@@ -2403,29 +2403,29 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(7)) {
{
- org.apache.thrift.protocol.TList _list209 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.partitionKeys = new ArrayList<FieldSchema>(_list209.size);
- FieldSchema _elem210;
- for (int _i211 = 0; _i211 < _list209.size; ++_i211)
+ org.apache.thrift.protocol.TList _list217 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.partitionKeys = new ArrayList<FieldSchema>(_list217.size);
+ FieldSchema _elem218;
+ for (int _i219 = 0; _i219 < _list217.size; ++_i219)
{
- _elem210 = new FieldSchema();
- _elem210.read(iprot);
- struct.partitionKeys.add(_elem210);
+ _elem218 = new FieldSchema();
+ _elem218.read(iprot);
+ struct.partitionKeys.add(_elem218);
}
}
struct.setPartitionKeysIsSet(true);
}
if (incoming.get(8)) {
{
- org.apache.thrift.protocol.TMap _map212 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.parameters = new HashMap<String,String>(2*_map212.size);
- String _key213;
- String _val214;
- for (int _i215 = 0; _i215 < _map212.size; ++_i215)
+ org.apache.thrift.protocol.TMap _map220 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.parameters = new HashMap<String,String>(2*_map220.size);
+ String _key221;
+ String _val222;
+ for (int _i223 = 0; _i223 < _map220.size; ++_i223)
{
- _key213 = iprot.readString();
- _val214 = iprot.readString();
- struct.parameters.put(_key213, _val214);
+ _key221 = iprot.readString();
+ _val222 = iprot.readString();
+ struct.parameters.put(_key221, _val222);
}
}
struct.setParametersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
index c9b70a4..55f2724 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
@@ -782,13 +782,13 @@ import org.slf4j.LoggerFactory;
case 3: // COL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list450 = iprot.readListBegin();
- struct.colNames = new ArrayList<String>(_list450.size);
- String _elem451;
- for (int _i452 = 0; _i452 < _list450.size; ++_i452)
+ org.apache.thrift.protocol.TList _list458 = iprot.readListBegin();
+ struct.colNames = new ArrayList<String>(_list458.size);
+ String _elem459;
+ for (int _i460 = 0; _i460 < _list458.size; ++_i460)
{
- _elem451 = iprot.readString();
- struct.colNames.add(_elem451);
+ _elem459 = iprot.readString();
+ struct.colNames.add(_elem459);
}
iprot.readListEnd();
}
@@ -848,9 +848,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.colNames.size()));
- for (String _iter453 : struct.colNames)
+ for (String _iter461 : struct.colNames)
{
- oprot.writeString(_iter453);
+ oprot.writeString(_iter461);
}
oprot.writeListEnd();
}
@@ -896,9 +896,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.colNames.size());
- for (String _iter454 : struct.colNames)
+ for (String _iter462 : struct.colNames)
{
- oprot.writeString(_iter454);
+ oprot.writeString(_iter462);
}
}
BitSet optionals = new BitSet();
@@ -931,13 +931,13 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TList _list455 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.colNames = new ArrayList<String>(_list455.size);
- String _elem456;
- for (int _i457 = 0; _i457 < _list455.size; ++_i457)
+ org.apache.thrift.protocol.TList _list463 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.colNames = new ArrayList<String>(_list463.size);
+ String _elem464;
+ for (int _i465 = 0; _i465 < _list463.size; ++_i465)
{
- _elem456 = iprot.readString();
- struct.colNames.add(_elem456);
+ _elem464 = iprot.readString();
+ struct.colNames.add(_elem464);
}
}
struct.setColNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
index 0685a22..b57f4bf 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
@@ -435,14 +435,14 @@ import org.slf4j.LoggerFactory;
case 1: // TABLE_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list424 = iprot.readListBegin();
- struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list424.size);
- ColumnStatisticsObj _elem425;
- for (int _i426 = 0; _i426 < _list424.size; ++_i426)
+ org.apache.thrift.protocol.TList _list432 = iprot.readListBegin();
+ struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list432.size);
+ ColumnStatisticsObj _elem433;
+ for (int _i434 = 0; _i434 < _list432.size; ++_i434)
{
- _elem425 = new ColumnStatisticsObj();
- _elem425.read(iprot);
- struct.tableStats.add(_elem425);
+ _elem433 = new ColumnStatisticsObj();
+ _elem433.read(iprot);
+ struct.tableStats.add(_elem433);
}
iprot.readListEnd();
}
@@ -476,9 +476,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLE_STATS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tableStats.size()));
- for (ColumnStatisticsObj _iter427 : struct.tableStats)
+ for (ColumnStatisticsObj _iter435 : struct.tableStats)
{
- _iter427.write(oprot);
+ _iter435.write(oprot);
}
oprot.writeListEnd();
}
@@ -508,9 +508,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tableStats.size());
- for (ColumnStatisticsObj _iter428 : struct.tableStats)
+ for (ColumnStatisticsObj _iter436 : struct.tableStats)
{
- _iter428.write(oprot);
+ _iter436.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -527,14 +527,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list429 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list429.size);
- ColumnStatisticsObj _elem430;
- for (int _i431 = 0; _i431 < _list429.size; ++_i431)
+ org.apache.thrift.protocol.TList _list437 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list437.size);
+ ColumnStatisticsObj _elem438;
+ for (int _i439 = 0; _i439 < _list437.size; ++_i439)
{
- _elem430 = new ColumnStatisticsObj();
- _elem430.read(iprot);
- struct.tableStats.add(_elem430);
+ _elem438 = new ColumnStatisticsObj();
+ _elem438.read(iprot);
+ struct.tableStats.add(_elem438);
}
}
struct.setTableStatsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
index de15fc6..9c6ee51 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
@@ -708,13 +708,13 @@ import org.slf4j.LoggerFactory;
case 3: // INVALID_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list618 = iprot.readListBegin();
- struct.invalidWriteIds = new ArrayList<Long>(_list618.size);
- long _elem619;
- for (int _i620 = 0; _i620 < _list618.size; ++_i620)
+ org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
+ struct.invalidWriteIds = new ArrayList<Long>(_list626.size);
+ long _elem627;
+ for (int _i628 = 0; _i628 < _list626.size; ++_i628)
{
- _elem619 = iprot.readI64();
- struct.invalidWriteIds.add(_elem619);
+ _elem627 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem627);
}
iprot.readListEnd();
}
@@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(INVALID_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.invalidWriteIds.size()));
- for (long _iter621 : struct.invalidWriteIds)
+ for (long _iter629 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter621);
+ oprot.writeI64(_iter629);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
oprot.writeI64(struct.writeIdHighWaterMark);
{
oprot.writeI32(struct.invalidWriteIds.size());
- for (long _iter622 : struct.invalidWriteIds)
+ for (long _iter630 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter622);
+ oprot.writeI64(_iter630);
}
}
oprot.writeBinary(struct.abortedBits);
@@ -827,13 +827,13 @@ import org.slf4j.LoggerFactory;
struct.writeIdHighWaterMark = iprot.readI64();
struct.setWriteIdHighWaterMarkIsSet(true);
{
- org.apache.thrift.protocol.TList _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.invalidWriteIds = new ArrayList<Long>(_list623.size);
- long _elem624;
- for (int _i625 = 0; _i625 < _list623.size; ++_i625)
+ org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.invalidWriteIds = new ArrayList<Long>(_list631.size);
+ long _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
{
- _elem624 = iprot.readI64();
- struct.invalidWriteIds.add(_elem624);
+ _elem632 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem632);
}
}
struct.setInvalidWriteIdsIsSet(true);