You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by xu...@apache.org on 2015/10/28 13:10:55 UTC
[02/55] [abbrv] hive git commit: HIVE-11591 : upgrade thrift to 0.9.3
and change generation to use undated annotations (Sergey Shelukhin,
reviewed by Alan Gates)
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationHandle.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationHandle.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationHandle.java
index 75a3c89..d1d86fe 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationHandle.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationHandle.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TOperationHandle implements org.apache.thrift.TBase<TOperationHandle, TOperationHandle._Fields>, java.io.Serializable, Cloneable, Comparable<TOperationHandle> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TOperationHandle");
@@ -333,10 +333,10 @@ public class TOperationHandle implements org.apache.thrift.TBase<TOperationHandl
return getOperationType();
case HAS_RESULT_SET:
- return Boolean.valueOf(isHasResultSet());
+ return isHasResultSet();
case MODIFIED_ROW_COUNT:
- return Double.valueOf(getModifiedRowCount());
+ return getModifiedRowCount();
}
throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationState.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationState.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationState.java
index 2dfde1c..fe029ef 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationState.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationState.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationType.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationType.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationType.java
index 6927740..f105259 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationType.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOperationType.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TPrimitiveTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TPrimitiveTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TPrimitiveTypeEntry.java
index 706c6ba..38a5be3 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TPrimitiveTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TPrimitiveTypeEntry.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TPrimitiveTypeEntry implements org.apache.thrift.TBase<TPrimitiveTypeEntry, TPrimitiveTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TPrimitiveTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPrimitiveTypeEntry");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TProtocolVersion.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TProtocolVersion.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TProtocolVersion.java
index 6e714c6..c936ada 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TProtocolVersion.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TProtocolVersion.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenReq.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenReq.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenReq.java
index 9452fd8..e74bb29 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenReq.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenReq.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TRenewDelegationTokenReq implements org.apache.thrift.TBase<TRenewDelegationTokenReq, TRenewDelegationTokenReq._Fields>, java.io.Serializable, Cloneable, Comparable<TRenewDelegationTokenReq> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRenewDelegationTokenReq");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenResp.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenResp.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenResp.java
index 8a0e78a..63633e3 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenResp.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRenewDelegationTokenResp.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TRenewDelegationTokenResp implements org.apache.thrift.TBase<TRenewDelegationTokenResp, TRenewDelegationTokenResp._Fields>, java.io.Serializable, Cloneable, Comparable<TRenewDelegationTokenResp> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRenewDelegationTokenResp");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java
index 96322db..28c34cd 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TRow implements org.apache.thrift.TBase<TRow, TRow._Fields>, java.io.Serializable, Cloneable, Comparable<TRow> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRow");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java
index 05e0b89..9b9b2ac 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TRowSet implements org.apache.thrift.TBase<TRowSet, TRowSet._Fields>, java.io.Serializable, Cloneable, Comparable<TRowSet> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRowSet");
@@ -312,7 +312,7 @@ public class TRowSet implements org.apache.thrift.TBase<TRowSet, TRowSet._Fields
public Object getFieldValue(_Fields field) {
switch (field) {
case START_ROW_OFFSET:
- return Long.valueOf(getStartRowOffset());
+ return getStartRowOffset();
case ROWS:
return getRows();
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TSessionHandle.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TSessionHandle.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TSessionHandle.java
index ff1e723..aeff2b6 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TSessionHandle.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TSessionHandle.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TSessionHandle implements org.apache.thrift.TBase<TSessionHandle, TSessionHandle._Fields>, java.io.Serializable, Cloneable, Comparable<TSessionHandle> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TSessionHandle");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java
index 5309d49..ccf281a 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TStatus implements org.apache.thrift.TBase<TStatus, TStatus._Fields>, java.io.Serializable, Cloneable, Comparable<TStatus> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStatus");
@@ -391,7 +391,7 @@ public class TStatus implements org.apache.thrift.TBase<TStatus, TStatus._Fields
return getSqlState();
case ERROR_CODE:
- return Integer.valueOf(getErrorCode());
+ return getErrorCode();
case ERROR_MESSAGE:
return getErrorMessage();
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatusCode.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatusCode.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatusCode.java
index 91d1a97..8900d4c 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatusCode.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatusCode.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
index a987733..7c15ec1 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TStringColumn._Fields>, java.io.Serializable, Cloneable, Comparable<TStringColumn> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStringColumn");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
index c902e0b..96e9be0 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TStringValue implements org.apache.thrift.TBase<TStringValue, TStringValue._Fields>, java.io.Serializable, Cloneable, Comparable<TStringValue> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStringValue");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
index f477764..c90926a 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntry, TStructTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TStructTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStructTypeEntry");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
index d97f593..7a38e15 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTableSchema._Fields>, java.io.Serializable, Cloneable, Comparable<TTableSchema> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableSchema");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
index c4fdd74..e187da2 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._Fields>, java.io.Serializable, Cloneable, Comparable<TTypeDesc> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTypeDesc");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
index 203d3b9..a53eaa2 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
index e6f2336..379bc92 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
index 54df6dc..cc786b2 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.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/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
index 9312d92..ac97b7f 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers, TTypeQualifiers._Fields>, java.io.Serializable, Cloneable, Comparable<TTypeQualifiers> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTypeQualifiers");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
index 5302024..0c7120d 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry, TUnionTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TUnionTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TUnionTypeEntry");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
index 5b60476..4ae9505 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.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-10-21")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
public class TUserDefinedTypeEntry implements org.apache.thrift.TBase<TUserDefinedTypeEntry, TUserDefinedTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TUserDefinedTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TUserDefinedTypeEntry");
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-php/TCLIService.php
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-php/TCLIService.php b/service/src/gen/thrift/gen-php/TCLIService.php
index f5dd904..eba62f1 100644
--- a/service/src/gen/thrift/gen-php/TCLIService.php
+++ b/service/src/gen/thrift/gen-php/TCLIService.php
@@ -1,7 +1,6 @@
<?php
-namespace ;
/**
- * 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/26535378/service/src/gen/thrift/gen-php/ThriftHive.php
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-php/ThriftHive.php b/service/src/gen/thrift/gen-php/ThriftHive.php
index 2c783b6..23dc8fd 100644
--- a/service/src/gen/thrift/gen-php/ThriftHive.php
+++ b/service/src/gen/thrift/gen-php/ThriftHive.php
@@ -1,7 +1,6 @@
<?php
-namespace ;
/**
- * 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/26535378/service/src/gen/thrift/gen-php/Types.php
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-php/Types.php b/service/src/gen/thrift/gen-php/Types.php
index d8f3c5b..cbf4c29 100644
--- a/service/src/gen/thrift/gen-php/Types.php
+++ b/service/src/gen/thrift/gen-php/Types.php
@@ -1,8 +1,6 @@
<?php
-namespace ;
-
/**
- * 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/26535378/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote b/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote
index 2bfca56..56f5c5d 100755
--- a/service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote
+++ b/service/src/gen/thrift/gen-py/TCLIService/TCLIService-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
#
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py b/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py
index 0067195..ad2d71d 100644
--- a/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py
+++ b/service/src/gen/thrift/gen-py/TCLIService/TCLIService.py
@@ -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
#
@@ -7,6 +7,7 @@
#
from thrift.Thrift import TType, TMessageType, TException, TApplicationException
+import logging
from ttypes import *
from thrift.Thrift import TProcessor
from thrift.transport import TTransport
@@ -188,7 +189,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "OpenSession failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "OpenSession failed: unknown result")
def CloseSession(self, req):
"""
@@ -219,7 +220,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseSession failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseSession failed: unknown result")
def GetInfo(self, req):
"""
@@ -250,7 +251,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetInfo failed: unknown result")
def ExecuteStatement(self, req):
"""
@@ -281,7 +282,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "ExecuteStatement failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "ExecuteStatement failed: unknown result")
def GetTypeInfo(self, req):
"""
@@ -312,7 +313,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTypeInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTypeInfo failed: unknown result")
def GetCatalogs(self, req):
"""
@@ -343,7 +344,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCatalogs failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetCatalogs failed: unknown result")
def GetSchemas(self, req):
"""
@@ -374,7 +375,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetSchemas failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetSchemas failed: unknown result")
def GetTables(self, req):
"""
@@ -405,7 +406,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTables failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTables failed: unknown result")
def GetTableTypes(self, req):
"""
@@ -436,7 +437,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTableTypes failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetTableTypes failed: unknown result")
def GetColumns(self, req):
"""
@@ -467,7 +468,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetColumns failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetColumns failed: unknown result")
def GetFunctions(self, req):
"""
@@ -498,7 +499,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetFunctions failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetFunctions failed: unknown result")
def GetOperationStatus(self, req):
"""
@@ -529,7 +530,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetOperationStatus failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetOperationStatus failed: unknown result")
def CancelOperation(self, req):
"""
@@ -560,7 +561,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelOperation failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelOperation failed: unknown result")
def CloseOperation(self, req):
"""
@@ -591,7 +592,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseOperation failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "CloseOperation failed: unknown result")
def GetResultSetMetadata(self, req):
"""
@@ -622,7 +623,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetResultSetMetadata failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetResultSetMetadata failed: unknown result")
def FetchResults(self, req):
"""
@@ -653,7 +654,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "FetchResults failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "FetchResults failed: unknown result")
def GetDelegationToken(self, req):
"""
@@ -684,7 +685,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "GetDelegationToken failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "GetDelegationToken failed: unknown result")
def CancelDelegationToken(self, req):
"""
@@ -715,7 +716,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelDelegationToken failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "CancelDelegationToken failed: unknown result")
def RenewDelegationToken(self, req):
"""
@@ -746,7 +747,7 @@ class Client(Iface):
iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "RenewDelegationToken failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "RenewDelegationToken failed: unknown result")
class Processor(Iface, TProcessor):
@@ -793,8 +794,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = OpenSession_result()
- result.success = self._handler.OpenSession(args.req)
- oprot.writeMessageBegin("OpenSession", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.OpenSession(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("OpenSession", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -804,8 +813,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = CloseSession_result()
- result.success = self._handler.CloseSession(args.req)
- oprot.writeMessageBegin("CloseSession", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.CloseSession(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("CloseSession", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -815,8 +832,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetInfo_result()
- result.success = self._handler.GetInfo(args.req)
- oprot.writeMessageBegin("GetInfo", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetInfo(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetInfo", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -826,8 +851,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = ExecuteStatement_result()
- result.success = self._handler.ExecuteStatement(args.req)
- oprot.writeMessageBegin("ExecuteStatement", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.ExecuteStatement(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("ExecuteStatement", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -837,8 +870,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetTypeInfo_result()
- result.success = self._handler.GetTypeInfo(args.req)
- oprot.writeMessageBegin("GetTypeInfo", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetTypeInfo(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetTypeInfo", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -848,8 +889,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetCatalogs_result()
- result.success = self._handler.GetCatalogs(args.req)
- oprot.writeMessageBegin("GetCatalogs", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetCatalogs(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetCatalogs", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -859,8 +908,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetSchemas_result()
- result.success = self._handler.GetSchemas(args.req)
- oprot.writeMessageBegin("GetSchemas", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetSchemas(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetSchemas", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -870,8 +927,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetTables_result()
- result.success = self._handler.GetTables(args.req)
- oprot.writeMessageBegin("GetTables", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetTables(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetTables", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -881,8 +946,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetTableTypes_result()
- result.success = self._handler.GetTableTypes(args.req)
- oprot.writeMessageBegin("GetTableTypes", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetTableTypes(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetTableTypes", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -892,8 +965,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetColumns_result()
- result.success = self._handler.GetColumns(args.req)
- oprot.writeMessageBegin("GetColumns", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetColumns(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetColumns", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -903,8 +984,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetFunctions_result()
- result.success = self._handler.GetFunctions(args.req)
- oprot.writeMessageBegin("GetFunctions", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetFunctions(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetFunctions", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -914,8 +1003,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetOperationStatus_result()
- result.success = self._handler.GetOperationStatus(args.req)
- oprot.writeMessageBegin("GetOperationStatus", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetOperationStatus(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetOperationStatus", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -925,8 +1022,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = CancelOperation_result()
- result.success = self._handler.CancelOperation(args.req)
- oprot.writeMessageBegin("CancelOperation", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.CancelOperation(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("CancelOperation", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -936,8 +1041,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = CloseOperation_result()
- result.success = self._handler.CloseOperation(args.req)
- oprot.writeMessageBegin("CloseOperation", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.CloseOperation(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("CloseOperation", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -947,8 +1060,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetResultSetMetadata_result()
- result.success = self._handler.GetResultSetMetadata(args.req)
- oprot.writeMessageBegin("GetResultSetMetadata", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetResultSetMetadata(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetResultSetMetadata", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -958,8 +1079,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = FetchResults_result()
- result.success = self._handler.FetchResults(args.req)
- oprot.writeMessageBegin("FetchResults", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.FetchResults(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("FetchResults", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -969,8 +1098,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = GetDelegationToken_result()
- result.success = self._handler.GetDelegationToken(args.req)
- oprot.writeMessageBegin("GetDelegationToken", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.GetDelegationToken(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("GetDelegationToken", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -980,8 +1117,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = CancelDelegationToken_result()
- result.success = self._handler.CancelDelegationToken(args.req)
- oprot.writeMessageBegin("CancelDelegationToken", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.CancelDelegationToken(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("CancelDelegationToken", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -991,8 +1136,16 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = RenewDelegationToken_result()
- result.success = self._handler.RenewDelegationToken(args.req)
- oprot.writeMessageBegin("RenewDelegationToken", TMessageType.REPLY, seqid)
+ try:
+ result.success = self._handler.RenewDelegationToken(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("RenewDelegationToken", msg_type, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-py/TCLIService/constants.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/TCLIService/constants.py b/service/src/gen/thrift/gen-py/TCLIService/constants.py
index 9fb1a86..c8d4f8f 100644
--- a/service/src/gen/thrift/gen-py/TCLIService/constants.py
+++ b/service/src/gen/thrift/gen-py/TCLIService/constants.py
@@ -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
#
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-py/TCLIService/ttypes.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/TCLIService/ttypes.py b/service/src/gen/thrift/gen-py/TCLIService/ttypes.py
index efee8ef..ef5f5f5 100644
--- a/service/src/gen/thrift/gen-py/TCLIService/ttypes.py
+++ b/service/src/gen/thrift/gen-py/TCLIService/ttypes.py
@@ -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
#
@@ -416,12 +416,12 @@ class TTypeQualifierValue:
break
if fid == 1:
if ftype == TType.I32:
- self.i32Value = iprot.readI32();
+ self.i32Value = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.stringValue = iprot.readString();
+ self.stringValue = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -494,7 +494,7 @@ class TTypeQualifiers:
self.qualifiers = {}
(_ktype1, _vtype2, _size0 ) = iprot.readMapBegin()
for _i4 in xrange(_size0):
- _key5 = iprot.readString();
+ _key5 = iprot.readString()
_val6 = TTypeQualifierValue()
_val6.read(iprot)
self.qualifiers[_key5] = _val6
@@ -572,7 +572,7 @@ class TPrimitiveTypeEntry:
break
if fid == 1:
if ftype == TType.I32:
- self.type = iprot.readI32();
+ self.type = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -650,7 +650,7 @@ class TArrayTypeEntry:
break
if fid == 1:
if ftype == TType.I32:
- self.objectTypePtr = iprot.readI32();
+ self.objectTypePtr = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -720,12 +720,12 @@ class TMapTypeEntry:
break
if fid == 1:
if ftype == TType.I32:
- self.keyTypePtr = iprot.readI32();
+ self.keyTypePtr = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.valueTypePtr = iprot.readI32();
+ self.valueTypePtr = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -802,8 +802,8 @@ class TStructTypeEntry:
self.nameToTypePtr = {}
(_ktype10, _vtype11, _size9 ) = iprot.readMapBegin()
for _i13 in xrange(_size9):
- _key14 = iprot.readString();
- _val15 = iprot.readI32();
+ _key14 = iprot.readString()
+ _val15 = iprot.readI32()
self.nameToTypePtr[_key14] = _val15
iprot.readMapEnd()
else:
@@ -879,8 +879,8 @@ class TUnionTypeEntry:
self.nameToTypePtr = {}
(_ktype19, _vtype20, _size18 ) = iprot.readMapBegin()
for _i22 in xrange(_size18):
- _key23 = iprot.readString();
- _val24 = iprot.readI32();
+ _key23 = iprot.readString()
+ _val24 = iprot.readI32()
self.nameToTypePtr[_key23] = _val24
iprot.readMapEnd()
else:
@@ -953,7 +953,7 @@ class TUserDefinedTypeEntry:
break
if fid == 1:
if ftype == TType.STRING:
- self.typeClassName = iprot.readString();
+ self.typeClassName = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -1241,7 +1241,7 @@ class TColumnDesc:
break
if fid == 1:
if ftype == TType.STRING:
- self.columnName = iprot.readString();
+ self.columnName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -1252,12 +1252,12 @@ class TColumnDesc:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.position = iprot.readI32();
+ self.position = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.comment = iprot.readString();
+ self.comment = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -1419,7 +1419,7 @@ class TBoolValue:
break
if fid == 1:
if ftype == TType.BOOL:
- self.value = iprot.readBool();
+ self.value = iprot.readBool()
else:
iprot.skip(ftype)
else:
@@ -1484,7 +1484,7 @@ class TByteValue:
break
if fid == 1:
if ftype == TType.BYTE:
- self.value = iprot.readByte();
+ self.value = iprot.readByte()
else:
iprot.skip(ftype)
else:
@@ -1549,7 +1549,7 @@ class TI16Value:
break
if fid == 1:
if ftype == TType.I16:
- self.value = iprot.readI16();
+ self.value = iprot.readI16()
else:
iprot.skip(ftype)
else:
@@ -1614,7 +1614,7 @@ class TI32Value:
break
if fid == 1:
if ftype == TType.I32:
- self.value = iprot.readI32();
+ self.value = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -1679,7 +1679,7 @@ class TI64Value:
break
if fid == 1:
if ftype == TType.I64:
- self.value = iprot.readI64();
+ self.value = iprot.readI64()
else:
iprot.skip(ftype)
else:
@@ -1744,7 +1744,7 @@ class TDoubleValue:
break
if fid == 1:
if ftype == TType.DOUBLE:
- self.value = iprot.readDouble();
+ self.value = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -1809,7 +1809,7 @@ class TStringValue:
break
if fid == 1:
if ftype == TType.STRING:
- self.value = iprot.readString();
+ self.value = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2106,14 +2106,14 @@ class TBoolColumn:
self.values = []
(_etype51, _size48) = iprot.readListBegin()
for _i52 in xrange(_size48):
- _elem53 = iprot.readBool();
+ _elem53 = iprot.readBool()
self.values.append(_elem53)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2196,14 +2196,14 @@ class TByteColumn:
self.values = []
(_etype58, _size55) = iprot.readListBegin()
for _i59 in xrange(_size55):
- _elem60 = iprot.readByte();
+ _elem60 = iprot.readByte()
self.values.append(_elem60)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2286,14 +2286,14 @@ class TI16Column:
self.values = []
(_etype65, _size62) = iprot.readListBegin()
for _i66 in xrange(_size62):
- _elem67 = iprot.readI16();
+ _elem67 = iprot.readI16()
self.values.append(_elem67)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2376,14 +2376,14 @@ class TI32Column:
self.values = []
(_etype72, _size69) = iprot.readListBegin()
for _i73 in xrange(_size69):
- _elem74 = iprot.readI32();
+ _elem74 = iprot.readI32()
self.values.append(_elem74)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2466,14 +2466,14 @@ class TI64Column:
self.values = []
(_etype79, _size76) = iprot.readListBegin()
for _i80 in xrange(_size76):
- _elem81 = iprot.readI64();
+ _elem81 = iprot.readI64()
self.values.append(_elem81)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2556,14 +2556,14 @@ class TDoubleColumn:
self.values = []
(_etype86, _size83) = iprot.readListBegin()
for _i87 in xrange(_size83):
- _elem88 = iprot.readDouble();
+ _elem88 = iprot.readDouble()
self.values.append(_elem88)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2646,14 +2646,14 @@ class TStringColumn:
self.values = []
(_etype93, _size90) = iprot.readListBegin()
for _i94 in xrange(_size90):
- _elem95 = iprot.readString();
+ _elem95 = iprot.readString()
self.values.append(_elem95)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2736,14 +2736,14 @@ class TBinaryColumn:
self.values = []
(_etype100, _size97) = iprot.readListBegin()
for _i101 in xrange(_size97):
- _elem102 = iprot.readString();
+ _elem102 = iprot.readString()
self.values.append(_elem102)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.nulls = iprot.readString();
+ self.nulls = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -2990,7 +2990,7 @@ class TRowSet:
break
if fid == 1:
if ftype == TType.I64:
- self.startRowOffset = iprot.readI64();
+ self.startRowOffset = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -3109,7 +3109,7 @@ class TStatus:
break
if fid == 1:
if ftype == TType.I32:
- self.statusCode = iprot.readI32();
+ self.statusCode = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
@@ -3117,24 +3117,24 @@ class TStatus:
self.infoMessages = []
(_etype121, _size118) = iprot.readListBegin()
for _i122 in xrange(_size118):
- _elem123 = iprot.readString();
+ _elem123 = iprot.readString()
self.infoMessages.append(_elem123)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.sqlState = iprot.readString();
+ self.sqlState = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.errorCode = iprot.readI32();
+ self.errorCode = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
- self.errorMessage = iprot.readString();
+ self.errorMessage = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -3227,12 +3227,12 @@ class THandleIdentifier:
break
if fid == 1:
if ftype == TType.STRING:
- self.guid = iprot.readString();
+ self.guid = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.secret = iprot.readString();
+ self.secret = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -3389,17 +3389,17 @@ class TOperationHandle:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.operationType = iprot.readI32();
+ self.operationType = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.BOOL:
- self.hasResultSet = iprot.readBool();
+ self.hasResultSet = iprot.readBool()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.DOUBLE:
- self.modifiedRowCount = iprot.readDouble();
+ self.modifiedRowCount = iprot.readDouble()
else:
iprot.skip(ftype)
else:
@@ -3494,17 +3494,17 @@ class TOpenSessionReq:
break
if fid == 1:
if ftype == TType.I32:
- self.client_protocol = iprot.readI32();
+ self.client_protocol = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.username = iprot.readString();
+ self.username = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.password = iprot.readString();
+ self.password = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
@@ -3512,8 +3512,8 @@ class TOpenSessionReq:
self.configuration = {}
(_ktype126, _vtype127, _size125 ) = iprot.readMapBegin()
for _i129 in xrange(_size125):
- _key130 = iprot.readString();
- _val131 = iprot.readString();
+ _key130 = iprot.readString()
+ _val131 = iprot.readString()
self.configuration[_key130] = _val131
iprot.readMapEnd()
else:
@@ -3616,7 +3616,7 @@ class TOpenSessionResp:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.serverProtocolVersion = iprot.readI32();
+ self.serverProtocolVersion = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -3630,8 +3630,8 @@ class TOpenSessionResp:
self.configuration = {}
(_ktype135, _vtype136, _size134 ) = iprot.readMapBegin()
for _i138 in xrange(_size134):
- _key139 = iprot.readString();
- _val140 = iprot.readString();
+ _key139 = iprot.readString()
+ _val140 = iprot.readString()
self.configuration[_key139] = _val140
iprot.readMapEnd()
else:
@@ -3872,32 +3872,32 @@ class TGetInfoValue:
break
if fid == 1:
if ftype == TType.STRING:
- self.stringValue = iprot.readString();
+ self.stringValue = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I16:
- self.smallIntValue = iprot.readI16();
+ self.smallIntValue = iprot.readI16()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I32:
- self.integerBitmask = iprot.readI32();
+ self.integerBitmask = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.integerFlag = iprot.readI32();
+ self.integerFlag = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.I32:
- self.binaryValue = iprot.readI32();
+ self.binaryValue = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.I64:
- self.lenValue = iprot.readI64();
+ self.lenValue = iprot.readI64()
else:
iprot.skip(ftype)
else:
@@ -3996,7 +3996,7 @@ class TGetInfoReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.infoType = iprot.readI32();
+ self.infoType = iprot.readI32()
else:
iprot.skip(ftype)
else:
@@ -4169,7 +4169,7 @@ class TExecuteStatementReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.statement = iprot.readString();
+ self.statement = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -4177,15 +4177,15 @@ class TExecuteStatementReq:
self.confOverlay = {}
(_ktype144, _vtype145, _size143 ) = iprot.readMapBegin()
for _i147 in xrange(_size143):
- _key148 = iprot.readString();
- _val149 = iprot.readString();
+ _key148 = iprot.readString()
+ _val149 = iprot.readString()
self.confOverlay[_key148] = _val149
iprot.readMapEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.BOOL:
- self.runAsync = iprot.readBool();
+ self.runAsync = iprot.readBool()
else:
iprot.skip(ftype)
else:
@@ -4667,12 +4667,12 @@ class TGetSchemasReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.catalogName = iprot.readString();
+ self.catalogName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.schemaName = iprot.readString();
+ self.schemaName = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -4849,17 +4849,17 @@ class TGetTablesReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.catalogName = iprot.readString();
+ self.catalogName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.schemaName = iprot.readString();
+ self.schemaName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.tableName = iprot.readString();
+ self.tableName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
@@ -4867,7 +4867,7 @@ class TGetTablesReq:
self.tableTypes = []
(_etype155, _size152) = iprot.readListBegin()
for _i156 in xrange(_size152):
- _elem157 = iprot.readString();
+ _elem157 = iprot.readString()
self.tableTypes.append(_elem157)
iprot.readListEnd()
else:
@@ -5209,22 +5209,22 @@ class TGetColumnsReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.catalogName = iprot.readString();
+ self.catalogName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.schemaName = iprot.readString();
+ self.schemaName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.tableName = iprot.readString();
+ self.tableName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
- self.columnName = iprot.readString();
+ self.columnName = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -5408,17 +5408,17 @@ class TGetFunctionsReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.catalogName = iprot.readString();
+ self.catalogName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.schemaName = iprot.readString();
+ self.schemaName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.functionName = iprot.readString();
+ self.functionName = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -5670,22 +5670,22 @@ class TGetOperationStatusResp:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.operationState = iprot.readI32();
+ self.operationState = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.sqlState = iprot.readString();
+ self.sqlState = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I32:
- self.errorCode = iprot.readI32();
+ self.errorCode = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
- self.errorMessage = iprot.readString();
+ self.errorMessage = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -6209,17 +6209,17 @@ class TFetchResultsReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.I32:
- self.orientation = iprot.readI32();
+ self.orientation = iprot.readI32()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.I64:
- self.maxRows = iprot.readI64();
+ self.maxRows = iprot.readI64()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.I16:
- self.fetchType = iprot.readI16();
+ self.fetchType = iprot.readI16()
else:
iprot.skip(ftype)
else:
@@ -6317,7 +6317,7 @@ class TFetchResultsResp:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.BOOL:
- self.hasMoreRows = iprot.readBool();
+ self.hasMoreRows = iprot.readBool()
else:
iprot.skip(ftype)
elif fid == 3:
@@ -6412,12 +6412,12 @@ class TGetDelegationTokenReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.owner = iprot.readString();
+ self.owner = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.renewer = iprot.readString();
+ self.renewer = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -6507,7 +6507,7 @@ class TGetDelegationTokenResp:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.delegationToken = iprot.readString();
+ self.delegationToken = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -6588,7 +6588,7 @@ class TCancelDelegationTokenReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.delegationToken = iprot.readString();
+ self.delegationToken = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -6739,7 +6739,7 @@ class TRenewDelegationTokenReq:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.delegationToken = iprot.readString();
+ self.delegationToken = iprot.readString()
else:
iprot.skip(ftype)
else:
http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/service/src/gen/thrift/gen-py/hive_service/ThriftHive-remote
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/hive_service/ThriftHive-remote b/service/src/gen/thrift/gen-py/hive_service/ThriftHive-remote
index 54d59a8..e167d5b 100755
--- a/service/src/gen/thrift/gen-py/hive_service/ThriftHive-remote
+++ b/service/src/gen/thrift/gen-py/hive_service/ThriftHive-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
#