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 #