hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject [13/22] hive git commit: HIVE-12832 Thrift and RDBMS schema changes for ACID fixes, branch-1 version.
Date Fri, 15 Jan 2016 01:18:02 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StringColumnStatsData.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StringColumnStatsData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StringColumnStatsData.java
index 9906ff3..2cbe955 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StringColumnStatsData.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StringColumnStatsData.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class StringColumnStatsData implements org.apache.thrift.TBase<StringColumnStatsData, StringColumnStatsData._Fields>, java.io.Serializable, Cloneable, Comparable<StringColumnStatsData> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StringColumnStatsData");
 
@@ -317,16 +317,16 @@ public class StringColumnStatsData implements org.apache.thrift.TBase<StringColu
   public Object getFieldValue(_Fields field) {
     switch (field) {
     case MAX_COL_LEN:
-      return Long.valueOf(getMaxColLen());
+      return getMaxColLen();
 
     case AVG_COL_LEN:
-      return Double.valueOf(getAvgColLen());
+      return getAvgColLen();
 
     case NUM_NULLS:
-      return Long.valueOf(getNumNulls());
+      return getNumNulls();
 
     case NUM_DVS:
-      return Long.valueOf(getNumDVs());
+      return getNumDVs();
 
     }
     throw new IllegalStateException();

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
index 51b9e38..81b63fc 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class Table implements org.apache.thrift.TBase<Table, Table._Fields>, java.io.Serializable, Cloneable, Comparable<Table> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Table");
 
@@ -798,13 +798,13 @@ public class Table implements org.apache.thrift.TBase<Table, Table._Fields>, jav
       return getOwner();
 
     case CREATE_TIME:
-      return Integer.valueOf(getCreateTime());
+      return getCreateTime();
 
     case LAST_ACCESS_TIME:
-      return Integer.valueOf(getLastAccessTime());
+      return getLastAccessTime();
 
     case RETENTION:
-      return Integer.valueOf(getRetention());
+      return getRetention();
 
     case SD:
       return getSd();
@@ -828,7 +828,7 @@ public class Table implements org.apache.thrift.TBase<Table, Table._Fields>, jav
       return getPrivileges();
 
     case TEMPORARY:
-      return Boolean.valueOf(isTemporary());
+      return isTemporary();
 
     }
     throw new IllegalStateException();

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
index 1edcaf9..70f2fb6 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class TableStatsRequest implements org.apache.thrift.TBase<TableStatsRequest, TableStatsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<TableStatsRequest> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TableStatsRequest");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
index 25a1f25..51fd1cc 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class TableStatsResult implements org.apache.thrift.TBase<TableStatsResult, TableStatsResult._Fields>, java.io.Serializable, Cloneable, Comparable<TableStatsResult> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TableStatsResult");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index 0c4db9d..9054e0e 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-1-13")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class ThriftHiveMetastore {
 
   /**
@@ -23758,10 +23758,10 @@ public class ThriftHiveMetastore {
         return getName();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       case CASCADE:
-        return Boolean.valueOf(isCascade());
+        return isCascade();
 
       }
       throw new IllegalStateException();
@@ -28788,7 +28788,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -29778,7 +29778,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -38418,7 +38418,7 @@ public class ThriftHiveMetastore {
         return getName();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       }
       throw new IllegalStateException();
@@ -39492,7 +39492,7 @@ public class ThriftHiveMetastore {
         return getName();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       case ENVIRONMENT_CONTEXT:
         return getEnvironment_context();
@@ -44713,7 +44713,7 @@ public class ThriftHiveMetastore {
         return getFilter();
 
       case MAX_TABLES:
-        return Short.valueOf(getMax_tables());
+        return getMax_tables();
 
       }
       throw new IllegalStateException();
@@ -48232,7 +48232,7 @@ public class ThriftHiveMetastore {
         return getNew_tbl();
 
       case CASCADE:
-        return Boolean.valueOf(isCascade());
+        return isCascade();
 
       }
       throw new IllegalStateException();
@@ -51971,7 +51971,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Integer.valueOf(getSuccess());
+        return getSuccess();
 
       case O1:
         return getO1();
@@ -53059,7 +53059,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Integer.valueOf(getSuccess());
+        return getSuccess();
 
       case O1:
         return getO1();
@@ -60109,7 +60109,7 @@ public class ThriftHiveMetastore {
         return getPart_vals();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       }
       throw new IllegalStateException();
@@ -60756,7 +60756,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -61440,7 +61440,7 @@ public class ThriftHiveMetastore {
         return getPart_vals();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       case ENVIRONMENT_CONTEXT:
         return getEnvironment_context();
@@ -62152,7 +62152,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -62775,7 +62775,7 @@ public class ThriftHiveMetastore {
         return getPart_name();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       }
       throw new IllegalStateException();
@@ -63390,7 +63390,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -64057,7 +64057,7 @@ public class ThriftHiveMetastore {
         return getPart_name();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       case ENVIRONMENT_CONTEXT:
         return getEnvironment_context();
@@ -64737,7 +64737,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -73306,7 +73306,7 @@ public class ThriftHiveMetastore {
         return getTbl_name();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -74601,7 +74601,7 @@ public class ThriftHiveMetastore {
         return getTbl_name();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       case USER_NAME:
         return getUser_name();
@@ -75943,7 +75943,7 @@ public class ThriftHiveMetastore {
         return getTbl_name();
 
       case MAX_PARTS:
-        return Integer.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -77133,7 +77133,7 @@ public class ThriftHiveMetastore {
         return getTbl_name();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -78276,7 +78276,7 @@ public class ThriftHiveMetastore {
         return getPart_vals();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -79724,7 +79724,7 @@ public class ThriftHiveMetastore {
         return getPart_vals();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       case USER_NAME:
         return getUser_name();
@@ -81219,7 +81219,7 @@ public class ThriftHiveMetastore {
         return getPart_vals();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -82540,7 +82540,7 @@ public class ThriftHiveMetastore {
         return getFilter();
 
       case MAX_PARTS:
-        return Short.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -83834,7 +83834,7 @@ public class ThriftHiveMetastore {
         return getFilter();
 
       case MAX_PARTS:
-        return Integer.valueOf(getMax_parts());
+        return getMax_parts();
 
       }
       throw new IllegalStateException();
@@ -91685,7 +91685,7 @@ public class ThriftHiveMetastore {
         return getPart_vals();
 
       case THROW_EXCEPTION:
-        return Boolean.valueOf(isThrow_exception());
+        return isThrow_exception();
 
       }
       throw new IllegalStateException();
@@ -92174,7 +92174,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -97887,7 +97887,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -101052,7 +101052,7 @@ public class ThriftHiveMetastore {
         return getIndex_name();
 
       case DELETE_DATA:
-        return Boolean.valueOf(isDeleteData());
+        return isDeleteData();
 
       }
       throw new IllegalStateException();
@@ -101667,7 +101667,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -103386,7 +103386,7 @@ public class ThriftHiveMetastore {
         return getTbl_name();
 
       case MAX_INDEXES:
-        return Short.valueOf(getMax_indexes());
+        return getMax_indexes();
 
       }
       throw new IllegalStateException();
@@ -104576,7 +104576,7 @@ public class ThriftHiveMetastore {
         return getTbl_name();
 
       case MAX_INDEXES:
-        return Short.valueOf(getMax_indexes());
+        return getMax_indexes();
 
       }
       throw new IllegalStateException();
@@ -106098,7 +106098,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -107243,7 +107243,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -114012,7 +114012,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -115464,7 +115464,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -116812,7 +116812,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -123558,7 +123558,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -124380,7 +124380,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -125818,7 +125818,7 @@ public class ThriftHiveMetastore {
         return getGrantorType();
 
       case GRANT_OPTION:
-        return Boolean.valueOf(isGrant_option());
+        return isGrant_option();
 
       }
       throw new IllegalStateException();
@@ -126503,7 +126503,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -127545,7 +127545,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -134050,7 +134050,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -134877,7 +134877,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Boolean.valueOf(isSuccess());
+        return isSuccess();
 
       case O1:
         return getO1();
@@ -138481,7 +138481,7 @@ public class ThriftHiveMetastore {
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case SUCCESS:
-        return Long.valueOf(getSuccess());
+        return getSuccess();
 
       case O1:
         return getO1();

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
index a877338..1ddb02e 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class TxnAbortedException extends TException implements org.apache.thrift.TBase<TxnAbortedException, TxnAbortedException._Fields>, java.io.Serializable, Cloneable, Comparable<TxnAbortedException> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnAbortedException");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
index 8b255b9..6eb5c35 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TxnInfo> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnInfo");
 
@@ -42,6 +42,9 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
   private static final org.apache.thrift.protocol.TField STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("state", org.apache.thrift.protocol.TType.I32, (short)2);
   private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)3);
   private static final org.apache.thrift.protocol.TField HOSTNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("hostname", org.apache.thrift.protocol.TType.STRING, (short)4);
+  private static final org.apache.thrift.protocol.TField AGENT_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("agentInfo", org.apache.thrift.protocol.TType.STRING, (short)5);
+  private static final org.apache.thrift.protocol.TField HEARTBEAT_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("heartbeatCount", org.apache.thrift.protocol.TType.I32, (short)6);
+  private static final org.apache.thrift.protocol.TField META_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("metaInfo", org.apache.thrift.protocol.TType.STRING, (short)7);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -53,6 +56,9 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
   private TxnState state; // required
   private String user; // required
   private String hostname; // required
+  private String agentInfo; // optional
+  private int heartbeatCount; // optional
+  private String metaInfo; // 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 {
@@ -63,7 +69,10 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
      */
     STATE((short)2, "state"),
     USER((short)3, "user"),
-    HOSTNAME((short)4, "hostname");
+    HOSTNAME((short)4, "hostname"),
+    AGENT_INFO((short)5, "agentInfo"),
+    HEARTBEAT_COUNT((short)6, "heartbeatCount"),
+    META_INFO((short)7, "metaInfo");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -86,6 +95,12 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
           return USER;
         case 4: // HOSTNAME
           return HOSTNAME;
+        case 5: // AGENT_INFO
+          return AGENT_INFO;
+        case 6: // HEARTBEAT_COUNT
+          return HEARTBEAT_COUNT;
+        case 7: // META_INFO
+          return META_INFO;
         default:
           return null;
       }
@@ -127,7 +142,9 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
 
   // isset id assignments
   private static final int __ID_ISSET_ID = 0;
+  private static final int __HEARTBEATCOUNT_ISSET_ID = 1;
   private byte __isset_bitfield = 0;
+  private static final _Fields optionals[] = {_Fields.AGENT_INFO,_Fields.HEARTBEAT_COUNT,_Fields.META_INFO};
   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);
@@ -139,11 +156,21 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
     tmpMap.put(_Fields.HOSTNAME, new org.apache.thrift.meta_data.FieldMetaData("hostname", org.apache.thrift.TFieldRequirementType.REQUIRED, 
         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    tmpMap.put(_Fields.AGENT_INFO, new org.apache.thrift.meta_data.FieldMetaData("agentInfo", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    tmpMap.put(_Fields.HEARTBEAT_COUNT, new org.apache.thrift.meta_data.FieldMetaData("heartbeatCount", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+    tmpMap.put(_Fields.META_INFO, new org.apache.thrift.meta_data.FieldMetaData("metaInfo", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TxnInfo.class, metaDataMap);
   }
 
   public TxnInfo() {
+    this.agentInfo = "Unknown";
+
+    this.heartbeatCount = 0;
+
   }
 
   public TxnInfo(
@@ -175,6 +202,13 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
     if (other.isSetHostname()) {
       this.hostname = other.hostname;
     }
+    if (other.isSetAgentInfo()) {
+      this.agentInfo = other.agentInfo;
+    }
+    this.heartbeatCount = other.heartbeatCount;
+    if (other.isSetMetaInfo()) {
+      this.metaInfo = other.metaInfo;
+    }
   }
 
   public TxnInfo deepCopy() {
@@ -188,6 +222,11 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
     this.state = null;
     this.user = null;
     this.hostname = null;
+    this.agentInfo = "Unknown";
+
+    this.heartbeatCount = 0;
+
+    this.metaInfo = null;
   }
 
   public long getId() {
@@ -289,6 +328,74 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
     }
   }
 
+  public String getAgentInfo() {
+    return this.agentInfo;
+  }
+
+  public void setAgentInfo(String agentInfo) {
+    this.agentInfo = agentInfo;
+  }
+
+  public void unsetAgentInfo() {
+    this.agentInfo = null;
+  }
+
+  /** Returns true if field agentInfo is set (has been assigned a value) and false otherwise */
+  public boolean isSetAgentInfo() {
+    return this.agentInfo != null;
+  }
+
+  public void setAgentInfoIsSet(boolean value) {
+    if (!value) {
+      this.agentInfo = null;
+    }
+  }
+
+  public int getHeartbeatCount() {
+    return this.heartbeatCount;
+  }
+
+  public void setHeartbeatCount(int heartbeatCount) {
+    this.heartbeatCount = heartbeatCount;
+    setHeartbeatCountIsSet(true);
+  }
+
+  public void unsetHeartbeatCount() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __HEARTBEATCOUNT_ISSET_ID);
+  }
+
+  /** Returns true if field heartbeatCount is set (has been assigned a value) and false otherwise */
+  public boolean isSetHeartbeatCount() {
+    return EncodingUtils.testBit(__isset_bitfield, __HEARTBEATCOUNT_ISSET_ID);
+  }
+
+  public void setHeartbeatCountIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __HEARTBEATCOUNT_ISSET_ID, value);
+  }
+
+  public String getMetaInfo() {
+    return this.metaInfo;
+  }
+
+  public void setMetaInfo(String metaInfo) {
+    this.metaInfo = metaInfo;
+  }
+
+  public void unsetMetaInfo() {
+    this.metaInfo = null;
+  }
+
+  /** Returns true if field metaInfo is set (has been assigned a value) and false otherwise */
+  public boolean isSetMetaInfo() {
+    return this.metaInfo != null;
+  }
+
+  public void setMetaInfoIsSet(boolean value) {
+    if (!value) {
+      this.metaInfo = null;
+    }
+  }
+
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case ID:
@@ -323,13 +430,37 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
       }
       break;
 
+    case AGENT_INFO:
+      if (value == null) {
+        unsetAgentInfo();
+      } else {
+        setAgentInfo((String)value);
+      }
+      break;
+
+    case HEARTBEAT_COUNT:
+      if (value == null) {
+        unsetHeartbeatCount();
+      } else {
+        setHeartbeatCount((Integer)value);
+      }
+      break;
+
+    case META_INFO:
+      if (value == null) {
+        unsetMetaInfo();
+      } else {
+        setMetaInfo((String)value);
+      }
+      break;
+
     }
   }
 
   public Object getFieldValue(_Fields field) {
     switch (field) {
     case ID:
-      return Long.valueOf(getId());
+      return getId();
 
     case STATE:
       return getState();
@@ -340,6 +471,15 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
     case HOSTNAME:
       return getHostname();
 
+    case AGENT_INFO:
+      return getAgentInfo();
+
+    case HEARTBEAT_COUNT:
+      return getHeartbeatCount();
+
+    case META_INFO:
+      return getMetaInfo();
+
     }
     throw new IllegalStateException();
   }
@@ -359,6 +499,12 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
       return isSetUser();
     case HOSTNAME:
       return isSetHostname();
+    case AGENT_INFO:
+      return isSetAgentInfo();
+    case HEARTBEAT_COUNT:
+      return isSetHeartbeatCount();
+    case META_INFO:
+      return isSetMetaInfo();
     }
     throw new IllegalStateException();
   }
@@ -412,6 +558,33 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
         return false;
     }
 
+    boolean this_present_agentInfo = true && this.isSetAgentInfo();
+    boolean that_present_agentInfo = true && that.isSetAgentInfo();
+    if (this_present_agentInfo || that_present_agentInfo) {
+      if (!(this_present_agentInfo && that_present_agentInfo))
+        return false;
+      if (!this.agentInfo.equals(that.agentInfo))
+        return false;
+    }
+
+    boolean this_present_heartbeatCount = true && this.isSetHeartbeatCount();
+    boolean that_present_heartbeatCount = true && that.isSetHeartbeatCount();
+    if (this_present_heartbeatCount || that_present_heartbeatCount) {
+      if (!(this_present_heartbeatCount && that_present_heartbeatCount))
+        return false;
+      if (this.heartbeatCount != that.heartbeatCount)
+        return false;
+    }
+
+    boolean this_present_metaInfo = true && this.isSetMetaInfo();
+    boolean that_present_metaInfo = true && that.isSetMetaInfo();
+    if (this_present_metaInfo || that_present_metaInfo) {
+      if (!(this_present_metaInfo && that_present_metaInfo))
+        return false;
+      if (!this.metaInfo.equals(that.metaInfo))
+        return false;
+    }
+
     return true;
   }
 
@@ -439,6 +612,21 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
     if (present_hostname)
       list.add(hostname);
 
+    boolean present_agentInfo = true && (isSetAgentInfo());
+    list.add(present_agentInfo);
+    if (present_agentInfo)
+      list.add(agentInfo);
+
+    boolean present_heartbeatCount = true && (isSetHeartbeatCount());
+    list.add(present_heartbeatCount);
+    if (present_heartbeatCount)
+      list.add(heartbeatCount);
+
+    boolean present_metaInfo = true && (isSetMetaInfo());
+    list.add(present_metaInfo);
+    if (present_metaInfo)
+      list.add(metaInfo);
+
     return list.hashCode();
   }
 
@@ -490,6 +678,36 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
         return lastComparison;
       }
     }
+    lastComparison = Boolean.valueOf(isSetAgentInfo()).compareTo(other.isSetAgentInfo());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetAgentInfo()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.agentInfo, other.agentInfo);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetHeartbeatCount()).compareTo(other.isSetHeartbeatCount());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetHeartbeatCount()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.heartbeatCount, other.heartbeatCount);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetMetaInfo()).compareTo(other.isSetMetaInfo());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetMetaInfo()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.metaInfo, other.metaInfo);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
     return 0;
   }
 
@@ -537,6 +755,32 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
       sb.append(this.hostname);
     }
     first = false;
+    if (isSetAgentInfo()) {
+      if (!first) sb.append(", ");
+      sb.append("agentInfo:");
+      if (this.agentInfo == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.agentInfo);
+      }
+      first = false;
+    }
+    if (isSetHeartbeatCount()) {
+      if (!first) sb.append(", ");
+      sb.append("heartbeatCount:");
+      sb.append(this.heartbeatCount);
+      first = false;
+    }
+    if (isSetMetaInfo()) {
+      if (!first) sb.append(", ");
+      sb.append("metaInfo:");
+      if (this.metaInfo == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.metaInfo);
+      }
+      first = false;
+    }
     sb.append(")");
     return sb.toString();
   }
@@ -630,6 +874,30 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
+          case 5: // AGENT_INFO
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+              struct.agentInfo = iprot.readString();
+              struct.setAgentInfoIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 6: // HEARTBEAT_COUNT
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.heartbeatCount = iprot.readI32();
+              struct.setHeartbeatCountIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 7: // META_INFO
+            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+              struct.metaInfo = iprot.readString();
+              struct.setMetaInfoIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
           default:
             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -661,6 +929,25 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
         oprot.writeString(struct.hostname);
         oprot.writeFieldEnd();
       }
+      if (struct.agentInfo != null) {
+        if (struct.isSetAgentInfo()) {
+          oprot.writeFieldBegin(AGENT_INFO_FIELD_DESC);
+          oprot.writeString(struct.agentInfo);
+          oprot.writeFieldEnd();
+        }
+      }
+      if (struct.isSetHeartbeatCount()) {
+        oprot.writeFieldBegin(HEARTBEAT_COUNT_FIELD_DESC);
+        oprot.writeI32(struct.heartbeatCount);
+        oprot.writeFieldEnd();
+      }
+      if (struct.metaInfo != null) {
+        if (struct.isSetMetaInfo()) {
+          oprot.writeFieldBegin(META_INFO_FIELD_DESC);
+          oprot.writeString(struct.metaInfo);
+          oprot.writeFieldEnd();
+        }
+      }
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -682,6 +969,26 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
       oprot.writeI32(struct.state.getValue());
       oprot.writeString(struct.user);
       oprot.writeString(struct.hostname);
+      BitSet optionals = new BitSet();
+      if (struct.isSetAgentInfo()) {
+        optionals.set(0);
+      }
+      if (struct.isSetHeartbeatCount()) {
+        optionals.set(1);
+      }
+      if (struct.isSetMetaInfo()) {
+        optionals.set(2);
+      }
+      oprot.writeBitSet(optionals, 3);
+      if (struct.isSetAgentInfo()) {
+        oprot.writeString(struct.agentInfo);
+      }
+      if (struct.isSetHeartbeatCount()) {
+        oprot.writeI32(struct.heartbeatCount);
+      }
+      if (struct.isSetMetaInfo()) {
+        oprot.writeString(struct.metaInfo);
+      }
     }
 
     @Override
@@ -695,6 +1002,19 @@ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields
       struct.setUserIsSet(true);
       struct.hostname = iprot.readString();
       struct.setHostnameIsSet(true);
+      BitSet incoming = iprot.readBitSet(3);
+      if (incoming.get(0)) {
+        struct.agentInfo = iprot.readString();
+        struct.setAgentInfoIsSet(true);
+      }
+      if (incoming.get(1)) {
+        struct.heartbeatCount = iprot.readI32();
+        struct.setHeartbeatCountIsSet(true);
+      }
+      if (incoming.get(2)) {
+        struct.metaInfo = iprot.readString();
+        struct.setMetaInfoIsSet(true);
+      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
index 05af505..23392e9 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class TxnOpenException extends TException implements org.apache.thrift.TBase<TxnOpenException, TxnOpenException._Fields>, java.io.Serializable, Cloneable, Comparable<TxnOpenException> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnOpenException");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnState.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnState.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnState.java
index 69d6239..de59755 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnState.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnState.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
index 61e7ceb..b71685b 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class Type implements org.apache.thrift.TBase<Type, Type._Fields>, java.io.Serializable, Cloneable, Comparable<Type> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Type");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
index e05e79d..c3b15fb 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class UnknownDBException extends TException implements org.apache.thrift.TBase<UnknownDBException, UnknownDBException._Fields>, java.io.Serializable, Cloneable, Comparable<UnknownDBException> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnknownDBException");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
index c626bf6..e78f765 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class UnknownPartitionException extends TException implements org.apache.thrift.TBase<UnknownPartitionException, UnknownPartitionException._Fields>, java.io.Serializable, Cloneable, Comparable<UnknownPartitionException> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnknownPartitionException");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
index 2856121..a3c4760 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class UnknownTableException extends TException implements org.apache.thrift.TBase<UnknownTableException, UnknownTableException._Fields>, java.io.Serializable, Cloneable, Comparable<UnknownTableException> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnknownTableException");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
index cf248e0..59d5ff4 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class UnlockRequest implements org.apache.thrift.TBase<UnlockRequest, UnlockRequest._Fields>, java.io.Serializable, Cloneable, Comparable<UnlockRequest> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnlockRequest");
 
@@ -185,7 +185,7 @@ public class UnlockRequest implements org.apache.thrift.TBase<UnlockRequest, Unl
   public Object getFieldValue(_Fields field) {
     switch (field) {
     case LOCKID:
-      return Long.valueOf(getLockid());
+      return getLockid();
 
     }
     throw new IllegalStateException();

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
index cc8d5f5..51d25da 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-14")
 public class Version implements org.apache.thrift.TBase<Version, Version._Fields>, java.io.Serializable, Cloneable, Comparable<Version> {
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Version");
 

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/hive_metastoreConstants.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/hive_metastoreConstants.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/hive_metastoreConstants.java
index b6e0a29..5a666f2 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/hive_metastoreConstants.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/hive_metastoreConstants.java
@@ -1,5 +1,5 @@
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php b/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
index a2e5b05..6154d8c 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
@@ -1,7 +1,7 @@
 <?php
 namespace metastore;
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-php/metastore/Types.php
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-php/metastore/Types.php b/metastore/src/gen/thrift/gen-php/metastore/Types.php
index 949a6e9..4fc2da6 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -2,7 +2,7 @@
 namespace metastore;
 
 /**
- * Autogenerated by Thrift Compiler (0.9.2)
+ * Autogenerated by Thrift Compiler (0.9.3)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  *  @generated
@@ -10078,6 +10078,18 @@ class TxnInfo {
    * @var string
    */
   public $hostname = null;
+  /**
+   * @var string
+   */
+  public $agentInfo = "Unknown";
+  /**
+   * @var int
+   */
+  public $heartbeatCount = 0;
+  /**
+   * @var string
+   */
+  public $metaInfo = null;
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -10098,6 +10110,18 @@ class TxnInfo {
           'var' => 'hostname',
           'type' => TType::STRING,
           ),
+        5 => array(
+          'var' => 'agentInfo',
+          'type' => TType::STRING,
+          ),
+        6 => array(
+          'var' => 'heartbeatCount',
+          'type' => TType::I32,
+          ),
+        7 => array(
+          'var' => 'metaInfo',
+          'type' => TType::STRING,
+          ),
         );
     }
     if (is_array($vals)) {
@@ -10113,6 +10137,15 @@ class TxnInfo {
       if (isset($vals['hostname'])) {
         $this->hostname = $vals['hostname'];
       }
+      if (isset($vals['agentInfo'])) {
+        $this->agentInfo = $vals['agentInfo'];
+      }
+      if (isset($vals['heartbeatCount'])) {
+        $this->heartbeatCount = $vals['heartbeatCount'];
+      }
+      if (isset($vals['metaInfo'])) {
+        $this->metaInfo = $vals['metaInfo'];
+      }
     }
   }
 
@@ -10163,6 +10196,27 @@ class TxnInfo {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 5:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->agentInfo);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 6:
+          if ($ftype == TType::I32) {
+            $xfer += $input->readI32($this->heartbeatCount);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 7:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->metaInfo);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -10196,6 +10250,21 @@ class TxnInfo {
       $xfer += $output->writeString($this->hostname);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->agentInfo !== null) {
+      $xfer += $output->writeFieldBegin('agentInfo', TType::STRING, 5);
+      $xfer += $output->writeString($this->agentInfo);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->heartbeatCount !== null) {
+      $xfer += $output->writeFieldBegin('heartbeatCount', TType::I32, 6);
+      $xfer += $output->writeI32($this->heartbeatCount);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->metaInfo !== null) {
+      $xfer += $output->writeFieldBegin('metaInfo', TType::STRING, 7);
+      $xfer += $output->writeString($this->metaInfo);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -10476,6 +10545,10 @@ class OpenTxnRequest {
    * @var string
    */
   public $hostname = null;
+  /**
+   * @var string
+   */
+  public $agentInfo = "Unknown";
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -10492,6 +10565,10 @@ class OpenTxnRequest {
           'var' => 'hostname',
           'type' => TType::STRING,
           ),
+        4 => array(
+          'var' => 'agentInfo',
+          'type' => TType::STRING,
+          ),
         );
     }
     if (is_array($vals)) {
@@ -10504,6 +10581,9 @@ class OpenTxnRequest {
       if (isset($vals['hostname'])) {
         $this->hostname = $vals['hostname'];
       }
+      if (isset($vals['agentInfo'])) {
+        $this->agentInfo = $vals['agentInfo'];
+      }
     }
   }
 
@@ -10547,6 +10627,13 @@ class OpenTxnRequest {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 4:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->agentInfo);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -10575,6 +10662,11 @@ class OpenTxnRequest {
       $xfer += $output->writeString($this->hostname);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->agentInfo !== null) {
+      $xfer += $output->writeFieldBegin('agentInfo', TType::STRING, 4);
+      $xfer += $output->writeString($this->agentInfo);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -11019,6 +11111,10 @@ class LockRequest {
    * @var string
    */
   public $hostname = null;
+  /**
+   * @var string
+   */
+  public $agentInfo = "Unknown";
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -11044,6 +11140,10 @@ class LockRequest {
           'var' => 'hostname',
           'type' => TType::STRING,
           ),
+        5 => array(
+          'var' => 'agentInfo',
+          'type' => TType::STRING,
+          ),
         );
     }
     if (is_array($vals)) {
@@ -11059,6 +11159,9 @@ class LockRequest {
       if (isset($vals['hostname'])) {
         $this->hostname = $vals['hostname'];
       }
+      if (isset($vals['agentInfo'])) {
+        $this->agentInfo = $vals['agentInfo'];
+      }
     }
   }
 
@@ -11120,6 +11223,13 @@ class LockRequest {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 5:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->agentInfo);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -11165,6 +11275,11 @@ class LockRequest {
       $xfer += $output->writeString($this->hostname);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->agentInfo !== null) {
+      $xfer += $output->writeFieldBegin('agentInfo', TType::STRING, 5);
+      $xfer += $output->writeString($this->agentInfo);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -11277,6 +11392,14 @@ class CheckLockRequest {
    * @var int
    */
   public $lockid = null;
+  /**
+   * @var int
+   */
+  public $txnid = null;
+  /**
+   * @var int
+   */
+  public $elapsed_ms = null;
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -11285,12 +11408,26 @@ class CheckLockRequest {
           'var' => 'lockid',
           'type' => TType::I64,
           ),
+        2 => array(
+          'var' => 'txnid',
+          'type' => TType::I64,
+          ),
+        3 => array(
+          'var' => 'elapsed_ms',
+          'type' => TType::I64,
+          ),
         );
     }
     if (is_array($vals)) {
       if (isset($vals['lockid'])) {
         $this->lockid = $vals['lockid'];
       }
+      if (isset($vals['txnid'])) {
+        $this->txnid = $vals['txnid'];
+      }
+      if (isset($vals['elapsed_ms'])) {
+        $this->elapsed_ms = $vals['elapsed_ms'];
+      }
     }
   }
 
@@ -11320,6 +11457,20 @@ class CheckLockRequest {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 2:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->txnid);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 3:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->elapsed_ms);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -11338,6 +11489,16 @@ class CheckLockRequest {
       $xfer += $output->writeI64($this->lockid);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->txnid !== null) {
+      $xfer += $output->writeFieldBegin('txnid', TType::I64, 2);
+      $xfer += $output->writeI64($this->txnid);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->elapsed_ms !== null) {
+      $xfer += $output->writeFieldBegin('elapsed_ms', TType::I64, 3);
+      $xfer += $output->writeI64($this->elapsed_ms);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -11423,12 +11584,58 @@ class UnlockRequest {
 class ShowLocksRequest {
   static $_TSPEC;
 
+  /**
+   * @var string
+   */
+  public $dbname = null;
+  /**
+   * @var string
+   */
+  public $tablename = null;
+  /**
+   * @var string
+   */
+  public $partname = null;
+  /**
+   * @var bool
+   */
+  public $isExtended = false;
 
-  public function __construct() {
+  public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
       self::$_TSPEC = array(
+        1 => array(
+          'var' => 'dbname',
+          'type' => TType::STRING,
+          ),
+        2 => array(
+          'var' => 'tablename',
+          'type' => TType::STRING,
+          ),
+        3 => array(
+          'var' => 'partname',
+          'type' => TType::STRING,
+          ),
+        4 => array(
+          'var' => 'isExtended',
+          'type' => TType::BOOL,
+          ),
         );
     }
+    if (is_array($vals)) {
+      if (isset($vals['dbname'])) {
+        $this->dbname = $vals['dbname'];
+      }
+      if (isset($vals['tablename'])) {
+        $this->tablename = $vals['tablename'];
+      }
+      if (isset($vals['partname'])) {
+        $this->partname = $vals['partname'];
+      }
+      if (isset($vals['isExtended'])) {
+        $this->isExtended = $vals['isExtended'];
+      }
+    }
   }
 
   public function getName() {
@@ -11450,6 +11657,34 @@ class ShowLocksRequest {
       }
       switch ($fid)
       {
+        case 1:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->dbname);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 2:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->tablename);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 3:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->partname);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 4:
+          if ($ftype == TType::BOOL) {
+            $xfer += $input->readBool($this->isExtended);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -11463,6 +11698,26 @@ class ShowLocksRequest {
   public function write($output) {
     $xfer = 0;
     $xfer += $output->writeStructBegin('ShowLocksRequest');
+    if ($this->dbname !== null) {
+      $xfer += $output->writeFieldBegin('dbname', TType::STRING, 1);
+      $xfer += $output->writeString($this->dbname);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->tablename !== null) {
+      $xfer += $output->writeFieldBegin('tablename', TType::STRING, 2);
+      $xfer += $output->writeString($this->tablename);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->partname !== null) {
+      $xfer += $output->writeFieldBegin('partname', TType::STRING, 3);
+      $xfer += $output->writeString($this->partname);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->isExtended !== null) {
+      $xfer += $output->writeFieldBegin('isExtended', TType::BOOL, 4);
+      $xfer += $output->writeBool($this->isExtended);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -11517,6 +11772,26 @@ class ShowLocksResponseElement {
    * @var string
    */
   public $hostname = null;
+  /**
+   * @var int
+   */
+  public $heartbeatCount = 0;
+  /**
+   * @var string
+   */
+  public $agentInfo = null;
+  /**
+   * @var int
+   */
+  public $blockedByExtId = null;
+  /**
+   * @var int
+   */
+  public $blockedByIntId = null;
+  /**
+   * @var int
+   */
+  public $lockIdInternal = null;
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -11565,6 +11840,26 @@ class ShowLocksResponseElement {
           'var' => 'hostname',
           'type' => TType::STRING,
           ),
+        12 => array(
+          'var' => 'heartbeatCount',
+          'type' => TType::I32,
+          ),
+        13 => array(
+          'var' => 'agentInfo',
+          'type' => TType::STRING,
+          ),
+        14 => array(
+          'var' => 'blockedByExtId',
+          'type' => TType::I64,
+          ),
+        15 => array(
+          'var' => 'blockedByIntId',
+          'type' => TType::I64,
+          ),
+        16 => array(
+          'var' => 'lockIdInternal',
+          'type' => TType::I64,
+          ),
         );
     }
     if (is_array($vals)) {
@@ -11601,6 +11896,21 @@ class ShowLocksResponseElement {
       if (isset($vals['hostname'])) {
         $this->hostname = $vals['hostname'];
       }
+      if (isset($vals['heartbeatCount'])) {
+        $this->heartbeatCount = $vals['heartbeatCount'];
+      }
+      if (isset($vals['agentInfo'])) {
+        $this->agentInfo = $vals['agentInfo'];
+      }
+      if (isset($vals['blockedByExtId'])) {
+        $this->blockedByExtId = $vals['blockedByExtId'];
+      }
+      if (isset($vals['blockedByIntId'])) {
+        $this->blockedByIntId = $vals['blockedByIntId'];
+      }
+      if (isset($vals['lockIdInternal'])) {
+        $this->lockIdInternal = $vals['lockIdInternal'];
+      }
     }
   }
 
@@ -11700,6 +12010,41 @@ class ShowLocksResponseElement {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 12:
+          if ($ftype == TType::I32) {
+            $xfer += $input->readI32($this->heartbeatCount);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 13:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->agentInfo);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 14:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->blockedByExtId);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 15:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->blockedByIntId);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 16:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->lockIdInternal);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -11768,6 +12113,31 @@ class ShowLocksResponseElement {
       $xfer += $output->writeString($this->hostname);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->heartbeatCount !== null) {
+      $xfer += $output->writeFieldBegin('heartbeatCount', TType::I32, 12);
+      $xfer += $output->writeI32($this->heartbeatCount);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->agentInfo !== null) {
+      $xfer += $output->writeFieldBegin('agentInfo', TType::STRING, 13);
+      $xfer += $output->writeString($this->agentInfo);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->blockedByExtId !== null) {
+      $xfer += $output->writeFieldBegin('blockedByExtId', TType::I64, 14);
+      $xfer += $output->writeI64($this->blockedByExtId);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->blockedByIntId !== null) {
+      $xfer += $output->writeFieldBegin('blockedByIntId', TType::I64, 15);
+      $xfer += $output->writeI64($this->blockedByIntId);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->lockIdInternal !== null) {
+      $xfer += $output->writeFieldBegin('lockIdInternal', TType::I64, 16);
+      $xfer += $output->writeI64($this->lockIdInternal);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -12492,6 +12862,22 @@ class ShowCompactResponseElement {
    * @var string
    */
   public $runAs = null;
+  /**
+   * @var int
+   */
+  public $hightestTxnId = null;
+  /**
+   * @var string
+   */
+  public $metaInfo = null;
+  /**
+   * @var int
+   */
+  public $endTime = null;
+  /**
+   * @var string
+   */
+  public $hadoopJobId = "None";
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -12528,6 +12914,22 @@ class ShowCompactResponseElement {
           'var' => 'runAs',
           'type' => TType::STRING,
           ),
+        9 => array(
+          'var' => 'hightestTxnId',
+          'type' => TType::I64,
+          ),
+        10 => array(
+          'var' => 'metaInfo',
+          'type' => TType::STRING,
+          ),
+        11 => array(
+          'var' => 'endTime',
+          'type' => TType::I64,
+          ),
+        12 => array(
+          'var' => 'hadoopJobId',
+          'type' => TType::STRING,
+          ),
         );
     }
     if (is_array($vals)) {
@@ -12555,6 +12957,18 @@ class ShowCompactResponseElement {
       if (isset($vals['runAs'])) {
         $this->runAs = $vals['runAs'];
       }
+      if (isset($vals['hightestTxnId'])) {
+        $this->hightestTxnId = $vals['hightestTxnId'];
+      }
+      if (isset($vals['metaInfo'])) {
+        $this->metaInfo = $vals['metaInfo'];
+      }
+      if (isset($vals['endTime'])) {
+        $this->endTime = $vals['endTime'];
+      }
+      if (isset($vals['hadoopJobId'])) {
+        $this->hadoopJobId = $vals['hadoopJobId'];
+      }
     }
   }
 
@@ -12633,6 +13047,34 @@ class ShowCompactResponseElement {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 9:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->hightestTxnId);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 10:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->metaInfo);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 11:
+          if ($ftype == TType::I64) {
+            $xfer += $input->readI64($this->endTime);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 12:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->hadoopJobId);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -12686,6 +13128,26 @@ class ShowCompactResponseElement {
       $xfer += $output->writeString($this->runAs);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->hightestTxnId !== null) {
+      $xfer += $output->writeFieldBegin('hightestTxnId', TType::I64, 9);
+      $xfer += $output->writeI64($this->hightestTxnId);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->metaInfo !== null) {
+      $xfer += $output->writeFieldBegin('metaInfo', TType::STRING, 10);
+      $xfer += $output->writeString($this->metaInfo);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->endTime !== null) {
+      $xfer += $output->writeFieldBegin('endTime', TType::I64, 11);
+      $xfer += $output->writeI64($this->endTime);
+      $xfer += $output->writeFieldEnd();
+    }
+    if ($this->hadoopJobId !== null) {
+      $xfer += $output->writeFieldBegin('hadoopJobId', TType::STRING, 12);
+      $xfer += $output->writeString($this->hadoopJobId);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;

http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index e6d3755..b3182a8 100755
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -1,6 +1,6 @@
 #!/usr/bin/env python
 #
-# Autogenerated by Thrift Compiler (0.9.2)
+# Autogenerated by Thrift Compiler (0.9.3)
 #
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
 #
@@ -158,8 +158,8 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('  void setOption(string key, string value)')
   print('  string getOption(string key)')
   print('   getOptions()')
+  print('  string getCpuProfile(i32 profileDurationInSec)')
   print('  i64 aliveSince()')
-  print('  reflection_limited.Service getLimitedReflection()')
   print('  void reinitialize()')
   print('  void shutdown()')
   print('')
@@ -1022,18 +1022,18 @@ elif cmd == 'getOptions':
     sys.exit(1)
   pp.pprint(client.getOptions())
 
+elif cmd == 'getCpuProfile':
+  if len(args) != 1:
+    print('getCpuProfile requires 1 args')
+    sys.exit(1)
+  pp.pprint(client.getCpuProfile(eval(args[0]),))
+
 elif cmd == 'aliveSince':
   if len(args) != 0:
     print('aliveSince requires 0 args')
     sys.exit(1)
   pp.pprint(client.aliveSince())
 
-elif cmd == 'getLimitedReflection':
-  if len(args) != 0:
-    print('getLimitedReflection requires 0 args')
-    sys.exit(1)
-  pp.pprint(client.getLimitedReflection())
-
 elif cmd == 'reinitialize':
   if len(args) != 0:
     print('reinitialize requires 0 args')


Mime
View raw message