hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vgumas...@apache.org
Subject [5/8] hive git commit: HIVE-15294: Capture additional metadata to replicate a simple insert at destination (Vaibhav Gumashta reviewed by Thejas Nair)
Date Mon, 19 Dec 2016 22:10:06 GMT
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);


Mime
View raw message