You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2016/01/15 02:18:00 UTC
[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
#