You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2016/01/15 02:18:02 UTC
[13/22] hive git commit: HIVE-12832 Thrift and RDBMS schema changes
for ACID fixes, branch-1 version.
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')