Return-Path: X-Original-To: apmail-hive-commits-archive@www.apache.org Delivered-To: apmail-hive-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 9DE6818066 for ; Fri, 15 Jan 2016 01:17:54 +0000 (UTC) Received: (qmail 85262 invoked by uid 500); 15 Jan 2016 01:17:52 -0000 Delivered-To: apmail-hive-commits-archive@hive.apache.org Received: (qmail 85112 invoked by uid 500); 15 Jan 2016 01:17:52 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 83313 invoked by uid 99); 15 Jan 2016 01:17:51 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 15 Jan 2016 01:17:51 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C18FEE38A4; Fri, 15 Jan 2016 01:17:50 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: gates@apache.org To: commits@hive.apache.org Date: Fri, 15 Jan 2016 01:18:00 -0000 Message-Id: In-Reply-To: <7d5f42c6ef1a4921a7d6da35f00622af@git.apache.org> References: <7d5f42c6ef1a4921a7d6da35f00622af@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [11/22] hive git commit: HIVE-12832 Thrift and RDBMS schema changes for ACID fixes, branch-1 version. http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py b/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py index f86fda9..d1c07a5 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/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/92072ad2/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py index 0b80390..596fdf5 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/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 # @@ -242,12 +242,12 @@ class Version: break if fid == 1: if ftype == TType.STRING: - self.version = iprot.readString(); + self.version = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.comments = iprot.readString(); + self.comments = iprot.readString() else: iprot.skip(ftype) else: @@ -323,17 +323,17 @@ class FieldSchema: break if fid == 1: if ftype == TType.STRING: - self.name = iprot.readString(); + self.name = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.type = iprot.readString(); + self.type = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.comment = iprot.readString(); + self.comment = iprot.readString() else: iprot.skip(ftype) else: @@ -417,17 +417,17 @@ class Type: break if fid == 1: if ftype == TType.STRING: - self.name = iprot.readString(); + self.name = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.type1 = iprot.readString(); + self.type1 = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.type2 = iprot.readString(); + self.type2 = iprot.readString() else: iprot.skip(ftype) elif fid == 4: @@ -533,17 +533,17 @@ class HiveObjectRef: break if fid == 1: if ftype == TType.I32: - self.objectType = iprot.readI32(); + self.objectType = iprot.readI32() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.objectName = iprot.readString(); + self.objectName = iprot.readString() else: iprot.skip(ftype) elif fid == 4: @@ -551,14 +551,14 @@ class HiveObjectRef: self.partValues = [] (_etype10, _size7) = iprot.readListBegin() for _i11 in xrange(_size7): - _elem12 = iprot.readString(); + _elem12 = iprot.readString() self.partValues.append(_elem12) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.STRING: - self.columnName = iprot.readString(); + self.columnName = iprot.readString() else: iprot.skip(ftype) else: @@ -658,27 +658,27 @@ class PrivilegeGrantInfo: break if fid == 1: if ftype == TType.STRING: - self.privilege = iprot.readString(); + self.privilege = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.grantor = iprot.readString(); + self.grantor = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.grantorType = iprot.readI32(); + self.grantorType = iprot.readI32() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.BOOL: - self.grantOption = iprot.readBool(); + self.grantOption = iprot.readBool() else: iprot.skip(ftype) else: @@ -778,12 +778,12 @@ class HiveObjectPrivilege: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.principalName = iprot.readString(); + self.principalName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I32: - self.principalType = iprot.readI32(); + self.principalType = iprot.readI32() else: iprot.skip(ftype) elif fid == 4: @@ -952,7 +952,7 @@ class PrincipalPrivilegeSet: self.userPrivileges = {} (_ktype22, _vtype23, _size21 ) = iprot.readMapBegin() for _i25 in xrange(_size21): - _key26 = iprot.readString(); + _key26 = iprot.readString() _val27 = [] (_etype31, _size28) = iprot.readListBegin() for _i32 in xrange(_size28): @@ -969,7 +969,7 @@ class PrincipalPrivilegeSet: self.groupPrivileges = {} (_ktype35, _vtype36, _size34 ) = iprot.readMapBegin() for _i38 in xrange(_size34): - _key39 = iprot.readString(); + _key39 = iprot.readString() _val40 = [] (_etype44, _size41) = iprot.readListBegin() for _i45 in xrange(_size41): @@ -986,7 +986,7 @@ class PrincipalPrivilegeSet: self.rolePrivileges = {} (_ktype48, _vtype49, _size47 ) = iprot.readMapBegin() for _i51 in xrange(_size47): - _key52 = iprot.readString(); + _key52 = iprot.readString() _val53 = [] (_etype57, _size54) = iprot.readListBegin() for _i58 in xrange(_size54): @@ -1097,7 +1097,7 @@ class GrantRevokePrivilegeRequest: break if fid == 1: if ftype == TType.I32: - self.requestType = iprot.readI32(); + self.requestType = iprot.readI32() else: iprot.skip(ftype) elif fid == 2: @@ -1108,7 +1108,7 @@ class GrantRevokePrivilegeRequest: iprot.skip(ftype) elif fid == 3: if ftype == TType.BOOL: - self.revokeGrantOption = iprot.readBool(); + self.revokeGrantOption = iprot.readBool() else: iprot.skip(ftype) else: @@ -1183,7 +1183,7 @@ class GrantRevokePrivilegeResponse: break if fid == 1: if ftype == TType.BOOL: - self.success = iprot.readBool(); + self.success = iprot.readBool() else: iprot.skip(ftype) else: @@ -1254,17 +1254,17 @@ class Role: break if fid == 1: if ftype == TType.STRING: - self.roleName = iprot.readString(); + self.roleName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.ownerName = iprot.readString(); + self.ownerName = iprot.readString() else: iprot.skip(ftype) else: @@ -1357,37 +1357,37 @@ class RolePrincipalGrant: break if fid == 1: if ftype == TType.STRING: - self.roleName = iprot.readString(); + self.roleName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.principalName = iprot.readString(); + self.principalName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I32: - self.principalType = iprot.readI32(); + self.principalType = iprot.readI32() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.BOOL: - self.grantOption = iprot.readBool(); + self.grantOption = iprot.readBool() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.grantTime = iprot.readI32(); + self.grantTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.STRING: - self.grantorName = iprot.readString(); + self.grantorName = iprot.readString() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.I32: - self.grantorPrincipalType = iprot.readI32(); + self.grantorPrincipalType = iprot.readI32() else: iprot.skip(ftype) else: @@ -1485,12 +1485,12 @@ class GetRoleGrantsForPrincipalRequest: break if fid == 1: if ftype == TType.STRING: - self.principal_name = iprot.readString(); + self.principal_name = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.principal_type = iprot.readI32(); + self.principal_type = iprot.readI32() else: iprot.skip(ftype) else: @@ -1640,7 +1640,7 @@ class GetPrincipalsInRoleRequest: break if fid == 1: if ftype == TType.STRING: - self.roleName = iprot.readString(); + self.roleName = iprot.readString() else: iprot.skip(ftype) else: @@ -1801,37 +1801,37 @@ class GrantRevokeRoleRequest: break if fid == 1: if ftype == TType.I32: - self.requestType = iprot.readI32(); + self.requestType = iprot.readI32() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.roleName = iprot.readString(); + self.roleName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.principalName = iprot.readString(); + self.principalName = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.principalType = iprot.readI32(); + self.principalType = iprot.readI32() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.STRING: - self.grantor = iprot.readString(); + self.grantor = iprot.readString() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.grantorType = iprot.readI32(); + self.grantorType = iprot.readI32() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.BOOL: - self.grantOption = iprot.readBool(); + self.grantOption = iprot.readBool() else: iprot.skip(ftype) else: @@ -1926,7 +1926,7 @@ class GrantRevokeRoleResponse: break if fid == 1: if ftype == TType.BOOL: - self.success = iprot.readBool(); + self.success = iprot.readBool() else: iprot.skip(ftype) else: @@ -2009,17 +2009,17 @@ class Database: break if fid == 1: if ftype == TType.STRING: - self.name = iprot.readString(); + self.name = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.description = iprot.readString(); + self.description = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.locationUri = iprot.readString(); + self.locationUri = iprot.readString() else: iprot.skip(ftype) elif fid == 4: @@ -2027,8 +2027,8 @@ class Database: self.parameters = {} (_ktype84, _vtype85, _size83 ) = iprot.readMapBegin() for _i87 in xrange(_size83): - _key88 = iprot.readString(); - _val89 = iprot.readString(); + _key88 = iprot.readString() + _val89 = iprot.readString() self.parameters[_key88] = _val89 iprot.readMapEnd() else: @@ -2041,12 +2041,12 @@ class Database: iprot.skip(ftype) elif fid == 6: if ftype == TType.STRING: - self.ownerName = iprot.readString(); + self.ownerName = iprot.readString() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.I32: - self.ownerType = iprot.readI32(); + self.ownerType = iprot.readI32() else: iprot.skip(ftype) else: @@ -2151,12 +2151,12 @@ class SerDeInfo: break if fid == 1: if ftype == TType.STRING: - self.name = iprot.readString(); + self.name = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.serializationLib = iprot.readString(); + self.serializationLib = iprot.readString() else: iprot.skip(ftype) elif fid == 3: @@ -2164,8 +2164,8 @@ class SerDeInfo: self.parameters = {} (_ktype93, _vtype94, _size92 ) = iprot.readMapBegin() for _i96 in xrange(_size92): - _key97 = iprot.readString(); - _val98 = iprot.readString(); + _key97 = iprot.readString() + _val98 = iprot.readString() self.parameters[_key97] = _val98 iprot.readMapEnd() else: @@ -2249,12 +2249,12 @@ class Order: break if fid == 1: if ftype == TType.STRING: - self.col = iprot.readString(); + self.col = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.order = iprot.readI32(); + self.order = iprot.readI32() else: iprot.skip(ftype) else: @@ -2333,7 +2333,7 @@ class SkewedInfo: self.skewedColNames = [] (_etype104, _size101) = iprot.readListBegin() for _i105 in xrange(_size101): - _elem106 = iprot.readString(); + _elem106 = iprot.readString() self.skewedColNames.append(_elem106) iprot.readListEnd() else: @@ -2346,7 +2346,7 @@ class SkewedInfo: _elem112 = [] (_etype116, _size113) = iprot.readListBegin() for _i117 in xrange(_size113): - _elem118 = iprot.readString(); + _elem118 = iprot.readString() _elem112.append(_elem118) iprot.readListEnd() self.skewedColValues.append(_elem112) @@ -2361,10 +2361,10 @@ class SkewedInfo: _key124 = [] (_etype129, _size126) = iprot.readListBegin() for _i130 in xrange(_size126): - _elem131 = iprot.readString(); + _elem131 = iprot.readString() _key124.append(_elem131) iprot.readListEnd() - _val125 = iprot.readString(); + _val125 = iprot.readString() self.skewedColValueLocationMaps[_key124] = _val125 iprot.readMapEnd() else: @@ -2501,27 +2501,27 @@ class StorageDescriptor: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.location = iprot.readString(); + self.location = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.inputFormat = iprot.readString(); + self.inputFormat = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.outputFormat = iprot.readString(); + self.outputFormat = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.BOOL: - self.compressed = iprot.readBool(); + self.compressed = iprot.readBool() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.numBuckets = iprot.readI32(); + self.numBuckets = iprot.readI32() else: iprot.skip(ftype) elif fid == 7: @@ -2535,7 +2535,7 @@ class StorageDescriptor: self.bucketCols = [] (_etype147, _size144) = iprot.readListBegin() for _i148 in xrange(_size144): - _elem149 = iprot.readString(); + _elem149 = iprot.readString() self.bucketCols.append(_elem149) iprot.readListEnd() else: @@ -2556,8 +2556,8 @@ class StorageDescriptor: self.parameters = {} (_ktype157, _vtype158, _size156 ) = iprot.readMapBegin() for _i160 in xrange(_size156): - _key161 = iprot.readString(); - _val162 = iprot.readString(); + _key161 = iprot.readString() + _val162 = iprot.readString() self.parameters[_key161] = _val162 iprot.readMapEnd() else: @@ -2570,7 +2570,7 @@ class StorageDescriptor: iprot.skip(ftype) elif fid == 12: if ftype == TType.BOOL: - self.storedAsSubDirectories = iprot.readBool(); + self.storedAsSubDirectories = iprot.readBool() else: iprot.skip(ftype) else: @@ -2742,32 +2742,32 @@ class Table: break if fid == 1: if ftype == TType.STRING: - self.tableName = iprot.readString(); + self.tableName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.owner = iprot.readString(); + self.owner = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.lastAccessTime = iprot.readI32(); + self.lastAccessTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.retention = iprot.readI32(); + self.retention = iprot.readI32() else: iprot.skip(ftype) elif fid == 7: @@ -2792,25 +2792,25 @@ class Table: self.parameters = {} (_ktype175, _vtype176, _size174 ) = iprot.readMapBegin() for _i178 in xrange(_size174): - _key179 = iprot.readString(); - _val180 = iprot.readString(); + _key179 = iprot.readString() + _val180 = iprot.readString() self.parameters[_key179] = _val180 iprot.readMapEnd() else: iprot.skip(ftype) elif fid == 10: if ftype == TType.STRING: - self.viewOriginalText = iprot.readString(); + self.viewOriginalText = iprot.readString() else: iprot.skip(ftype) elif fid == 11: if ftype == TType.STRING: - self.viewExpandedText = iprot.readString(); + self.viewExpandedText = iprot.readString() else: iprot.skip(ftype) elif fid == 12: if ftype == TType.STRING: - self.tableType = iprot.readString(); + self.tableType = iprot.readString() else: iprot.skip(ftype) elif fid == 13: @@ -2821,7 +2821,7 @@ class Table: iprot.skip(ftype) elif fid == 14: if ftype == TType.BOOL: - self.temporary = iprot.readBool(); + self.temporary = iprot.readBool() else: iprot.skip(ftype) else: @@ -2982,29 +2982,29 @@ class Partition: self.values = [] (_etype187, _size184) = iprot.readListBegin() for _i188 in xrange(_size184): - _elem189 = iprot.readString(); + _elem189 = iprot.readString() self.values.append(_elem189) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.tableName = iprot.readString(); + self.tableName = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.lastAccessTime = iprot.readI32(); + self.lastAccessTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 6: @@ -3018,8 +3018,8 @@ class Partition: self.parameters = {} (_ktype191, _vtype192, _size190 ) = iprot.readMapBegin() for _i194 in xrange(_size190): - _key195 = iprot.readString(); - _val196 = iprot.readString(); + _key195 = iprot.readString() + _val196 = iprot.readString() self.parameters[_key195] = _val196 iprot.readMapEnd() else: @@ -3152,24 +3152,24 @@ class PartitionWithoutSD: self.values = [] (_etype203, _size200) = iprot.readListBegin() for _i204 in xrange(_size200): - _elem205 = iprot.readString(); + _elem205 = iprot.readString() self.values.append(_elem205) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I32: - self.lastAccessTime = iprot.readI32(); + self.lastAccessTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.relativePath = iprot.readString(); + self.relativePath = iprot.readString() else: iprot.skip(ftype) elif fid == 5: @@ -3177,8 +3177,8 @@ class PartitionWithoutSD: self.parameters = {} (_ktype207, _vtype208, _size206 ) = iprot.readMapBegin() for _i210 in xrange(_size206): - _key211 = iprot.readString(); - _val212 = iprot.readString(); + _key211 = iprot.readString() + _val212 = iprot.readString() self.parameters[_key211] = _val212 iprot.readMapEnd() else: @@ -3457,17 +3457,17 @@ class PartitionSpec: break if fid == 1: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tableName = iprot.readString(); + self.tableName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.rootPath = iprot.readString(); + self.rootPath = iprot.readString() else: iprot.skip(ftype) elif fid == 4: @@ -3591,37 +3591,37 @@ class Index: break if fid == 1: if ftype == TType.STRING: - self.indexName = iprot.readString(); + self.indexName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.indexHandlerClass = iprot.readString(); + self.indexHandlerClass = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.origTableName = iprot.readString(); + self.origTableName = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.lastAccessTime = iprot.readI32(); + self.lastAccessTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.STRING: - self.indexTableName = iprot.readString(); + self.indexTableName = iprot.readString() else: iprot.skip(ftype) elif fid == 8: @@ -3635,15 +3635,15 @@ class Index: self.parameters = {} (_ktype231, _vtype232, _size230 ) = iprot.readMapBegin() for _i234 in xrange(_size230): - _key235 = iprot.readString(); - _val236 = iprot.readString(); + _key235 = iprot.readString() + _val236 = iprot.readString() self.parameters[_key235] = _val236 iprot.readMapEnd() else: iprot.skip(ftype) elif fid == 10: if ftype == TType.BOOL: - self.deferredRebuild = iprot.readBool(); + self.deferredRebuild = iprot.readBool() else: iprot.skip(ftype) else: @@ -3763,17 +3763,17 @@ class BooleanColumnStatsData: break if fid == 1: if ftype == TType.I64: - self.numTrues = iprot.readI64(); + self.numTrues = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I64: - self.numFalses = iprot.readI64(); + self.numFalses = iprot.readI64() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) else: @@ -3863,22 +3863,22 @@ class DoubleColumnStatsData: break if fid == 1: if ftype == TType.DOUBLE: - self.lowValue = iprot.readDouble(); + self.lowValue = iprot.readDouble() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.DOUBLE: - self.highValue = iprot.readDouble(); + self.highValue = iprot.readDouble() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I64: - self.numDVs = iprot.readI64(); + self.numDVs = iprot.readI64() else: iprot.skip(ftype) else: @@ -3971,22 +3971,22 @@ class LongColumnStatsData: break if fid == 1: if ftype == TType.I64: - self.lowValue = iprot.readI64(); + self.lowValue = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I64: - self.highValue = iprot.readI64(); + self.highValue = iprot.readI64() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I64: - self.numDVs = iprot.readI64(); + self.numDVs = iprot.readI64() else: iprot.skip(ftype) else: @@ -4079,22 +4079,22 @@ class StringColumnStatsData: break if fid == 1: if ftype == TType.I64: - self.maxColLen = iprot.readI64(); + self.maxColLen = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.DOUBLE: - self.avgColLen = iprot.readDouble(); + self.avgColLen = iprot.readDouble() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I64: - self.numDVs = iprot.readI64(); + self.numDVs = iprot.readI64() else: iprot.skip(ftype) else: @@ -4188,17 +4188,17 @@ class BinaryColumnStatsData: break if fid == 1: if ftype == TType.I64: - self.maxColLen = iprot.readI64(); + self.maxColLen = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.DOUBLE: - self.avgColLen = iprot.readDouble(); + self.avgColLen = iprot.readDouble() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) else: @@ -4283,12 +4283,12 @@ class Decimal: break if fid == 1: if ftype == TType.STRING: - self.unscaled = iprot.readString(); + self.unscaled = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I16: - self.scale = iprot.readI16(); + self.scale = iprot.readI16() else: iprot.skip(ftype) else: @@ -4383,12 +4383,12 @@ class DecimalColumnStatsData: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I64: - self.numDVs = iprot.readI64(); + self.numDVs = iprot.readI64() else: iprot.skip(ftype) else: @@ -4472,7 +4472,7 @@ class Date: break if fid == 1: if ftype == TType.I64: - self.daysSinceEpoch = iprot.readI64(); + self.daysSinceEpoch = iprot.readI64() else: iprot.skip(ftype) else: @@ -4560,12 +4560,12 @@ class DateColumnStatsData: iprot.skip(ftype) elif fid == 3: if ftype == TType.I64: - self.numNulls = iprot.readI64(); + self.numNulls = iprot.readI64() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I64: - self.numDVs = iprot.readI64(); + self.numDVs = iprot.readI64() else: iprot.skip(ftype) else: @@ -4805,12 +4805,12 @@ class ColumnStatisticsObj: break if fid == 1: if ftype == TType.STRING: - self.colName = iprot.readString(); + self.colName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.colType = iprot.readString(); + self.colType = iprot.readString() else: iprot.skip(ftype) elif fid == 3: @@ -4909,27 +4909,27 @@ class ColumnStatisticsDesc: break if fid == 1: if ftype == TType.BOOL: - self.isTblLevel = iprot.readBool(); + self.isTblLevel = iprot.readBool() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.tableName = iprot.readString(); + self.tableName = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.partName = iprot.readString(); + self.partName = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I64: - self.lastAnalyzed = iprot.readI64(); + self.lastAnalyzed = iprot.readI64() else: iprot.skip(ftype) else: @@ -5126,7 +5126,7 @@ class AggrStats: iprot.skip(ftype) elif fid == 2: if ftype == TType.I64: - self.partsFound = iprot.readI64(); + self.partsFound = iprot.readI64() else: iprot.skip(ftype) else: @@ -5296,8 +5296,8 @@ class Schema: self.properties = {} (_ktype267, _vtype268, _size266 ) = iprot.readMapBegin() for _i270 in xrange(_size266): - _key271 = iprot.readString(); - _val272 = iprot.readString(); + _key271 = iprot.readString() + _val272 = iprot.readString() self.properties[_key271] = _val272 iprot.readMapEnd() else: @@ -5379,8 +5379,8 @@ class EnvironmentContext: self.properties = {} (_ktype277, _vtype278, _size276 ) = iprot.readMapBegin() for _i280 in xrange(_size276): - _key281 = iprot.readString(); - _val282 = iprot.readString(); + _key281 = iprot.readString() + _val282 = iprot.readString() self.properties[_key281] = _val282 iprot.readMapEnd() else: @@ -5465,7 +5465,7 @@ class PartitionsByExprResult: iprot.skip(ftype) elif fid == 2: if ftype == TType.BOOL: - self.hasUnknownPartitions = iprot.readBool(); + self.hasUnknownPartitions = iprot.readBool() else: iprot.skip(ftype) else: @@ -5554,27 +5554,27 @@ class PartitionsByExprRequest: break if fid == 1: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tblName = iprot.readString(); + self.tblName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.expr = iprot.readString(); + self.expr = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.defaultPartitionName = iprot.readString(); + self.defaultPartitionName = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I16: - self.maxParts = iprot.readI16(); + self.maxParts = iprot.readI16() else: iprot.skip(ftype) else: @@ -5744,7 +5744,7 @@ class PartitionsStatsResult: self.partStats = {} (_ktype300, _vtype301, _size299 ) = iprot.readMapBegin() for _i303 in xrange(_size299): - _key304 = iprot.readString(); + _key304 = iprot.readString() _val305 = [] (_etype309, _size306) = iprot.readListBegin() for _i310 in xrange(_size306): @@ -5833,12 +5833,12 @@ class TableStatsRequest: break if fid == 1: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tblName = iprot.readString(); + self.tblName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: @@ -5846,7 +5846,7 @@ class TableStatsRequest: self.colNames = [] (_etype318, _size315) = iprot.readListBegin() for _i319 in xrange(_size315): - _elem320 = iprot.readString(); + _elem320 = iprot.readString() self.colNames.append(_elem320) iprot.readListEnd() else: @@ -5941,12 +5941,12 @@ class PartitionsStatsRequest: break if fid == 1: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tblName = iprot.readString(); + self.tblName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: @@ -5954,7 +5954,7 @@ class PartitionsStatsRequest: self.colNames = [] (_etype325, _size322) = iprot.readListBegin() for _i326 in xrange(_size322): - _elem327 = iprot.readString(); + _elem327 = iprot.readString() self.colNames.append(_elem327) iprot.readListEnd() else: @@ -5964,7 +5964,7 @@ class PartitionsStatsRequest: self.partNames = [] (_etype331, _size328) = iprot.readListBegin() for _i332 in xrange(_size328): - _elem333 = iprot.readString(); + _elem333 = iprot.readString() self.partNames.append(_elem333) iprot.readListEnd() else: @@ -6146,12 +6146,12 @@ class AddPartitionsRequest: break if fid == 1: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tblName = iprot.readString(); + self.tblName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: @@ -6167,12 +6167,12 @@ class AddPartitionsRequest: iprot.skip(ftype) elif fid == 4: if ftype == TType.BOOL: - self.ifNotExists = iprot.readBool(); + self.ifNotExists = iprot.readBool() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.BOOL: - self.needResult = iprot.readBool(); + self.needResult = iprot.readBool() else: iprot.skip(ftype) else: @@ -6345,12 +6345,12 @@ class DropPartitionsExpr: break if fid == 1: if ftype == TType.STRING: - self.expr = iprot.readString(); + self.expr = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.partArchiveLevel = iprot.readI32(); + self.partArchiveLevel = iprot.readI32() else: iprot.skip(ftype) else: @@ -6428,7 +6428,7 @@ class RequestPartsSpec: self.names = [] (_etype360, _size357) = iprot.readListBegin() for _i361 in xrange(_size357): - _elem362 = iprot.readString(); + _elem362 = iprot.readString() self.names.append(_elem362) iprot.readListEnd() else: @@ -6538,12 +6538,12 @@ class DropPartitionsRequest: break if fid == 1: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tblName = iprot.readString(); + self.tblName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: @@ -6554,17 +6554,17 @@ class DropPartitionsRequest: iprot.skip(ftype) elif fid == 4: if ftype == TType.BOOL: - self.deleteData = iprot.readBool(); + self.deleteData = iprot.readBool() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.BOOL: - self.ifExists = iprot.readBool(); + self.ifExists = iprot.readBool() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.BOOL: - self.ignoreProtection = iprot.readBool(); + self.ignoreProtection = iprot.readBool() else: iprot.skip(ftype) elif fid == 7: @@ -6575,7 +6575,7 @@ class DropPartitionsRequest: iprot.skip(ftype) elif fid == 8: if ftype == TType.BOOL: - self.needResult = iprot.readBool(); + self.needResult = iprot.readBool() else: iprot.skip(ftype) else: @@ -6684,12 +6684,12 @@ class ResourceUri: break if fid == 1: if ftype == TType.I32: - self.resourceType = iprot.readI32(); + self.resourceType = iprot.readI32() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.uri = iprot.readString(); + self.uri = iprot.readString() else: iprot.skip(ftype) else: @@ -6780,37 +6780,37 @@ class Function: break if fid == 1: if ftype == TType.STRING: - self.functionName = iprot.readString(); + self.functionName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.className = iprot.readString(); + self.className = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.ownerName = iprot.readString(); + self.ownerName = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.ownerType = iprot.readI32(); + self.ownerType = iprot.readI32() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.createTime = iprot.readI32(); + self.createTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.I32: - self.functionType = iprot.readI32(); + self.functionType = iprot.readI32() else: iprot.skip(ftype) elif fid == 8: @@ -6906,6 +6906,9 @@ class TxnInfo: - state - user - hostname + - agentInfo + - heartbeatCount + - metaInfo """ thrift_spec = ( @@ -6914,13 +6917,19 @@ class TxnInfo: (2, TType.I32, 'state', None, None, ), # 2 (3, TType.STRING, 'user', None, None, ), # 3 (4, TType.STRING, 'hostname', None, None, ), # 4 + (5, TType.STRING, 'agentInfo', None, "Unknown", ), # 5 + (6, TType.I32, 'heartbeatCount', None, 0, ), # 6 + (7, TType.STRING, 'metaInfo', None, None, ), # 7 ) - def __init__(self, id=None, state=None, user=None, hostname=None,): + def __init__(self, id=None, state=None, user=None, hostname=None, agentInfo=thrift_spec[5][4], heartbeatCount=thrift_spec[6][4], metaInfo=None,): self.id = id self.state = state self.user = user self.hostname = hostname + self.agentInfo = agentInfo + self.heartbeatCount = heartbeatCount + self.metaInfo = metaInfo def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -6933,22 +6942,37 @@ class TxnInfo: break if fid == 1: if ftype == TType.I64: - self.id = iprot.readI64(); + self.id = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.state = iprot.readI32(); + self.state = iprot.readI32() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.user = iprot.readString(); + self.user = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.hostname = iprot.readString(); + self.hostname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.agentInfo = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.I32: + self.heartbeatCount = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.metaInfo = iprot.readString() else: iprot.skip(ftype) else: @@ -6977,6 +7001,18 @@ class TxnInfo: oprot.writeFieldBegin('hostname', TType.STRING, 4) oprot.writeString(self.hostname) oprot.writeFieldEnd() + if self.agentInfo is not None: + oprot.writeFieldBegin('agentInfo', TType.STRING, 5) + oprot.writeString(self.agentInfo) + oprot.writeFieldEnd() + if self.heartbeatCount is not None: + oprot.writeFieldBegin('heartbeatCount', TType.I32, 6) + oprot.writeI32(self.heartbeatCount) + oprot.writeFieldEnd() + if self.metaInfo is not None: + oprot.writeFieldBegin('metaInfo', TType.STRING, 7) + oprot.writeString(self.metaInfo) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -6998,6 +7034,9 @@ class TxnInfo: value = (value * 31) ^ hash(self.state) value = (value * 31) ^ hash(self.user) value = (value * 31) ^ hash(self.hostname) + value = (value * 31) ^ hash(self.agentInfo) + value = (value * 31) ^ hash(self.heartbeatCount) + value = (value * 31) ^ hash(self.metaInfo) return value def __repr__(self): @@ -7039,7 +7078,7 @@ class GetOpenTxnsInfoResponse: break if fid == 1: if ftype == TType.I64: - self.txn_high_water_mark = iprot.readI64(); + self.txn_high_water_mark = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: @@ -7130,7 +7169,7 @@ class GetOpenTxnsResponse: break if fid == 1: if ftype == TType.I64: - self.txn_high_water_mark = iprot.readI64(); + self.txn_high_water_mark = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: @@ -7138,7 +7177,7 @@ class GetOpenTxnsResponse: self.open_txns = set() (_etype388, _size385) = iprot.readSetBegin() for _i389 in xrange(_size385): - _elem390 = iprot.readI64(); + _elem390 = iprot.readI64() self.open_txns.add(_elem390) iprot.readSetEnd() else: @@ -7198,6 +7237,7 @@ class OpenTxnRequest: - num_txns - user - hostname + - agentInfo """ thrift_spec = ( @@ -7205,12 +7245,14 @@ class OpenTxnRequest: (1, TType.I32, 'num_txns', None, None, ), # 1 (2, TType.STRING, 'user', None, None, ), # 2 (3, TType.STRING, 'hostname', None, None, ), # 3 + (4, TType.STRING, 'agentInfo', None, "Unknown", ), # 4 ) - def __init__(self, num_txns=None, user=None, hostname=None,): + def __init__(self, num_txns=None, user=None, hostname=None, agentInfo=thrift_spec[4][4],): self.num_txns = num_txns self.user = user self.hostname = hostname + self.agentInfo = agentInfo def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -7223,17 +7265,22 @@ class OpenTxnRequest: break if fid == 1: if ftype == TType.I32: - self.num_txns = iprot.readI32(); + self.num_txns = iprot.readI32() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.user = iprot.readString(); + self.user = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.hostname = iprot.readString(); + self.hostname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.agentInfo = iprot.readString() else: iprot.skip(ftype) else: @@ -7258,6 +7305,10 @@ class OpenTxnRequest: oprot.writeFieldBegin('hostname', TType.STRING, 3) oprot.writeString(self.hostname) oprot.writeFieldEnd() + if self.agentInfo is not None: + oprot.writeFieldBegin('agentInfo', TType.STRING, 4) + oprot.writeString(self.agentInfo) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -7276,6 +7327,7 @@ class OpenTxnRequest: value = (value * 31) ^ hash(self.num_txns) value = (value * 31) ^ hash(self.user) value = (value * 31) ^ hash(self.hostname) + value = (value * 31) ^ hash(self.agentInfo) return value def __repr__(self): @@ -7317,7 +7369,7 @@ class OpenTxnsResponse: self.txn_ids = [] (_etype395, _size392) = iprot.readListBegin() for _i396 in xrange(_size392): - _elem397 = iprot.readI64(); + _elem397 = iprot.readI64() self.txn_ids.append(_elem397) iprot.readListEnd() else: @@ -7389,7 +7441,7 @@ class AbortTxnRequest: break if fid == 1: if ftype == TType.I64: - self.txnid = iprot.readI64(); + self.txnid = iprot.readI64() else: iprot.skip(ftype) else: @@ -7456,7 +7508,7 @@ class CommitTxnRequest: break if fid == 1: if ftype == TType.I64: - self.txnid = iprot.readI64(); + self.txnid = iprot.readI64() else: iprot.skip(ftype) else: @@ -7535,27 +7587,27 @@ class LockComponent: break if fid == 1: if ftype == TType.I32: - self.type = iprot.readI32(); + self.type = iprot.readI32() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.level = iprot.readI32(); + self.level = iprot.readI32() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.dbname = iprot.readString(); + self.dbname = 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.partitionname = iprot.readString(); + self.partitionname = iprot.readString() else: iprot.skip(ftype) else: @@ -7628,6 +7680,7 @@ class LockRequest: - txnid - user - hostname + - agentInfo """ thrift_spec = ( @@ -7636,13 +7689,15 @@ class LockRequest: (2, TType.I64, 'txnid', None, None, ), # 2 (3, TType.STRING, 'user', None, None, ), # 3 (4, TType.STRING, 'hostname', None, None, ), # 4 + (5, TType.STRING, 'agentInfo', None, "Unknown", ), # 5 ) - def __init__(self, component=None, txnid=None, user=None, hostname=None,): + def __init__(self, component=None, txnid=None, user=None, hostname=None, agentInfo=thrift_spec[5][4],): self.component = component self.txnid = txnid self.user = user self.hostname = hostname + self.agentInfo = agentInfo def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -7666,17 +7721,22 @@ class LockRequest: iprot.skip(ftype) elif fid == 2: if ftype == TType.I64: - self.txnid = iprot.readI64(); + self.txnid = iprot.readI64() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.user = iprot.readString(); + self.user = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.hostname = iprot.readString(); + self.hostname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.agentInfo = iprot.readString() else: iprot.skip(ftype) else: @@ -7708,6 +7768,10 @@ class LockRequest: oprot.writeFieldBegin('hostname', TType.STRING, 4) oprot.writeString(self.hostname) oprot.writeFieldEnd() + if self.agentInfo is not None: + oprot.writeFieldBegin('agentInfo', TType.STRING, 5) + oprot.writeString(self.agentInfo) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -7727,6 +7791,7 @@ class LockRequest: value = (value * 31) ^ hash(self.txnid) value = (value * 31) ^ hash(self.user) value = (value * 31) ^ hash(self.hostname) + value = (value * 31) ^ hash(self.agentInfo) return value def __repr__(self): @@ -7768,12 +7833,12 @@ class LockResponse: break if fid == 1: if ftype == TType.I64: - self.lockid = iprot.readI64(); + self.lockid = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.state = iprot.readI32(); + self.state = iprot.readI32() else: iprot.skip(ftype) else: @@ -7826,15 +7891,21 @@ class CheckLockRequest: """ Attributes: - lockid + - txnid + - elapsed_ms """ thrift_spec = ( None, # 0 (1, TType.I64, 'lockid', None, None, ), # 1 + (2, TType.I64, 'txnid', None, None, ), # 2 + (3, TType.I64, 'elapsed_ms', None, None, ), # 3 ) - def __init__(self, lockid=None,): + def __init__(self, lockid=None, txnid=None, elapsed_ms=None,): self.lockid = lockid + self.txnid = txnid + self.elapsed_ms = elapsed_ms def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -7847,7 +7918,17 @@ class CheckLockRequest: break if fid == 1: if ftype == TType.I64: - self.lockid = iprot.readI64(); + self.lockid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.txnid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.elapsed_ms = iprot.readI64() else: iprot.skip(ftype) else: @@ -7864,6 +7945,14 @@ class CheckLockRequest: oprot.writeFieldBegin('lockid', TType.I64, 1) oprot.writeI64(self.lockid) oprot.writeFieldEnd() + if self.txnid is not None: + oprot.writeFieldBegin('txnid', TType.I64, 2) + oprot.writeI64(self.txnid) + oprot.writeFieldEnd() + if self.elapsed_ms is not None: + oprot.writeFieldBegin('elapsed_ms', TType.I64, 3) + oprot.writeI64(self.elapsed_ms) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -7876,6 +7965,8 @@ class CheckLockRequest: def __hash__(self): value = 17 value = (value * 31) ^ hash(self.lockid) + value = (value * 31) ^ hash(self.txnid) + value = (value * 31) ^ hash(self.elapsed_ms) return value def __repr__(self): @@ -7914,7 +8005,7 @@ class UnlockRequest: break if fid == 1: if ftype == TType.I64: - self.lockid = iprot.readI64(); + self.lockid = iprot.readI64() else: iprot.skip(ftype) else: @@ -7957,10 +8048,28 @@ class UnlockRequest: return not (self == other) class ShowLocksRequest: + """ + Attributes: + - dbname + - tablename + - partname + - isExtended + """ thrift_spec = ( + None, # 0 + (1, TType.STRING, 'dbname', None, None, ), # 1 + (2, TType.STRING, 'tablename', None, None, ), # 2 + (3, TType.STRING, 'partname', None, None, ), # 3 + (4, TType.BOOL, 'isExtended', None, False, ), # 4 ) + def __init__(self, dbname=None, tablename=None, partname=None, isExtended=thrift_spec[4][4],): + self.dbname = dbname + self.tablename = tablename + self.partname = partname + self.isExtended = isExtended + def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) @@ -7970,6 +8079,26 @@ class ShowLocksRequest: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break + if fid == 1: + if ftype == TType.STRING: + self.dbname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.tablename = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.partname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BOOL: + self.isExtended = iprot.readBool() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -7980,6 +8109,22 @@ class ShowLocksRequest: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return oprot.writeStructBegin('ShowLocksRequest') + if self.dbname is not None: + oprot.writeFieldBegin('dbname', TType.STRING, 1) + oprot.writeString(self.dbname) + oprot.writeFieldEnd() + if self.tablename is not None: + oprot.writeFieldBegin('tablename', TType.STRING, 2) + oprot.writeString(self.tablename) + oprot.writeFieldEnd() + if self.partname is not None: + oprot.writeFieldBegin('partname', TType.STRING, 3) + oprot.writeString(self.partname) + oprot.writeFieldEnd() + if self.isExtended is not None: + oprot.writeFieldBegin('isExtended', TType.BOOL, 4) + oprot.writeBool(self.isExtended) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -7989,6 +8134,10 @@ class ShowLocksRequest: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.dbname) + value = (value * 31) ^ hash(self.tablename) + value = (value * 31) ^ hash(self.partname) + value = (value * 31) ^ hash(self.isExtended) return value def __repr__(self): @@ -8016,6 +8165,11 @@ class ShowLocksResponseElement: - acquiredat - user - hostname + - heartbeatCount + - agentInfo + - blockedByExtId + - blockedByIntId + - lockIdInternal """ thrift_spec = ( @@ -8031,9 +8185,14 @@ class ShowLocksResponseElement: (9, TType.I64, 'acquiredat', None, None, ), # 9 (10, TType.STRING, 'user', None, None, ), # 10 (11, TType.STRING, 'hostname', None, None, ), # 11 + (12, TType.I32, 'heartbeatCount', None, 0, ), # 12 + (13, TType.STRING, 'agentInfo', None, None, ), # 13 + (14, TType.I64, 'blockedByExtId', None, None, ), # 14 + (15, TType.I64, 'blockedByIntId', None, None, ), # 15 + (16, TType.I64, 'lockIdInternal', None, None, ), # 16 ) - def __init__(self, lockid=None, dbname=None, tablename=None, partname=None, state=None, type=None, txnid=None, lastheartbeat=None, acquiredat=None, user=None, hostname=None,): + def __init__(self, lockid=None, dbname=None, tablename=None, partname=None, state=None, type=None, txnid=None, lastheartbeat=None, acquiredat=None, user=None, hostname=None, heartbeatCount=thrift_spec[12][4], agentInfo=None, blockedByExtId=None, blockedByIntId=None, lockIdInternal=None,): self.lockid = lockid self.dbname = dbname self.tablename = tablename @@ -8045,6 +8204,11 @@ class ShowLocksResponseElement: self.acquiredat = acquiredat self.user = user self.hostname = hostname + self.heartbeatCount = heartbeatCount + self.agentInfo = agentInfo + self.blockedByExtId = blockedByExtId + self.blockedByIntId = blockedByIntId + self.lockIdInternal = lockIdInternal def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -8057,57 +8221,82 @@ class ShowLocksResponseElement: break if fid == 1: if ftype == TType.I64: - self.lockid = iprot.readI64(); + self.lockid = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbname = iprot.readString(); + self.dbname = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.tablename = iprot.readString(); + self.tablename = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.partname = iprot.readString(); + self.partname = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.state = iprot.readI32(); + self.state = iprot.readI32() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.type = iprot.readI32(); + self.type = iprot.readI32() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.I64: - self.txnid = iprot.readI64(); + self.txnid = iprot.readI64() else: iprot.skip(ftype) elif fid == 8: if ftype == TType.I64: - self.lastheartbeat = iprot.readI64(); + self.lastheartbeat = iprot.readI64() else: iprot.skip(ftype) elif fid == 9: if ftype == TType.I64: - self.acquiredat = iprot.readI64(); + self.acquiredat = iprot.readI64() else: iprot.skip(ftype) elif fid == 10: if ftype == TType.STRING: - self.user = iprot.readString(); + self.user = iprot.readString() else: iprot.skip(ftype) elif fid == 11: if ftype == TType.STRING: - self.hostname = iprot.readString(); + self.hostname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.I32: + self.heartbeatCount = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 13: + if ftype == TType.STRING: + self.agentInfo = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 14: + if ftype == TType.I64: + self.blockedByExtId = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 15: + if ftype == TType.I64: + self.blockedByIntId = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 16: + if ftype == TType.I64: + self.lockIdInternal = iprot.readI64() else: iprot.skip(ftype) else: @@ -8164,6 +8353,26 @@ class ShowLocksResponseElement: oprot.writeFieldBegin('hostname', TType.STRING, 11) oprot.writeString(self.hostname) oprot.writeFieldEnd() + if self.heartbeatCount is not None: + oprot.writeFieldBegin('heartbeatCount', TType.I32, 12) + oprot.writeI32(self.heartbeatCount) + oprot.writeFieldEnd() + if self.agentInfo is not None: + oprot.writeFieldBegin('agentInfo', TType.STRING, 13) + oprot.writeString(self.agentInfo) + oprot.writeFieldEnd() + if self.blockedByExtId is not None: + oprot.writeFieldBegin('blockedByExtId', TType.I64, 14) + oprot.writeI64(self.blockedByExtId) + oprot.writeFieldEnd() + if self.blockedByIntId is not None: + oprot.writeFieldBegin('blockedByIntId', TType.I64, 15) + oprot.writeI64(self.blockedByIntId) + oprot.writeFieldEnd() + if self.lockIdInternal is not None: + oprot.writeFieldBegin('lockIdInternal', TType.I64, 16) + oprot.writeI64(self.lockIdInternal) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -8198,6 +8407,11 @@ class ShowLocksResponseElement: value = (value * 31) ^ hash(self.acquiredat) value = (value * 31) ^ hash(self.user) value = (value * 31) ^ hash(self.hostname) + value = (value * 31) ^ hash(self.heartbeatCount) + value = (value * 31) ^ hash(self.agentInfo) + value = (value * 31) ^ hash(self.blockedByExtId) + value = (value * 31) ^ hash(self.blockedByIntId) + value = (value * 31) ^ hash(self.lockIdInternal) return value def __repr__(self): @@ -8313,12 +8527,12 @@ class HeartbeatRequest: break if fid == 1: if ftype == TType.I64: - self.lockid = iprot.readI64(); + self.lockid = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I64: - self.txnid = iprot.readI64(); + self.txnid = iprot.readI64() else: iprot.skip(ftype) else: @@ -8391,12 +8605,12 @@ class HeartbeatTxnRangeRequest: break if fid == 1: if ftype == TType.I64: - self.min = iprot.readI64(); + self.min = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I64: - self.max = iprot.readI64(); + self.max = iprot.readI64() else: iprot.skip(ftype) else: @@ -8476,7 +8690,7 @@ class HeartbeatTxnRangeResponse: self.aborted = set() (_etype416, _size413) = iprot.readSetBegin() for _i417 in xrange(_size413): - _elem418 = iprot.readI64(); + _elem418 = iprot.readI64() self.aborted.add(_elem418) iprot.readSetEnd() else: @@ -8486,7 +8700,7 @@ class HeartbeatTxnRangeResponse: self.nosuch = set() (_etype422, _size419) = iprot.readSetBegin() for _i423 in xrange(_size419): - _elem424 = iprot.readI64(); + _elem424 = iprot.readI64() self.nosuch.add(_elem424) iprot.readSetEnd() else: @@ -8580,27 +8794,27 @@ class CompactionRequest: break if fid == 1: if ftype == TType.STRING: - self.dbname = iprot.readString(); + self.dbname = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tablename = iprot.readString(); + self.tablename = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.partitionname = iprot.readString(); + self.partitionname = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.type = iprot.readI32(); + self.type = iprot.readI32() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.STRING: - self.runas = iprot.readString(); + self.runas = iprot.readString() else: iprot.skip(ftype) else: @@ -8723,6 +8937,10 @@ class ShowCompactResponseElement: - workerid - start - runAs + - hightestTxnId + - metaInfo + - endTime + - hadoopJobId """ thrift_spec = ( @@ -8735,9 +8953,13 @@ class ShowCompactResponseElement: (6, TType.STRING, 'workerid', None, None, ), # 6 (7, TType.I64, 'start', None, None, ), # 7 (8, TType.STRING, 'runAs', None, None, ), # 8 + (9, TType.I64, 'hightestTxnId', None, None, ), # 9 + (10, TType.STRING, 'metaInfo', None, None, ), # 10 + (11, TType.I64, 'endTime', None, None, ), # 11 + (12, TType.STRING, 'hadoopJobId', None, "None", ), # 12 ) - def __init__(self, dbname=None, tablename=None, partitionname=None, type=None, state=None, workerid=None, start=None, runAs=None,): + def __init__(self, dbname=None, tablename=None, partitionname=None, type=None, state=None, workerid=None, start=None, runAs=None, hightestTxnId=None, metaInfo=None, endTime=None, hadoopJobId=thrift_spec[12][4],): self.dbname = dbname self.tablename = tablename self.partitionname = partitionname @@ -8746,6 +8968,10 @@ class ShowCompactResponseElement: self.workerid = workerid self.start = start self.runAs = runAs + self.hightestTxnId = hightestTxnId + self.metaInfo = metaInfo + self.endTime = endTime + self.hadoopJobId = hadoopJobId def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -8758,42 +8984,62 @@ class ShowCompactResponseElement: break if fid == 1: if ftype == TType.STRING: - self.dbname = iprot.readString(); + self.dbname = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tablename = iprot.readString(); + self.tablename = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.partitionname = iprot.readString(); + self.partitionname = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.type = iprot.readI32(); + self.type = iprot.readI32() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.STRING: - self.state = iprot.readString(); + self.state = iprot.readString() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.STRING: - self.workerid = iprot.readString(); + self.workerid = iprot.readString() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.I64: - self.start = iprot.readI64(); + self.start = iprot.readI64() else: iprot.skip(ftype) elif fid == 8: if ftype == TType.STRING: - self.runAs = iprot.readString(); + self.runAs = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.I64: + self.hightestTxnId = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.STRING: + self.metaInfo = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.I64: + self.endTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.STRING: + self.hadoopJobId = iprot.readString() else: iprot.skip(ftype) else: @@ -8838,6 +9084,22 @@ class ShowCompactResponseElement: oprot.writeFieldBegin('runAs', TType.STRING, 8) oprot.writeString(self.runAs) oprot.writeFieldEnd() + if self.hightestTxnId is not None: + oprot.writeFieldBegin('hightestTxnId', TType.I64, 9) + oprot.writeI64(self.hightestTxnId) + oprot.writeFieldEnd() + if self.metaInfo is not None: + oprot.writeFieldBegin('metaInfo', TType.STRING, 10) + oprot.writeString(self.metaInfo) + oprot.writeFieldEnd() + if self.endTime is not None: + oprot.writeFieldBegin('endTime', TType.I64, 11) + oprot.writeI64(self.endTime) + oprot.writeFieldEnd() + if self.hadoopJobId is not None: + oprot.writeFieldBegin('hadoopJobId', TType.STRING, 12) + oprot.writeString(self.hadoopJobId) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -8863,6 +9125,10 @@ class ShowCompactResponseElement: value = (value * 31) ^ hash(self.workerid) value = (value * 31) ^ hash(self.start) value = (value * 31) ^ hash(self.runAs) + value = (value * 31) ^ hash(self.hightestTxnId) + value = (value * 31) ^ hash(self.metaInfo) + value = (value * 31) ^ hash(self.endTime) + value = (value * 31) ^ hash(self.hadoopJobId) return value def __repr__(self): @@ -8986,17 +9252,17 @@ class AddDynamicPartitions: break if fid == 1: if ftype == TType.I64: - self.txnid = iprot.readI64(); + self.txnid = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.dbname = iprot.readString(); + self.dbname = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.tablename = iprot.readString(); + self.tablename = iprot.readString() else: iprot.skip(ftype) elif fid == 4: @@ -9004,7 +9270,7 @@ class AddDynamicPartitions: self.partitionnames = [] (_etype437, _size434) = iprot.readListBegin() for _i438 in xrange(_size434): - _elem439 = iprot.readString(); + _elem439 = iprot.readString() self.partitionnames.append(_elem439) iprot.readListEnd() else: @@ -9100,12 +9366,12 @@ class NotificationEventRequest: break if fid == 1: if ftype == TType.I64: - self.lastEvent = iprot.readI64(); + self.lastEvent = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.maxEvents = iprot.readI32(); + self.maxEvents = iprot.readI32() else: iprot.skip(ftype) else: @@ -9192,32 +9458,32 @@ class NotificationEvent: break if fid == 1: if ftype == TType.I64: - self.eventId = iprot.readI64(); + self.eventId = iprot.readI64() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.eventTime = iprot.readI32(); + self.eventTime = iprot.readI32() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.eventType = iprot.readString(); + self.eventType = iprot.readString() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = iprot.readString() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.STRING: - self.tableName = iprot.readString(); + self.tableName = iprot.readString() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -9391,7 +9657,7 @@ class CurrentNotificationEventId: break if fid == 1: if ftype == TType.I64: - self.eventId = iprot.readI64(); + self.eventId = iprot.readI64() else: iprot.skip(ftype) else: @@ -9461,7 +9727,7 @@ class InsertEventRequestData: self.filesAdded = [] (_etype451, _size448) = iprot.readListBegin() for _i452 in xrange(_size448): - _elem453 = iprot.readString(); + _elem453 = iprot.readString() self.filesAdded.append(_elem453) iprot.readListEnd() else: @@ -9611,7 +9877,7 @@ class FireEventRequest: break if fid == 1: if ftype == TType.BOOL: - self.successful = iprot.readBool(); + self.successful = iprot.readBool() else: iprot.skip(ftype) elif fid == 2: @@ -9622,12 +9888,12 @@ class FireEventRequest: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.dbName = iprot.readString(); + self.dbName = 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: @@ -9635,7 +9901,7 @@ class FireEventRequest: self.partitionVals = [] (_etype458, _size455) = iprot.readListBegin() for _i459 in xrange(_size455): - _elem460 = iprot.readString(); + _elem460 = iprot.readString() self.partitionVals.append(_elem460) iprot.readListEnd() else: @@ -9849,7 +10115,7 @@ class MetaException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -9917,7 +10183,7 @@ class UnknownTableException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -9985,7 +10251,7 @@ class UnknownDBException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10053,7 +10319,7 @@ class AlreadyExistsException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10121,7 +10387,7 @@ class InvalidPartitionException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10189,7 +10455,7 @@ class UnknownPartitionException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10257,7 +10523,7 @@ class InvalidObjectException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10325,7 +10591,7 @@ class NoSuchObjectException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10393,7 +10659,7 @@ class IndexAlreadyExistsException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10461,7 +10727,7 @@ class InvalidOperationException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10529,7 +10795,7 @@ class ConfigValSecurityException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10597,7 +10863,7 @@ class InvalidInputException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10665,7 +10931,7 @@ class NoSuchTxnException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10733,7 +10999,7 @@ class TxnAbortedException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10801,7 +11067,7 @@ class TxnOpenException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: @@ -10869,7 +11135,7 @@ class NoSuchLockException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString(); + self.message = iprot.readString() else: iprot.skip(ftype) else: http://git-wip-us.apache.org/repos/asf/hive/blob/92072ad2/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb b/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb index 7ef6f43..eeccc84 100644 --- a/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb +++ b/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb @@ -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 #