You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2016/12/19 22:10:06 UTC
[5/8] hive git commit: HIVE-15294: Capture additional metadata to
replicate a simple insert at destination (Vaibhav Gumashta reviewed by Thejas
Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
index 5cf880a..7aebede 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
@@ -351,13 +351,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list602.size);
- long _elem603;
- for (int _i604 = 0; _i604 < _list602.size; ++_i604)
+ org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list610.size);
+ long _elem611;
+ for (int _i612 = 0; _i612 < _list610.size; ++_i612)
{
- _elem603 = iprot.readI64();
- struct.fileIds.add(_elem603);
+ _elem611 = iprot.readI64();
+ struct.fileIds.add(_elem611);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
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 _iter605 : struct.fileIds)
+ for (long _iter613 : struct.fileIds)
{
- oprot.writeI64(_iter605);
+ oprot.writeI64(_iter613);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter606 : struct.fileIds)
+ for (long _iter614 : struct.fileIds)
{
- oprot.writeI64(_iter606);
+ oprot.writeI64(_iter614);
}
}
}
@@ -421,13 +421,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest 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.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list607.size);
- long _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.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list615.size);
+ long _elem616;
+ for (int _i617 = 0; _i617 < _list615.size; ++_i617)
{
- _elem608 = iprot.readI64();
- struct.fileIds.add(_elem608);
+ _elem616 = iprot.readI64();
+ struct.fileIds.add(_elem616);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
index 8870c2f..fe83a6e 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
@@ -433,15 +433,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map592 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map592.size);
- long _key593;
- ByteBuffer _val594;
- for (int _i595 = 0; _i595 < _map592.size; ++_i595)
+ org.apache.thrift.protocol.TMap _map600 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map600.size);
+ long _key601;
+ ByteBuffer _val602;
+ for (int _i603 = 0; _i603 < _map600.size; ++_i603)
{
- _key593 = iprot.readI64();
- _val594 = iprot.readBinary();
- struct.metadata.put(_key593, _val594);
+ _key601 = iprot.readI64();
+ _val602 = iprot.readBinary();
+ struct.metadata.put(_key601, _val602);
}
iprot.readMapEnd();
}
@@ -475,10 +475,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (Map.Entry<Long, ByteBuffer> _iter596 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter604 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter596.getKey());
- oprot.writeBinary(_iter596.getValue());
+ oprot.writeI64(_iter604.getKey());
+ oprot.writeBinary(_iter604.getValue());
}
oprot.writeMapEnd();
}
@@ -506,10 +506,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, ByteBuffer> _iter597 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter605 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter597.getKey());
- oprot.writeBinary(_iter597.getValue());
+ oprot.writeI64(_iter605.getKey());
+ oprot.writeBinary(_iter605.getValue());
}
}
oprot.writeBool(struct.isSupported);
@@ -519,15 +519,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map598 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map598.size);
- long _key599;
- ByteBuffer _val600;
- for (int _i601 = 0; _i601 < _map598.size; ++_i601)
+ org.apache.thrift.protocol.TMap _map606 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map606.size);
+ long _key607;
+ ByteBuffer _val608;
+ for (int _i609 = 0; _i609 < _map606.size; ++_i609)
{
- _key599 = iprot.readI64();
- _val600 = iprot.readBinary();
- struct.metadata.put(_key599, _val600);
+ _key607 = iprot.readI64();
+ _val608 = iprot.readBinary();
+ struct.metadata.put(_key607, _val608);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
index de4b2f6..225fda9 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
@@ -525,13 +525,13 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
- struct.tblNames = new ArrayList<String>(_list650.size);
- String _elem651;
- for (int _i652 = 0; _i652 < _list650.size; ++_i652)
+ org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
+ struct.tblNames = new ArrayList<String>(_list658.size);
+ String _elem659;
+ for (int _i660 = 0; _i660 < _list658.size; ++_i660)
{
- _elem651 = iprot.readString();
- struct.tblNames.add(_elem651);
+ _elem659 = iprot.readString();
+ struct.tblNames.add(_elem659);
}
iprot.readListEnd();
}
@@ -572,9 +572,9 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tblNames.size()));
- for (String _iter653 : struct.tblNames)
+ for (String _iter661 : struct.tblNames)
{
- oprot.writeString(_iter653);
+ oprot.writeString(_iter661);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
if (struct.isSetTblNames()) {
{
oprot.writeI32(struct.tblNames.size());
- for (String _iter654 : struct.tblNames)
+ for (String _iter662 : struct.tblNames)
{
- oprot.writeString(_iter654);
+ oprot.writeString(_iter662);
}
}
}
@@ -636,13 +636,13 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tblNames = new ArrayList<String>(_list655.size);
- String _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.STRING, iprot.readI32());
+ struct.tblNames = new ArrayList<String>(_list663.size);
+ String _elem664;
+ for (int _i665 = 0; _i665 < _list663.size; ++_i665)
{
- _elem656 = iprot.readString();
- struct.tblNames.add(_elem656);
+ _elem664 = iprot.readString();
+ struct.tblNames.add(_elem664);
}
}
struct.setTblNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
index 4c456f2..91cb198 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
@@ -354,14 +354,14 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
case 1: // TABLES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
- struct.tables = new ArrayList<Table>(_list658.size);
- Table _elem659;
- for (int _i660 = 0; _i660 < _list658.size; ++_i660)
+ org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
+ struct.tables = new ArrayList<Table>(_list666.size);
+ Table _elem667;
+ for (int _i668 = 0; _i668 < _list666.size; ++_i668)
{
- _elem659 = new Table();
- _elem659.read(iprot);
- struct.tables.add(_elem659);
+ _elem667 = new Table();
+ _elem667.read(iprot);
+ struct.tables.add(_elem667);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
oprot.writeFieldBegin(TABLES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tables.size()));
- for (Table _iter661 : struct.tables)
+ for (Table _iter669 : struct.tables)
{
- _iter661.write(oprot);
+ _iter669.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tables.size());
- for (Table _iter662 : struct.tables)
+ for (Table _iter670 : struct.tables)
{
- _iter662.write(oprot);
+ _iter670.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tables = new ArrayList<Table>(_list663.size);
- Table _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.tables = new ArrayList<Table>(_list671.size);
+ Table _elem672;
+ for (int _i673 = 0; _i673 < _list671.size; ++_i673)
{
- _elem664 = new Table();
- _elem664.read(iprot);
- struct.tables.add(_elem664);
+ _elem672 = new Table();
+ _elem672.read(iprot);
+ struct.tables.add(_elem672);
}
}
struct.setTablesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index a8df524..39a607d 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -39,6 +39,7 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("InsertEventRequestData");
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)1);
+ 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)2);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -47,10 +48,12 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
}
private List<String> filesAdded; // required
+ private List<ByteBuffer> filesAddedChecksum; // 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 {
- FILES_ADDED((short)1, "filesAdded");
+ FILES_ADDED((short)1, "filesAdded"),
+ FILES_ADDED_CHECKSUM((short)2, "filesAddedChecksum");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -67,6 +70,8 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
switch(fieldId) {
case 1: // FILES_ADDED
return FILES_ADDED;
+ case 2: // FILES_ADDED_CHECKSUM
+ return FILES_ADDED_CHECKSUM;
default:
return null;
}
@@ -107,12 +112,16 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
}
// isset id assignments
+ private static final _Fields optionals[] = {_Fields.FILES_ADDED_CHECKSUM};
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.FILES_ADDED, new org.apache.thrift.meta_data.FieldMetaData("filesAdded", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ tmpMap.put(_Fields.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 , true))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(InsertEventRequestData.class, metaDataMap);
}
@@ -135,6 +144,10 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
List<String> __this__filesAdded = new ArrayList<String>(other.filesAdded);
this.filesAdded = __this__filesAdded;
}
+ if (other.isSetFilesAddedChecksum()) {
+ List<ByteBuffer> __this__filesAddedChecksum = new ArrayList<ByteBuffer>(other.filesAddedChecksum);
+ this.filesAddedChecksum = __this__filesAddedChecksum;
+ }
}
public InsertEventRequestData deepCopy() {
@@ -144,6 +157,7 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
@Override
public void clear() {
this.filesAdded = null;
+ this.filesAddedChecksum = null;
}
public int getFilesAddedSize() {
@@ -184,6 +198,44 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
}
}
+ public int getFilesAddedChecksumSize() {
+ return (this.filesAddedChecksum == null) ? 0 : this.filesAddedChecksum.size();
+ }
+
+ public java.util.Iterator<ByteBuffer> getFilesAddedChecksumIterator() {
+ return (this.filesAddedChecksum == null) ? null : this.filesAddedChecksum.iterator();
+ }
+
+ public void addToFilesAddedChecksum(ByteBuffer elem) {
+ if (this.filesAddedChecksum == null) {
+ this.filesAddedChecksum = new ArrayList<ByteBuffer>();
+ }
+ this.filesAddedChecksum.add(elem);
+ }
+
+ public List<ByteBuffer> getFilesAddedChecksum() {
+ return this.filesAddedChecksum;
+ }
+
+ public void setFilesAddedChecksum(List<ByteBuffer> filesAddedChecksum) {
+ this.filesAddedChecksum = filesAddedChecksum;
+ }
+
+ public void unsetFilesAddedChecksum() {
+ this.filesAddedChecksum = null;
+ }
+
+ /** Returns true if field filesAddedChecksum is set (has been assigned a value) and false otherwise */
+ public boolean isSetFilesAddedChecksum() {
+ return this.filesAddedChecksum != null;
+ }
+
+ public void setFilesAddedChecksumIsSet(boolean value) {
+ if (!value) {
+ this.filesAddedChecksum = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case FILES_ADDED:
@@ -194,6 +246,14 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
}
break;
+ case FILES_ADDED_CHECKSUM:
+ if (value == null) {
+ unsetFilesAddedChecksum();
+ } else {
+ setFilesAddedChecksum((List<ByteBuffer>)value);
+ }
+ break;
+
}
}
@@ -202,6 +262,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
case FILES_ADDED:
return getFilesAdded();
+ case FILES_ADDED_CHECKSUM:
+ return getFilesAddedChecksum();
+
}
throw new IllegalStateException();
}
@@ -215,6 +278,8 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
switch (field) {
case FILES_ADDED:
return isSetFilesAdded();
+ case FILES_ADDED_CHECKSUM:
+ return isSetFilesAddedChecksum();
}
throw new IllegalStateException();
}
@@ -241,6 +306,15 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
return false;
}
+ boolean this_present_filesAddedChecksum = true && this.isSetFilesAddedChecksum();
+ boolean that_present_filesAddedChecksum = true && that.isSetFilesAddedChecksum();
+ if (this_present_filesAddedChecksum || that_present_filesAddedChecksum) {
+ if (!(this_present_filesAddedChecksum && that_present_filesAddedChecksum))
+ return false;
+ if (!this.filesAddedChecksum.equals(that.filesAddedChecksum))
+ return false;
+ }
+
return true;
}
@@ -253,6 +327,11 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
if (present_filesAdded)
list.add(filesAdded);
+ boolean present_filesAddedChecksum = true && (isSetFilesAddedChecksum());
+ list.add(present_filesAddedChecksum);
+ if (present_filesAddedChecksum)
+ list.add(filesAddedChecksum);
+
return list.hashCode();
}
@@ -274,6 +353,16 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetFilesAddedChecksum()).compareTo(other.isSetFilesAddedChecksum());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFilesAddedChecksum()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.filesAddedChecksum, other.filesAddedChecksum);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -301,6 +390,16 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
sb.append(this.filesAdded);
}
first = false;
+ if (isSetFilesAddedChecksum()) {
+ if (!first) sb.append(", ");
+ sb.append("filesAddedChecksum:");
+ if (this.filesAddedChecksum == null) {
+ sb.append("null");
+ } else {
+ org.apache.thrift.TBaseHelper.toString(this.filesAddedChecksum, sb);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -366,6 +465,24 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 2: // FILES_ADDED_CHECKSUM
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list561 = iprot.readListBegin();
+ struct.filesAddedChecksum = new ArrayList<ByteBuffer>(_list561.size);
+ ByteBuffer _elem562;
+ for (int _i563 = 0; _i563 < _list561.size; ++_i563)
+ {
+ _elem562 = iprot.readBinary();
+ struct.filesAddedChecksum.add(_elem562);
+ }
+ iprot.readListEnd();
+ }
+ struct.setFilesAddedChecksumIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -383,14 +500,28 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
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 _iter561 : struct.filesAdded)
+ for (String _iter564 : struct.filesAdded)
{
- oprot.writeString(_iter561);
+ oprot.writeString(_iter564);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
+ if (struct.filesAddedChecksum != null) {
+ if (struct.isSetFilesAddedChecksum()) {
+ 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 (ByteBuffer _iter565 : struct.filesAddedChecksum)
+ {
+ oprot.writeBinary(_iter565);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -410,9 +541,23 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter562 : struct.filesAdded)
+ for (String _iter566 : struct.filesAdded)
{
- oprot.writeString(_iter562);
+ oprot.writeString(_iter566);
+ }
+ }
+ BitSet optionals = new BitSet();
+ if (struct.isSetFilesAddedChecksum()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetFilesAddedChecksum()) {
+ {
+ oprot.writeI32(struct.filesAddedChecksum.size());
+ for (ByteBuffer _iter567 : struct.filesAddedChecksum)
+ {
+ oprot.writeBinary(_iter567);
+ }
}
}
}
@@ -421,16 +566,30 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
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 _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list563.size);
- String _elem564;
- for (int _i565 = 0; _i565 < _list563.size; ++_i565)
+ org.apache.thrift.protocol.TList _list568 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list568.size);
+ String _elem569;
+ for (int _i570 = 0; _i570 < _list568.size; ++_i570)
{
- _elem564 = iprot.readString();
- struct.filesAdded.add(_elem564);
+ _elem569 = iprot.readString();
+ struct.filesAdded.add(_elem569);
}
}
struct.setFilesAddedIsSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list571 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAddedChecksum = new ArrayList<ByteBuffer>(_list571.size);
+ ByteBuffer _elem572;
+ for (int _i573 = 0; _i573 < _list571.size; ++_i573)
+ {
+ _elem572 = iprot.readBinary();
+ struct.filesAddedChecksum.add(_elem572);
+ }
+ }
+ struct.setFilesAddedChecksumIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
index 6eff25d..0a1302f 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
@@ -547,13 +547,13 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list610.size);
- long _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ org.apache.thrift.protocol.TList _list618 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list618.size);
+ long _elem619;
+ for (int _i620 = 0; _i620 < _list618.size; ++_i620)
{
- _elem611 = iprot.readI64();
- struct.fileIds.add(_elem611);
+ _elem619 = iprot.readI64();
+ struct.fileIds.add(_elem619);
}
iprot.readListEnd();
}
@@ -565,13 +565,13 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
case 2: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list613 = iprot.readListBegin();
- struct.metadata = new ArrayList<ByteBuffer>(_list613.size);
- ByteBuffer _elem614;
- for (int _i615 = 0; _i615 < _list613.size; ++_i615)
+ org.apache.thrift.protocol.TList _list621 = iprot.readListBegin();
+ struct.metadata = new ArrayList<ByteBuffer>(_list621.size);
+ ByteBuffer _elem622;
+ for (int _i623 = 0; _i623 < _list621.size; ++_i623)
{
- _elem614 = iprot.readBinary();
- struct.metadata.add(_elem614);
+ _elem622 = iprot.readBinary();
+ struct.metadata.add(_elem622);
}
iprot.readListEnd();
}
@@ -605,9 +605,9 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
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 _iter616 : struct.fileIds)
+ for (long _iter624 : struct.fileIds)
{
- oprot.writeI64(_iter616);
+ oprot.writeI64(_iter624);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (ByteBuffer _iter617 : struct.metadata)
+ for (ByteBuffer _iter625 : struct.metadata)
{
- oprot.writeBinary(_iter617);
+ oprot.writeBinary(_iter625);
}
oprot.writeListEnd();
}
@@ -651,16 +651,16 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter618 : struct.fileIds)
+ for (long _iter626 : struct.fileIds)
{
- oprot.writeI64(_iter618);
+ oprot.writeI64(_iter626);
}
}
{
oprot.writeI32(struct.metadata.size());
- for (ByteBuffer _iter619 : struct.metadata)
+ for (ByteBuffer _iter627 : struct.metadata)
{
- oprot.writeBinary(_iter619);
+ oprot.writeBinary(_iter627);
}
}
BitSet optionals = new BitSet();
@@ -677,24 +677,24 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe
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 _list620 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list620.size);
- long _elem621;
- for (int _i622 = 0; _i622 < _list620.size; ++_i622)
+ org.apache.thrift.protocol.TList _list628 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list628.size);
+ long _elem629;
+ for (int _i630 = 0; _i630 < _list628.size; ++_i630)
{
- _elem621 = iprot.readI64();
- struct.fileIds.add(_elem621);
+ _elem629 = iprot.readI64();
+ struct.fileIds.add(_elem629);
}
}
struct.setFileIdsIsSet(true);
{
- org.apache.thrift.protocol.TList _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new ArrayList<ByteBuffer>(_list623.size);
- ByteBuffer _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.STRING, iprot.readI32());
+ struct.metadata = new ArrayList<ByteBuffer>(_list631.size);
+ ByteBuffer _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
{
- _elem624 = iprot.readBinary();
- struct.metadata.add(_elem624);
+ _elem632 = iprot.readBinary();
+ struct.metadata.add(_elem632);
}
}
struct.setMetadataIsSet(true);