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 2018/07/24 11:43:09 UTC
[13/19] hive git commit: HIVE-19267: Replicate ACID/MM tables write
operations (Mahesh Kumar Behera, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
index 27b6cf8..af62ca1 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
@@ -436,13 +436,13 @@ import org.slf4j.LoggerFactory;
case 1: // FULL_TABLE_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
- struct.fullTableNames = new ArrayList<String>(_list602.size);
- String _elem603;
- for (int _i604 = 0; _i604 < _list602.size; ++_i604)
+ org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
+ struct.fullTableNames = new ArrayList<String>(_list610.size);
+ String _elem611;
+ for (int _i612 = 0; _i612 < _list610.size; ++_i612)
{
- _elem603 = iprot.readString();
- struct.fullTableNames.add(_elem603);
+ _elem611 = iprot.readString();
+ struct.fullTableNames.add(_elem611);
}
iprot.readListEnd();
}
@@ -476,9 +476,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 _iter605 : struct.fullTableNames)
+ for (String _iter613 : struct.fullTableNames)
{
- oprot.writeString(_iter605);
+ oprot.writeString(_iter613);
}
oprot.writeListEnd();
}
@@ -508,9 +508,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fullTableNames.size());
- for (String _iter606 : struct.fullTableNames)
+ for (String _iter614 : struct.fullTableNames)
{
- oprot.writeString(_iter606);
+ oprot.writeString(_iter614);
}
}
oprot.writeString(struct.validTxnList);
@@ -520,13 +520,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 _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.fullTableNames = new ArrayList<String>(_list607.size);
- String _elem608;
- for (int _i609 = 0; _i609 < _list607.size; ++_i609)
+ org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.fullTableNames = new ArrayList<String>(_list615.size);
+ String _elem616;
+ for (int _i617 = 0; _i617 < _list615.size; ++_i617)
{
- _elem608 = iprot.readString();
- struct.fullTableNames.add(_elem608);
+ _elem616 = iprot.readString();
+ struct.fullTableNames.add(_elem616);
}
}
struct.setFullTableNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
index 7a1bbc7..615a422 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
+++ b/standalone-metastore/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 _list618 = iprot.readListBegin();
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list618.size);
- TableValidWriteIds _elem619;
- for (int _i620 = 0; _i620 < _list618.size; ++_i620)
+ org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list626.size);
+ TableValidWriteIds _elem627;
+ for (int _i628 = 0; _i628 < _list626.size; ++_i628)
{
- _elem619 = new TableValidWriteIds();
- _elem619.read(iprot);
- struct.tblValidWriteIds.add(_elem619);
+ _elem627 = new TableValidWriteIds();
+ _elem627.read(iprot);
+ struct.tblValidWriteIds.add(_elem627);
}
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 _iter621 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter629 : struct.tblValidWriteIds)
{
- _iter621.write(oprot);
+ _iter629.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tblValidWriteIds.size());
- for (TableValidWriteIds _iter622 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter630 : struct.tblValidWriteIds)
{
- _iter622.write(oprot);
+ _iter630.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 _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list623.size);
- TableValidWriteIds _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.STRUCT, iprot.readI32());
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list631.size);
+ TableValidWriteIds _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
{
- _elem624 = new TableValidWriteIds();
- _elem624.read(iprot);
- struct.tblValidWriteIds.add(_elem624);
+ _elem632 = new TableValidWriteIds();
+ _elem632.read(iprot);
+ struct.tblValidWriteIds.add(_elem632);
}
}
struct.setTblValidWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
index 4999215..a3dceab 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
+++ b/standalone-metastore/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 _set666 = iprot.readSetBegin();
- struct.aborted = new HashSet<Long>(2*_set666.size);
- long _elem667;
- for (int _i668 = 0; _i668 < _set666.size; ++_i668)
+ org.apache.thrift.protocol.TSet _set674 = iprot.readSetBegin();
+ struct.aborted = new HashSet<Long>(2*_set674.size);
+ long _elem675;
+ for (int _i676 = 0; _i676 < _set674.size; ++_i676)
{
- _elem667 = iprot.readI64();
- struct.aborted.add(_elem667);
+ _elem675 = iprot.readI64();
+ struct.aborted.add(_elem675);
}
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 _set669 = iprot.readSetBegin();
- struct.nosuch = new HashSet<Long>(2*_set669.size);
- long _elem670;
- for (int _i671 = 0; _i671 < _set669.size; ++_i671)
+ org.apache.thrift.protocol.TSet _set677 = iprot.readSetBegin();
+ struct.nosuch = new HashSet<Long>(2*_set677.size);
+ long _elem678;
+ for (int _i679 = 0; _i679 < _set677.size; ++_i679)
{
- _elem670 = iprot.readI64();
- struct.nosuch.add(_elem670);
+ _elem678 = iprot.readI64();
+ struct.nosuch.add(_elem678);
}
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 _iter672 : struct.aborted)
+ for (long _iter680 : struct.aborted)
{
- oprot.writeI64(_iter672);
+ oprot.writeI64(_iter680);
}
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 _iter673 : struct.nosuch)
+ for (long _iter681 : struct.nosuch)
{
- oprot.writeI64(_iter673);
+ oprot.writeI64(_iter681);
}
oprot.writeSetEnd();
}
@@ -542,16 +542,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.aborted.size());
- for (long _iter674 : struct.aborted)
+ for (long _iter682 : struct.aborted)
{
- oprot.writeI64(_iter674);
+ oprot.writeI64(_iter682);
}
}
{
oprot.writeI32(struct.nosuch.size());
- for (long _iter675 : struct.nosuch)
+ for (long _iter683 : struct.nosuch)
{
- oprot.writeI64(_iter675);
+ oprot.writeI64(_iter683);
}
}
}
@@ -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 _set676 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.aborted = new HashSet<Long>(2*_set676.size);
- long _elem677;
- for (int _i678 = 0; _i678 < _set676.size; ++_i678)
+ org.apache.thrift.protocol.TSet _set684 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.aborted = new HashSet<Long>(2*_set684.size);
+ long _elem685;
+ for (int _i686 = 0; _i686 < _set684.size; ++_i686)
{
- _elem677 = iprot.readI64();
- struct.aborted.add(_elem677);
+ _elem685 = iprot.readI64();
+ struct.aborted.add(_elem685);
}
}
struct.setAbortedIsSet(true);
{
- org.apache.thrift.protocol.TSet _set679 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.nosuch = new HashSet<Long>(2*_set679.size);
- long _elem680;
- for (int _i681 = 0; _i681 < _set679.size; ++_i681)
+ org.apache.thrift.protocol.TSet _set687 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.nosuch = new HashSet<Long>(2*_set687.size);
+ long _elem688;
+ for (int _i689 = 0; _i689 < _set687.size; ++_i689)
{
- _elem680 = iprot.readI64();
- struct.nosuch.add(_elem680);
+ _elem688 = iprot.readI64();
+ struct.nosuch.add(_elem688);
}
}
struct.setNosuchIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index 0a240e0..4a9824b 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -41,6 +41,7 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField REPLACE_FIELD_DESC = new org.apache.thrift.protocol.TField("replace", org.apache.thrift.protocol.TType.BOOL, (short)1);
private static final org.apache.thrift.protocol.TField FILES_ADDED_FIELD_DESC = new org.apache.thrift.protocol.TField("filesAdded", org.apache.thrift.protocol.TType.LIST, (short)2);
private static final org.apache.thrift.protocol.TField FILES_ADDED_CHECKSUM_FIELD_DESC = new org.apache.thrift.protocol.TField("filesAddedChecksum", org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField SUB_DIRECTORY_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("subDirectoryList", org.apache.thrift.protocol.TType.LIST, (short)4);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -51,12 +52,14 @@ import org.slf4j.LoggerFactory;
private boolean replace; // optional
private List<String> filesAdded; // required
private List<String> filesAddedChecksum; // optional
+ private List<String> subDirectoryList; // 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 {
REPLACE((short)1, "replace"),
FILES_ADDED((short)2, "filesAdded"),
- FILES_ADDED_CHECKSUM((short)3, "filesAddedChecksum");
+ FILES_ADDED_CHECKSUM((short)3, "filesAddedChecksum"),
+ SUB_DIRECTORY_LIST((short)4, "subDirectoryList");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -77,6 +80,8 @@ import org.slf4j.LoggerFactory;
return FILES_ADDED;
case 3: // FILES_ADDED_CHECKSUM
return FILES_ADDED_CHECKSUM;
+ case 4: // SUB_DIRECTORY_LIST
+ return SUB_DIRECTORY_LIST;
default:
return null;
}
@@ -119,7 +124,7 @@ import org.slf4j.LoggerFactory;
// isset id assignments
private static final int __REPLACE_ISSET_ID = 0;
private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.REPLACE,_Fields.FILES_ADDED_CHECKSUM};
+ private static final _Fields optionals[] = {_Fields.REPLACE,_Fields.FILES_ADDED_CHECKSUM,_Fields.SUB_DIRECTORY_LIST};
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);
@@ -131,6 +136,9 @@ import org.slf4j.LoggerFactory;
tmpMap.put(_Fields.FILES_ADDED_CHECKSUM, new org.apache.thrift.meta_data.FieldMetaData("filesAddedChecksum", 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.SUB_DIRECTORY_LIST, new org.apache.thrift.meta_data.FieldMetaData("subDirectoryList", 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))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(InsertEventRequestData.class, metaDataMap);
}
@@ -159,6 +167,10 @@ import org.slf4j.LoggerFactory;
List<String> __this__filesAddedChecksum = new ArrayList<String>(other.filesAddedChecksum);
this.filesAddedChecksum = __this__filesAddedChecksum;
}
+ if (other.isSetSubDirectoryList()) {
+ List<String> __this__subDirectoryList = new ArrayList<String>(other.subDirectoryList);
+ this.subDirectoryList = __this__subDirectoryList;
+ }
}
public InsertEventRequestData deepCopy() {
@@ -171,6 +183,7 @@ import org.slf4j.LoggerFactory;
this.replace = false;
this.filesAdded = null;
this.filesAddedChecksum = null;
+ this.subDirectoryList = null;
}
public boolean isReplace() {
@@ -271,6 +284,44 @@ import org.slf4j.LoggerFactory;
}
}
+ public int getSubDirectoryListSize() {
+ return (this.subDirectoryList == null) ? 0 : this.subDirectoryList.size();
+ }
+
+ public java.util.Iterator<String> getSubDirectoryListIterator() {
+ return (this.subDirectoryList == null) ? null : this.subDirectoryList.iterator();
+ }
+
+ public void addToSubDirectoryList(String elem) {
+ if (this.subDirectoryList == null) {
+ this.subDirectoryList = new ArrayList<String>();
+ }
+ this.subDirectoryList.add(elem);
+ }
+
+ public List<String> getSubDirectoryList() {
+ return this.subDirectoryList;
+ }
+
+ public void setSubDirectoryList(List<String> subDirectoryList) {
+ this.subDirectoryList = subDirectoryList;
+ }
+
+ public void unsetSubDirectoryList() {
+ this.subDirectoryList = null;
+ }
+
+ /** Returns true if field subDirectoryList is set (has been assigned a value) and false otherwise */
+ public boolean isSetSubDirectoryList() {
+ return this.subDirectoryList != null;
+ }
+
+ public void setSubDirectoryListIsSet(boolean value) {
+ if (!value) {
+ this.subDirectoryList = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case REPLACE:
@@ -297,6 +348,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case SUB_DIRECTORY_LIST:
+ if (value == null) {
+ unsetSubDirectoryList();
+ } else {
+ setSubDirectoryList((List<String>)value);
+ }
+ break;
+
}
}
@@ -311,6 +370,9 @@ import org.slf4j.LoggerFactory;
case FILES_ADDED_CHECKSUM:
return getFilesAddedChecksum();
+ case SUB_DIRECTORY_LIST:
+ return getSubDirectoryList();
+
}
throw new IllegalStateException();
}
@@ -328,6 +390,8 @@ import org.slf4j.LoggerFactory;
return isSetFilesAdded();
case FILES_ADDED_CHECKSUM:
return isSetFilesAddedChecksum();
+ case SUB_DIRECTORY_LIST:
+ return isSetSubDirectoryList();
}
throw new IllegalStateException();
}
@@ -372,6 +436,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_subDirectoryList = true && this.isSetSubDirectoryList();
+ boolean that_present_subDirectoryList = true && that.isSetSubDirectoryList();
+ if (this_present_subDirectoryList || that_present_subDirectoryList) {
+ if (!(this_present_subDirectoryList && that_present_subDirectoryList))
+ return false;
+ if (!this.subDirectoryList.equals(that.subDirectoryList))
+ return false;
+ }
+
return true;
}
@@ -394,6 +467,11 @@ import org.slf4j.LoggerFactory;
if (present_filesAddedChecksum)
list.add(filesAddedChecksum);
+ boolean present_subDirectoryList = true && (isSetSubDirectoryList());
+ list.add(present_subDirectoryList);
+ if (present_subDirectoryList)
+ list.add(subDirectoryList);
+
return list.hashCode();
}
@@ -435,6 +513,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetSubDirectoryList()).compareTo(other.isSetSubDirectoryList());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSubDirectoryList()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.subDirectoryList, other.subDirectoryList);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -478,6 +566,16 @@ import org.slf4j.LoggerFactory;
}
first = false;
}
+ if (isSetSubDirectoryList()) {
+ if (!first) sb.append(", ");
+ sb.append("subDirectoryList:");
+ if (this.subDirectoryList == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.subDirectoryList);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -538,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 _list724 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list724.size);
- String _elem725;
- for (int _i726 = 0; _i726 < _list724.size; ++_i726)
+ org.apache.thrift.protocol.TList _list732 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list732.size);
+ String _elem733;
+ for (int _i734 = 0; _i734 < _list732.size; ++_i734)
{
- _elem725 = iprot.readString();
- struct.filesAdded.add(_elem725);
+ _elem733 = iprot.readString();
+ struct.filesAdded.add(_elem733);
}
iprot.readListEnd();
}
@@ -556,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 _list727 = iprot.readListBegin();
- struct.filesAddedChecksum = new ArrayList<String>(_list727.size);
- String _elem728;
- for (int _i729 = 0; _i729 < _list727.size; ++_i729)
+ org.apache.thrift.protocol.TList _list735 = iprot.readListBegin();
+ struct.filesAddedChecksum = new ArrayList<String>(_list735.size);
+ String _elem736;
+ for (int _i737 = 0; _i737 < _list735.size; ++_i737)
{
- _elem728 = iprot.readString();
- struct.filesAddedChecksum.add(_elem728);
+ _elem736 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem736);
}
iprot.readListEnd();
}
@@ -571,6 +669,24 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 4: // SUB_DIRECTORY_LIST
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list738 = iprot.readListBegin();
+ struct.subDirectoryList = new ArrayList<String>(_list738.size);
+ String _elem739;
+ for (int _i740 = 0; _i740 < _list738.size; ++_i740)
+ {
+ _elem739 = iprot.readString();
+ struct.subDirectoryList.add(_elem739);
+ }
+ iprot.readListEnd();
+ }
+ struct.setSubDirectoryListIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -593,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 _iter730 : struct.filesAdded)
+ for (String _iter741 : struct.filesAdded)
{
- oprot.writeString(_iter730);
+ oprot.writeString(_iter741);
}
oprot.writeListEnd();
}
@@ -606,9 +722,23 @@ 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 _iter731 : struct.filesAddedChecksum)
+ for (String _iter742 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter731);
+ oprot.writeString(_iter742);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.subDirectoryList != null) {
+ if (struct.isSetSubDirectoryList()) {
+ 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 _iter743 : struct.subDirectoryList)
+ {
+ oprot.writeString(_iter743);
}
oprot.writeListEnd();
}
@@ -634,9 +764,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter732 : struct.filesAdded)
+ for (String _iter744 : struct.filesAdded)
{
- oprot.writeString(_iter732);
+ oprot.writeString(_iter744);
}
}
BitSet optionals = new BitSet();
@@ -646,16 +776,28 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFilesAddedChecksum()) {
optionals.set(1);
}
- oprot.writeBitSet(optionals, 2);
+ if (struct.isSetSubDirectoryList()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
if (struct.isSetReplace()) {
oprot.writeBool(struct.replace);
}
if (struct.isSetFilesAddedChecksum()) {
{
oprot.writeI32(struct.filesAddedChecksum.size());
- for (String _iter733 : struct.filesAddedChecksum)
+ for (String _iter745 : struct.filesAddedChecksum)
+ {
+ oprot.writeString(_iter745);
+ }
+ }
+ }
+ if (struct.isSetSubDirectoryList()) {
+ {
+ oprot.writeI32(struct.subDirectoryList.size());
+ for (String _iter746 : struct.subDirectoryList)
{
- oprot.writeString(_iter733);
+ oprot.writeString(_iter746);
}
}
}
@@ -665,34 +807,47 @@ 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 _list734 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list734.size);
- String _elem735;
- for (int _i736 = 0; _i736 < _list734.size; ++_i736)
+ org.apache.thrift.protocol.TList _list747 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list747.size);
+ String _elem748;
+ for (int _i749 = 0; _i749 < _list747.size; ++_i749)
{
- _elem735 = iprot.readString();
- struct.filesAdded.add(_elem735);
+ _elem748 = iprot.readString();
+ struct.filesAdded.add(_elem748);
}
}
struct.setFilesAddedIsSet(true);
- BitSet incoming = iprot.readBitSet(2);
+ BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
struct.replace = iprot.readBool();
struct.setReplaceIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAddedChecksum = new ArrayList<String>(_list737.size);
- String _elem738;
- for (int _i739 = 0; _i739 < _list737.size; ++_i739)
+ org.apache.thrift.protocol.TList _list750 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAddedChecksum = new ArrayList<String>(_list750.size);
+ String _elem751;
+ for (int _i752 = 0; _i752 < _list750.size; ++_i752)
{
- _elem738 = iprot.readString();
- struct.filesAddedChecksum.add(_elem738);
+ _elem751 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem751);
}
}
struct.setFilesAddedChecksumIsSet(true);
}
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TList _list753 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.subDirectoryList = new ArrayList<String>(_list753.size);
+ String _elem754;
+ for (int _i755 = 0; _i755 < _list753.size; ++_i755)
+ {
+ _elem754 = iprot.readString();
+ struct.subDirectoryList.add(_elem754);
+ }
+ }
+ struct.setSubDirectoryListIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
index d0dc21c..d4eed32 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
@@ -689,14 +689,14 @@ import org.slf4j.LoggerFactory;
case 1: // COMPONENT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
- struct.component = new ArrayList<LockComponent>(_list650.size);
- LockComponent _elem651;
- for (int _i652 = 0; _i652 < _list650.size; ++_i652)
+ org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
+ struct.component = new ArrayList<LockComponent>(_list658.size);
+ LockComponent _elem659;
+ for (int _i660 = 0; _i660 < _list658.size; ++_i660)
{
- _elem651 = new LockComponent();
- _elem651.read(iprot);
- struct.component.add(_elem651);
+ _elem659 = new LockComponent();
+ _elem659.read(iprot);
+ struct.component.add(_elem659);
}
iprot.readListEnd();
}
@@ -754,9 +754,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COMPONENT_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size()));
- for (LockComponent _iter653 : struct.component)
+ for (LockComponent _iter661 : struct.component)
{
- _iter653.write(oprot);
+ _iter661.write(oprot);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.component.size());
- for (LockComponent _iter654 : struct.component)
+ for (LockComponent _iter662 : struct.component)
{
- _iter654.write(oprot);
+ _iter662.write(oprot);
}
}
oprot.writeString(struct.user);
@@ -830,14 +830,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component = new ArrayList<LockComponent>(_list655.size);
- LockComponent _elem656;
- for (int _i657 = 0; _i657 < _list655.size; ++_i657)
+ org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component = new ArrayList<LockComponent>(_list663.size);
+ LockComponent _elem664;
+ for (int _i665 = 0; _i665 < _list663.size; ++_i665)
{
- _elem656 = new LockComponent();
- _elem656.read(iprot);
- struct.component.add(_elem656);
+ _elem664 = new LockComponent();
+ _elem664.read(iprot);
+ struct.component.add(_elem664);
}
}
struct.setComponentIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
index 0c850fa..9228c39 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // EVENTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
- struct.events = new ArrayList<NotificationEvent>(_list716.size);
- NotificationEvent _elem717;
- for (int _i718 = 0; _i718 < _list716.size; ++_i718)
+ org.apache.thrift.protocol.TList _list724 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list724.size);
+ NotificationEvent _elem725;
+ for (int _i726 = 0; _i726 < _list724.size; ++_i726)
{
- _elem717 = new NotificationEvent();
- _elem717.read(iprot);
- struct.events.add(_elem717);
+ _elem725 = new NotificationEvent();
+ _elem725.read(iprot);
+ struct.events.add(_elem725);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(EVENTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size()));
- for (NotificationEvent _iter719 : struct.events)
+ for (NotificationEvent _iter727 : struct.events)
{
- _iter719.write(oprot);
+ _iter727.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.events.size());
- for (NotificationEvent _iter720 : struct.events)
+ for (NotificationEvent _iter728 : struct.events)
{
- _iter720.write(oprot);
+ _iter728.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.events = new ArrayList<NotificationEvent>(_list721.size);
- NotificationEvent _elem722;
- for (int _i723 = 0; _i723 < _list721.size; ++_i723)
+ org.apache.thrift.protocol.TList _list729 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.events = new ArrayList<NotificationEvent>(_list729.size);
+ NotificationEvent _elem730;
+ for (int _i731 = 0; _i731 < _list729.size; ++_i731)
{
- _elem722 = new NotificationEvent();
- _elem722.read(iprot);
- struct.events.add(_elem722);
+ _elem730 = new NotificationEvent();
+ _elem730.read(iprot);
+ struct.events.add(_elem730);
}
}
struct.setEventsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
index 77c260d..7d9ebba 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
@@ -547,13 +547,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list784 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list784.size);
- long _elem785;
- for (int _i786 = 0; _i786 < _list784.size; ++_i786)
+ org.apache.thrift.protocol.TList _list808 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list808.size);
+ long _elem809;
+ for (int _i810 = 0; _i810 < _list808.size; ++_i810)
{
- _elem785 = iprot.readI64();
- struct.fileIds.add(_elem785);
+ _elem809 = iprot.readI64();
+ struct.fileIds.add(_elem809);
}
iprot.readListEnd();
}
@@ -565,13 +565,13 @@ import org.slf4j.LoggerFactory;
case 2: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list787 = iprot.readListBegin();
- struct.metadata = new ArrayList<ByteBuffer>(_list787.size);
- ByteBuffer _elem788;
- for (int _i789 = 0; _i789 < _list787.size; ++_i789)
+ org.apache.thrift.protocol.TList _list811 = iprot.readListBegin();
+ struct.metadata = new ArrayList<ByteBuffer>(_list811.size);
+ ByteBuffer _elem812;
+ for (int _i813 = 0; _i813 < _list811.size; ++_i813)
{
- _elem788 = iprot.readBinary();
- struct.metadata.add(_elem788);
+ _elem812 = iprot.readBinary();
+ struct.metadata.add(_elem812);
}
iprot.readListEnd();
}
@@ -605,9 +605,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter790 : struct.fileIds)
+ for (long _iter814 : struct.fileIds)
{
- oprot.writeI64(_iter790);
+ oprot.writeI64(_iter814);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (ByteBuffer _iter791 : struct.metadata)
+ for (ByteBuffer _iter815 : struct.metadata)
{
- oprot.writeBinary(_iter791);
+ oprot.writeBinary(_iter815);
}
oprot.writeListEnd();
}
@@ -651,16 +651,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter792 : struct.fileIds)
+ for (long _iter816 : struct.fileIds)
{
- oprot.writeI64(_iter792);
+ oprot.writeI64(_iter816);
}
}
{
oprot.writeI32(struct.metadata.size());
- for (ByteBuffer _iter793 : struct.metadata)
+ for (ByteBuffer _iter817 : struct.metadata)
{
- oprot.writeBinary(_iter793);
+ oprot.writeBinary(_iter817);
}
}
BitSet optionals = new BitSet();
@@ -677,24 +677,24 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, PutFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list794 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list794.size);
- long _elem795;
- for (int _i796 = 0; _i796 < _list794.size; ++_i796)
+ org.apache.thrift.protocol.TList _list818 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list818.size);
+ long _elem819;
+ for (int _i820 = 0; _i820 < _list818.size; ++_i820)
{
- _elem795 = iprot.readI64();
- struct.fileIds.add(_elem795);
+ _elem819 = iprot.readI64();
+ struct.fileIds.add(_elem819);
}
}
struct.setFileIdsIsSet(true);
{
- org.apache.thrift.protocol.TList _list797 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new ArrayList<ByteBuffer>(_list797.size);
- ByteBuffer _elem798;
- for (int _i799 = 0; _i799 < _list797.size; ++_i799)
+ org.apache.thrift.protocol.TList _list821 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new ArrayList<ByteBuffer>(_list821.size);
+ ByteBuffer _elem822;
+ for (int _i823 = 0; _i823 < _list821.size; ++_i823)
{
- _elem798 = iprot.readBinary();
- struct.metadata.add(_elem798);
+ _elem822 = iprot.readBinary();
+ struct.metadata.add(_elem822);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
index 97bb8a4..0aeca14 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
@@ -813,13 +813,13 @@ import org.slf4j.LoggerFactory;
case 6: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list594.size);
- String _elem595;
- for (int _i596 = 0; _i596 < _list594.size; ++_i596)
+ org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list602.size);
+ String _elem603;
+ for (int _i604 = 0; _i604 < _list602.size; ++_i604)
{
- _elem595 = iprot.readString();
- struct.partNames.add(_elem595);
+ _elem603 = iprot.readString();
+ struct.partNames.add(_elem603);
}
iprot.readListEnd();
}
@@ -871,9 +871,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PART_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size()));
- for (String _iter597 : struct.partNames)
+ for (String _iter605 : struct.partNames)
{
- oprot.writeString(_iter597);
+ oprot.writeString(_iter605);
}
oprot.writeListEnd();
}
@@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter598 : struct.partNames)
+ for (String _iter606 : struct.partNames)
{
- oprot.writeString(_iter598);
+ oprot.writeString(_iter606);
}
}
}
@@ -934,13 +934,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list599.size);
- String _elem600;
- for (int _i601 = 0; _i601 < _list599.size; ++_i601)
+ org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list607.size);
+ String _elem608;
+ for (int _i609 = 0; _i609 < _list607.size; ++_i609)
{
- _elem600 = iprot.readString();
- struct.partNames.add(_elem600);
+ _elem608 = iprot.readString();
+ struct.partNames.add(_elem608);
}
}
struct.setPartNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
index 62bc3b4..935af04 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
@@ -1119,14 +1119,14 @@ import org.slf4j.LoggerFactory;
case 4: // COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list904 = iprot.readListBegin();
- struct.cols = new ArrayList<FieldSchema>(_list904.size);
- FieldSchema _elem905;
- for (int _i906 = 0; _i906 < _list904.size; ++_i906)
+ org.apache.thrift.protocol.TList _list928 = iprot.readListBegin();
+ struct.cols = new ArrayList<FieldSchema>(_list928.size);
+ FieldSchema _elem929;
+ for (int _i930 = 0; _i930 < _list928.size; ++_i930)
{
- _elem905 = new FieldSchema();
- _elem905.read(iprot);
- struct.cols.add(_elem905);
+ _elem929 = new FieldSchema();
+ _elem929.read(iprot);
+ struct.cols.add(_elem929);
}
iprot.readListEnd();
}
@@ -1212,9 +1212,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 _iter907 : struct.cols)
+ for (FieldSchema _iter931 : struct.cols)
{
- _iter907.write(oprot);
+ _iter931.write(oprot);
}
oprot.writeListEnd();
}
@@ -1323,9 +1323,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetCols()) {
{
oprot.writeI32(struct.cols.size());
- for (FieldSchema _iter908 : struct.cols)
+ for (FieldSchema _iter932 : struct.cols)
{
- _iter908.write(oprot);
+ _iter932.write(oprot);
}
}
}
@@ -1368,14 +1368,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list909 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.cols = new ArrayList<FieldSchema>(_list909.size);
- FieldSchema _elem910;
- for (int _i911 = 0; _i911 < _list909.size; ++_i911)
+ org.apache.thrift.protocol.TList _list933 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.cols = new ArrayList<FieldSchema>(_list933.size);
+ FieldSchema _elem934;
+ for (int _i935 = 0; _i935 < _list933.size; ++_i935)
{
- _elem910 = new FieldSchema();
- _elem910.read(iprot);
- struct.cols.add(_elem910);
+ _elem934 = new FieldSchema();
+ _elem934.read(iprot);
+ struct.cols.add(_elem934);
}
}
struct.setColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
index d7e5132..9fb037f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
+++ b/standalone-metastore/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 _list692 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list692.size);
- ShowCompactResponseElement _elem693;
- for (int _i694 = 0; _i694 < _list692.size; ++_i694)
+ 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)
{
- _elem693 = new ShowCompactResponseElement();
- _elem693.read(iprot);
- struct.compacts.add(_elem693);
+ _elem701 = new ShowCompactResponseElement();
+ _elem701.read(iprot);
+ struct.compacts.add(_elem701);
}
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 _iter695 : struct.compacts)
+ for (ShowCompactResponseElement _iter703 : struct.compacts)
{
- _iter695.write(oprot);
+ _iter703.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter696 : struct.compacts)
+ for (ShowCompactResponseElement _iter704 : struct.compacts)
{
- _iter696.write(oprot);
+ _iter704.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 _list697 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list697.size);
- ShowCompactResponseElement _elem698;
- for (int _i699 = 0; _i699 < _list697.size; ++_i699)
+ 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)
{
- _elem698 = new ShowCompactResponseElement();
- _elem698.read(iprot);
- struct.compacts.add(_elem698);
+ _elem706 = new ShowCompactResponseElement();
+ _elem706.read(iprot);
+ struct.compacts.add(_elem706);
}
}
struct.setCompactsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
index 0e1009c..e0db2f7 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
+++ b/standalone-metastore/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 _list658 = iprot.readListBegin();
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list658.size);
- ShowLocksResponseElement _elem659;
- for (int _i660 = 0; _i660 < _list658.size; ++_i660)
+ 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)
{
- _elem659 = new ShowLocksResponseElement();
- _elem659.read(iprot);
- struct.locks.add(_elem659);
+ _elem667 = new ShowLocksResponseElement();
+ _elem667.read(iprot);
+ struct.locks.add(_elem667);
}
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 _iter661 : struct.locks)
+ for (ShowLocksResponseElement _iter669 : struct.locks)
{
- _iter661.write(oprot);
+ _iter669.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLocks()) {
{
oprot.writeI32(struct.locks.size());
- for (ShowLocksResponseElement _iter662 : struct.locks)
+ for (ShowLocksResponseElement _iter670 : struct.locks)
{
- _iter662.write(oprot);
+ _iter670.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list663.size);
- ShowLocksResponseElement _elem664;
- for (int _i665 = 0; _i665 < _list663.size; ++_i665)
+ 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)
{
- _elem664 = new ShowLocksResponseElement();
- _elem664.read(iprot);
- struct.locks.add(_elem664);
+ _elem672 = new ShowLocksResponseElement();
+ _elem672.read(iprot);
+ struct.locks.add(_elem672);
}
}
struct.setLocksIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
index 20f225d..de15fc6 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
+++ b/standalone-metastore/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 _list610 = iprot.readListBegin();
- struct.invalidWriteIds = new ArrayList<Long>(_list610.size);
- long _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ 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)
{
- _elem611 = iprot.readI64();
- struct.invalidWriteIds.add(_elem611);
+ _elem619 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem619);
}
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 _iter613 : struct.invalidWriteIds)
+ for (long _iter621 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter613);
+ oprot.writeI64(_iter621);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
oprot.writeI64(struct.writeIdHighWaterMark);
{
oprot.writeI32(struct.invalidWriteIds.size());
- for (long _iter614 : struct.invalidWriteIds)
+ for (long _iter622 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter614);
+ oprot.writeI64(_iter622);
}
}
oprot.writeBinary(struct.abortedBits);
@@ -827,13 +827,13 @@ import org.slf4j.LoggerFactory;
struct.writeIdHighWaterMark = iprot.readI64();
struct.setWriteIdHighWaterMarkIsSet(true);
{
- org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.invalidWriteIds = new ArrayList<Long>(_list615.size);
- long _elem616;
- for (int _i617 = 0; _i617 < _list615.size; ++_i617)
+ 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)
{
- _elem616 = iprot.readI64();
- struct.invalidWriteIds.add(_elem616);
+ _elem624 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem624);
}
}
struct.setInvalidWriteIdsIsSet(true);