http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 d1d86fe..fc5f458 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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 isHasResultSet(); + return Boolean.valueOf(isHasResultSet()); case MODIFIED_ROW_COUNT: - return getModifiedRowCount(); + return Double.valueOf(getModifiedRowCount()); } throw new IllegalStateException();
http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 fe029ef..2dfde1c 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 f105259..6927740 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 38a5be3..fe2ad7e 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 c936ada..6e714c6 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 e74bb29..0a8d6e1 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 63633e3..4a5b522 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 28c34cd..8153fb4 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 9b9b2ac..f0dd60f 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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 getStartRowOffset(); + return Long.valueOf(getStartRowOffset()); case ROWS: return getRows(); http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 aeff2b6..09161e5 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 ccf281a..2fd1ac1 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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 getErrorCode(); + return Integer.valueOf(getErrorCode()); case ERROR_MESSAGE: return getErrorMessage(); http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 8900d4c..91d1a97 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 7c15ec1..ed33013 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 96e9be0..302b552 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 c90926a..b25b0e8 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 7a38e15..73276cf 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 e187da2..d84b6a9 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 a53eaa2..203d3b9 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 379bc92..e6f2336 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 cc786b2..54df6dc 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 ac97b7f..80be0a4 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 0c7120d..49f7388 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 4ae9505..6bc7a6f 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.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") 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/ccb30e3e/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 eba62f1..f5dd904 100644 --- a/service/src/gen/thrift/gen-php/TCLIService.php +++ b/service/src/gen/thrift/gen-php/TCLIService.php @@ -1,6 +1,7 @@ <?php +namespace ; /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 23dc8fd..2c783b6 100644 --- a/service/src/gen/thrift/gen-php/ThriftHive.php +++ b/service/src/gen/thrift/gen-php/ThriftHive.php @@ -1,6 +1,7 @@ <?php +namespace ; /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 cbf4c29..d8f3c5b 100644 --- a/service/src/gen/thrift/gen-php/Types.php +++ b/service/src/gen/thrift/gen-php/Types.php @@ -1,6 +1,8 @@ <?php +namespace ; + /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * 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/ccb30e3e/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 56f5c5d..2bfca56 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.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 ad2d71d..0067195 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.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -7,7 +7,6 @@ # from thrift.Thrift import TType, TMessageType, TException, TApplicationException -import logging from ttypes import * from thrift.Thrift import TProcessor from thrift.transport import TTransport @@ -189,7 +188,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): """ @@ -220,7 +219,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): """ @@ -251,7 +250,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): """ @@ -282,7 +281,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): """ @@ -313,7 +312,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): """ @@ -344,7 +343,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): """ @@ -375,7 +374,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): """ @@ -406,7 +405,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): """ @@ -437,7 +436,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): """ @@ -468,7 +467,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): """ @@ -499,7 +498,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): """ @@ -530,7 +529,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): """ @@ -561,7 +560,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): """ @@ -592,7 +591,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): """ @@ -623,7 +622,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): """ @@ -654,7 +653,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): """ @@ -685,7 +684,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): """ @@ -716,7 +715,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): """ @@ -747,7 +746,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): @@ -794,16 +793,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = OpenSession_result() - 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.success = self._handler.OpenSession(args.req) + oprot.writeMessageBegin("OpenSession", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -813,16 +804,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = CloseSession_result() - 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.success = self._handler.CloseSession(args.req) + oprot.writeMessageBegin("CloseSession", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -832,16 +815,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetInfo_result() - 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.success = self._handler.GetInfo(args.req) + oprot.writeMessageBegin("GetInfo", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -851,16 +826,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = ExecuteStatement_result() - 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.success = self._handler.ExecuteStatement(args.req) + oprot.writeMessageBegin("ExecuteStatement", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -870,16 +837,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetTypeInfo_result() - 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.success = self._handler.GetTypeInfo(args.req) + oprot.writeMessageBegin("GetTypeInfo", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -889,16 +848,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetCatalogs_result() - 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.success = self._handler.GetCatalogs(args.req) + oprot.writeMessageBegin("GetCatalogs", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -908,16 +859,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetSchemas_result() - 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.success = self._handler.GetSchemas(args.req) + oprot.writeMessageBegin("GetSchemas", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -927,16 +870,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetTables_result() - 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.success = self._handler.GetTables(args.req) + oprot.writeMessageBegin("GetTables", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -946,16 +881,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetTableTypes_result() - 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.success = self._handler.GetTableTypes(args.req) + oprot.writeMessageBegin("GetTableTypes", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -965,16 +892,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetColumns_result() - 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.success = self._handler.GetColumns(args.req) + oprot.writeMessageBegin("GetColumns", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -984,16 +903,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetFunctions_result() - 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.success = self._handler.GetFunctions(args.req) + oprot.writeMessageBegin("GetFunctions", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1003,16 +914,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetOperationStatus_result() - 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.success = self._handler.GetOperationStatus(args.req) + oprot.writeMessageBegin("GetOperationStatus", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1022,16 +925,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = CancelOperation_result() - 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.success = self._handler.CancelOperation(args.req) + oprot.writeMessageBegin("CancelOperation", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1041,16 +936,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = CloseOperation_result() - 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.success = self._handler.CloseOperation(args.req) + oprot.writeMessageBegin("CloseOperation", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1060,16 +947,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetResultSetMetadata_result() - 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.success = self._handler.GetResultSetMetadata(args.req) + oprot.writeMessageBegin("GetResultSetMetadata", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1079,16 +958,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = FetchResults_result() - 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.success = self._handler.FetchResults(args.req) + oprot.writeMessageBegin("FetchResults", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1098,16 +969,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = GetDelegationToken_result() - 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.success = self._handler.GetDelegationToken(args.req) + oprot.writeMessageBegin("GetDelegationToken", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1117,16 +980,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = CancelDelegationToken_result() - 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.success = self._handler.CancelDelegationToken(args.req) + oprot.writeMessageBegin("CancelDelegationToken", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -1136,16 +991,8 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = RenewDelegationToken_result() - 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.success = self._handler.RenewDelegationToken(args.req) + oprot.writeMessageBegin("RenewDelegationToken", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 c8d4f8f..9fb1a86 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.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 ef5f5f5..efee8ef 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.3) +# Autogenerated by Thrift Compiler (0.9.2) # # 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/ccb30e3e/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 4bd7a5a..7f63595 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.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -91,6 +91,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' get_partitions_by_filter(string db_name, string tbl_name, string filter, i16 max_parts)') print(' get_part_specs_by_filter(string db_name, string tbl_name, string filter, i32 max_parts)') print(' PartitionsByExprResult get_partitions_by_expr(PartitionsByExprRequest req)') + print(' i32 get_num_partitions_by_filter(string db_name, string tbl_name, string filter)') print(' get_partitions_by_names(string db_name, string tbl_name, names)') print(' void alter_partition(string db_name, string tbl_name, Partition new_part)') print(' void alter_partitions(string db_name, string tbl_name, new_parts)') @@ -636,6 +637,12 @@ elif cmd == 'get_partitions_by_expr': sys.exit(1) pp.pprint(client.get_partitions_by_expr(eval(args[0]),)) +elif cmd == 'get_num_partitions_by_filter': + if len(args) != 3: + print('get_num_partitions_by_filter requires 3 args') + sys.exit(1) + pp.pprint(client.get_num_partitions_by_filter(args[0],args[1],args[2],)) + elif cmd == 'get_partitions_by_names': if len(args) != 3: print('get_partitions_by_names requires 3 args')