You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2016/10/04 18:46:51 UTC
[10/15] hive git commit: HIVE-14671 : merge master into hive-14535
(Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 22c0cc6,10778f2..6f157d8
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@@ -14858,6 -14695,183 +14927,183 @@@ class get_tables_result
def __ne__(self, other):
return not (self == other)
+ class get_tables_by_type_args:
+ """
+ Attributes:
+ - db_name
+ - pattern
+ - tableType
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'pattern', None, None, ), # 2
+ (3, TType.STRING, 'tableType', None, None, ), # 3
+ )
+
+ def __init__(self, db_name=None, pattern=None, tableType=None,):
+ self.db_name = db_name
+ self.pattern = pattern
+ self.tableType = tableType
+
+ 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))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.db_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.pattern = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.tableType = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_tables_by_type_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.pattern is not None:
+ oprot.writeFieldBegin('pattern', TType.STRING, 2)
+ oprot.writeString(self.pattern)
+ oprot.writeFieldEnd()
+ if self.tableType is not None:
+ oprot.writeFieldBegin('tableType', TType.STRING, 3)
+ oprot.writeString(self.tableType)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.db_name)
+ value = (value * 31) ^ hash(self.pattern)
+ value = (value * 31) ^ hash(self.tableType)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+ class get_tables_by_type_result:
+ """
+ Attributes:
+ - success
+ - o1
+ """
+
+ thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, success=None, o1=None,):
+ self.success = success
+ self.o1 = o1
+
+ 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))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.LIST:
+ self.success = []
- (_etype641, _size638) = iprot.readListBegin()
- for _i642 in xrange(_size638):
- _elem643 = iprot.readString()
- self.success.append(_elem643)
++ (_etype648, _size645) = iprot.readListBegin()
++ for _i649 in xrange(_size645):
++ _elem650 = iprot.readString()
++ self.success.append(_elem650)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = MetaException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_tables_by_type_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRING, len(self.success))
- for iter644 in self.success:
- oprot.writeString(iter644)
++ for iter651 in self.success:
++ oprot.writeString(iter651)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o1)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
class get_table_meta_args:
"""
Attributes:
@@@ -14900,10 -14914,10 +15146,10 @@@
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
-- (_etype648, _size645) = iprot.readListBegin()
-- for _i649 in xrange(_size645):
-- _elem650 = iprot.readString()
-- self.tbl_types.append(_elem650)
++ (_etype655, _size652) = iprot.readListBegin()
++ for _i656 in xrange(_size652):
++ _elem657 = iprot.readString()
++ self.tbl_types.append(_elem657)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -14928,8 -14942,8 +15174,8 @@@
if self.tbl_types is not None:
oprot.writeFieldBegin('tbl_types', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.tbl_types))
-- for iter651 in self.tbl_types:
-- oprot.writeString(iter651)
++ for iter658 in self.tbl_types:
++ oprot.writeString(iter658)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -14985,11 -14999,11 +15231,11 @@@ class get_table_meta_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype655, _size652) = iprot.readListBegin()
-- for _i656 in xrange(_size652):
-- _elem657 = TableMeta()
-- _elem657.read(iprot)
-- self.success.append(_elem657)
++ (_etype662, _size659) = iprot.readListBegin()
++ for _i663 in xrange(_size659):
++ _elem664 = TableMeta()
++ _elem664.read(iprot)
++ self.success.append(_elem664)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -15012,8 -15026,8 +15258,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter658 in self.success:
-- iter658.write(oprot)
++ for iter665 in self.success:
++ iter665.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -15137,10 -15151,10 +15383,10 @@@ class get_all_tables_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype662, _size659) = iprot.readListBegin()
-- for _i663 in xrange(_size659):
-- _elem664 = iprot.readString()
-- self.success.append(_elem664)
++ (_etype669, _size666) = iprot.readListBegin()
++ for _i670 in xrange(_size666):
++ _elem671 = iprot.readString()
++ self.success.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -15163,8 -15177,8 +15409,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter665 in self.success:
-- oprot.writeString(iter665)
++ for iter672 in self.success:
++ oprot.writeString(iter672)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -15400,10 -15414,10 +15646,10 @@@ class get_table_objects_by_name_args
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
-- (_etype669, _size666) = iprot.readListBegin()
-- for _i670 in xrange(_size666):
-- _elem671 = iprot.readString()
-- self.tbl_names.append(_elem671)
++ (_etype676, _size673) = iprot.readListBegin()
++ for _i677 in xrange(_size673):
++ _elem678 = iprot.readString()
++ self.tbl_names.append(_elem678)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -15424,8 -15438,8 +15670,8 @@@
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
-- for iter672 in self.tbl_names:
-- oprot.writeString(iter672)
++ for iter679 in self.tbl_names:
++ oprot.writeString(iter679)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -15486,11 -15500,11 +15732,11 @@@ class get_table_objects_by_name_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype676, _size673) = iprot.readListBegin()
-- for _i677 in xrange(_size673):
-- _elem678 = Table()
-- _elem678.read(iprot)
-- self.success.append(_elem678)
++ (_etype683, _size680) = iprot.readListBegin()
++ for _i684 in xrange(_size680):
++ _elem685 = Table()
++ _elem685.read(iprot)
++ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -15525,8 -15539,8 +15771,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter679 in self.success:
-- iter679.write(oprot)
++ for iter686 in self.success:
++ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -15692,10 -15706,10 +15938,10 @@@ class get_table_names_by_filter_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype683, _size680) = iprot.readListBegin()
-- for _i684 in xrange(_size680):
-- _elem685 = iprot.readString()
-- self.success.append(_elem685)
++ (_etype690, _size687) = iprot.readListBegin()
++ for _i691 in xrange(_size687):
++ _elem692 = iprot.readString()
++ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -15730,8 -15744,8 +15976,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter686 in self.success:
-- oprot.writeString(iter686)
++ for iter693 in self.success:
++ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -16701,11 -16715,11 +16947,11 @@@ class add_partitions_args
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
-- (_etype690, _size687) = iprot.readListBegin()
-- for _i691 in xrange(_size687):
-- _elem692 = Partition()
-- _elem692.read(iprot)
-- self.new_parts.append(_elem692)
++ (_etype697, _size694) = iprot.readListBegin()
++ for _i698 in xrange(_size694):
++ _elem699 = Partition()
++ _elem699.read(iprot)
++ self.new_parts.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -16722,8 -16736,8 +16968,8 @@@
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
-- for iter693 in self.new_parts:
-- iter693.write(oprot)
++ for iter700 in self.new_parts:
++ iter700.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -16881,11 -16895,11 +17127,11 @@@ class add_partitions_pspec_args
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
-- (_etype697, _size694) = iprot.readListBegin()
-- for _i698 in xrange(_size694):
-- _elem699 = PartitionSpec()
-- _elem699.read(iprot)
-- self.new_parts.append(_elem699)
++ (_etype704, _size701) = iprot.readListBegin()
++ for _i705 in xrange(_size701):
++ _elem706 = PartitionSpec()
++ _elem706.read(iprot)
++ self.new_parts.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -16902,8 -16916,8 +17148,8 @@@
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
-- for iter700 in self.new_parts:
-- iter700.write(oprot)
++ for iter707 in self.new_parts:
++ iter707.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -17077,10 -17091,10 +17323,10 @@@ class append_partition_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype704, _size701) = iprot.readListBegin()
-- for _i705 in xrange(_size701):
-- _elem706 = iprot.readString()
-- self.part_vals.append(_elem706)
++ (_etype711, _size708) = iprot.readListBegin()
++ for _i712 in xrange(_size708):
++ _elem713 = iprot.readString()
++ self.part_vals.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -17105,8 -17119,8 +17351,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter707 in self.part_vals:
-- oprot.writeString(iter707)
++ for iter714 in self.part_vals:
++ oprot.writeString(iter714)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -17459,10 -17473,10 +17705,10 @@@ class append_partition_with_environment
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype711, _size708) = iprot.readListBegin()
-- for _i712 in xrange(_size708):
-- _elem713 = iprot.readString()
-- self.part_vals.append(_elem713)
++ (_etype718, _size715) = iprot.readListBegin()
++ for _i719 in xrange(_size715):
++ _elem720 = iprot.readString()
++ self.part_vals.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -17493,8 -17507,8 +17739,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter714 in self.part_vals:
-- oprot.writeString(iter714)
++ for iter721 in self.part_vals:
++ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@@ -18089,10 -18103,10 +18335,10 @@@ class drop_partition_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype718, _size715) = iprot.readListBegin()
-- for _i719 in xrange(_size715):
-- _elem720 = iprot.readString()
-- self.part_vals.append(_elem720)
++ (_etype725, _size722) = iprot.readListBegin()
++ for _i726 in xrange(_size722):
++ _elem727 = iprot.readString()
++ self.part_vals.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -18122,8 -18136,8 +18368,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter721 in self.part_vals:
-- oprot.writeString(iter721)
++ for iter728 in self.part_vals:
++ oprot.writeString(iter728)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@@ -18296,10 -18310,10 +18542,10 @@@ class drop_partition_with_environment_c
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype725, _size722) = iprot.readListBegin()
-- for _i726 in xrange(_size722):
-- _elem727 = iprot.readString()
-- self.part_vals.append(_elem727)
++ (_etype732, _size729) = iprot.readListBegin()
++ for _i733 in xrange(_size729):
++ _elem734 = iprot.readString()
++ self.part_vals.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -18335,8 -18349,8 +18581,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter728 in self.part_vals:
-- oprot.writeString(iter728)
++ for iter735 in self.part_vals:
++ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@@ -19073,10 -19087,10 +19319,10 @@@ class get_partition_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype732, _size729) = iprot.readListBegin()
-- for _i733 in xrange(_size729):
-- _elem734 = iprot.readString()
-- self.part_vals.append(_elem734)
++ (_etype739, _size736) = iprot.readListBegin()
++ for _i740 in xrange(_size736):
++ _elem741 = iprot.readString()
++ self.part_vals.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -19101,8 -19115,8 +19347,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter735 in self.part_vals:
-- oprot.writeString(iter735)
++ for iter742 in self.part_vals:
++ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -19261,11 -19275,11 +19507,11 @@@ class exchange_partition_args
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
-- (_ktype737, _vtype738, _size736 ) = iprot.readMapBegin()
-- for _i740 in xrange(_size736):
-- _key741 = iprot.readString()
-- _val742 = iprot.readString()
-- self.partitionSpecs[_key741] = _val742
++ (_ktype744, _vtype745, _size743 ) = iprot.readMapBegin()
++ for _i747 in xrange(_size743):
++ _key748 = iprot.readString()
++ _val749 = iprot.readString()
++ self.partitionSpecs[_key748] = _val749
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@@ -19302,9 -19316,9 +19548,9 @@@
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
-- for kiter743,viter744 in self.partitionSpecs.items():
-- oprot.writeString(kiter743)
-- oprot.writeString(viter744)
++ for kiter750,viter751 in self.partitionSpecs.items():
++ oprot.writeString(kiter750)
++ oprot.writeString(viter751)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@@ -19509,11 -19523,11 +19755,11 @@@ class exchange_partitions_args
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
-- (_ktype746, _vtype747, _size745 ) = iprot.readMapBegin()
-- for _i749 in xrange(_size745):
-- _key750 = iprot.readString()
-- _val751 = iprot.readString()
-- self.partitionSpecs[_key750] = _val751
++ (_ktype753, _vtype754, _size752 ) = iprot.readMapBegin()
++ for _i756 in xrange(_size752):
++ _key757 = iprot.readString()
++ _val758 = iprot.readString()
++ self.partitionSpecs[_key757] = _val758
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@@ -19550,9 -19564,9 +19796,9 @@@
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
-- for kiter752,viter753 in self.partitionSpecs.items():
-- oprot.writeString(kiter752)
-- oprot.writeString(viter753)
++ for kiter759,viter760 in self.partitionSpecs.items():
++ oprot.writeString(kiter759)
++ oprot.writeString(viter760)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@@ -19635,11 -19649,11 +19881,11 @@@ class exchange_partitions_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype757, _size754) = iprot.readListBegin()
-- for _i758 in xrange(_size754):
-- _elem759 = Partition()
-- _elem759.read(iprot)
-- self.success.append(_elem759)
++ (_etype764, _size761) = iprot.readListBegin()
++ for _i765 in xrange(_size761):
++ _elem766 = Partition()
++ _elem766.read(iprot)
++ self.success.append(_elem766)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -19680,8 -19694,8 +19926,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter760 in self.success:
-- iter760.write(oprot)
++ for iter767 in self.success:
++ iter767.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -19775,10 -19789,10 +20021,10 @@@ class get_partition_with_auth_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype764, _size761) = iprot.readListBegin()
-- for _i765 in xrange(_size761):
-- _elem766 = iprot.readString()
-- self.part_vals.append(_elem766)
++ (_etype771, _size768) = iprot.readListBegin()
++ for _i772 in xrange(_size768):
++ _elem773 = iprot.readString()
++ self.part_vals.append(_elem773)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -19790,10 -19804,10 +20036,10 @@@
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
-- (_etype770, _size767) = iprot.readListBegin()
-- for _i771 in xrange(_size767):
-- _elem772 = iprot.readString()
-- self.group_names.append(_elem772)
++ (_etype777, _size774) = iprot.readListBegin()
++ for _i778 in xrange(_size774):
++ _elem779 = iprot.readString()
++ self.group_names.append(_elem779)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -19818,8 -19832,8 +20064,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter773 in self.part_vals:
-- oprot.writeString(iter773)
++ for iter780 in self.part_vals:
++ oprot.writeString(iter780)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@@ -19829,8 -19843,8 +20075,8 @@@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
-- for iter774 in self.group_names:
-- oprot.writeString(iter774)
++ for iter781 in self.group_names:
++ oprot.writeString(iter781)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -20259,11 -20273,11 +20505,11 @@@ class get_partitions_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype778, _size775) = iprot.readListBegin()
-- for _i779 in xrange(_size775):
-- _elem780 = Partition()
-- _elem780.read(iprot)
-- self.success.append(_elem780)
++ (_etype785, _size782) = iprot.readListBegin()
++ for _i786 in xrange(_size782):
++ _elem787 = Partition()
++ _elem787.read(iprot)
++ self.success.append(_elem787)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -20292,8 -20306,8 +20538,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter781 in self.success:
-- iter781.write(oprot)
++ for iter788 in self.success:
++ iter788.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -20387,10 -20401,10 +20633,10 @@@ class get_partitions_with_auth_args
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
-- (_etype785, _size782) = iprot.readListBegin()
-- for _i786 in xrange(_size782):
-- _elem787 = iprot.readString()
-- self.group_names.append(_elem787)
++ (_etype792, _size789) = iprot.readListBegin()
++ for _i793 in xrange(_size789):
++ _elem794 = iprot.readString()
++ self.group_names.append(_elem794)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -20423,8 -20437,8 +20669,8 @@@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
-- for iter788 in self.group_names:
-- oprot.writeString(iter788)
++ for iter795 in self.group_names:
++ oprot.writeString(iter795)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -20485,11 -20499,11 +20731,11 @@@ class get_partitions_with_auth_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype792, _size789) = iprot.readListBegin()
-- for _i793 in xrange(_size789):
-- _elem794 = Partition()
-- _elem794.read(iprot)
-- self.success.append(_elem794)
++ (_etype799, _size796) = iprot.readListBegin()
++ for _i800 in xrange(_size796):
++ _elem801 = Partition()
++ _elem801.read(iprot)
++ self.success.append(_elem801)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -20518,8 -20532,8 +20764,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter795 in self.success:
-- iter795.write(oprot)
++ for iter802 in self.success:
++ iter802.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -20677,11 -20691,11 +20923,11 @@@ class get_partitions_pspec_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype799, _size796) = iprot.readListBegin()
-- for _i800 in xrange(_size796):
-- _elem801 = PartitionSpec()
-- _elem801.read(iprot)
-- self.success.append(_elem801)
++ (_etype806, _size803) = iprot.readListBegin()
++ for _i807 in xrange(_size803):
++ _elem808 = PartitionSpec()
++ _elem808.read(iprot)
++ self.success.append(_elem808)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -20710,8 -20724,8 +20956,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter802 in self.success:
-- iter802.write(oprot)
++ for iter809 in self.success:
++ iter809.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -20866,10 -20880,10 +21112,10 @@@ class get_partition_names_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype806, _size803) = iprot.readListBegin()
-- for _i807 in xrange(_size803):
-- _elem808 = iprot.readString()
-- self.success.append(_elem808)
++ (_etype813, _size810) = iprot.readListBegin()
++ for _i814 in xrange(_size810):
++ _elem815 = iprot.readString()
++ self.success.append(_elem815)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -20892,8 -20906,8 +21138,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter809 in self.success:
-- oprot.writeString(iter809)
++ for iter816 in self.success:
++ oprot.writeString(iter816)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@@ -20969,10 -20983,10 +21215,10 @@@ class get_partitions_ps_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype813, _size810) = iprot.readListBegin()
-- for _i814 in xrange(_size810):
-- _elem815 = iprot.readString()
-- self.part_vals.append(_elem815)
++ (_etype820, _size817) = iprot.readListBegin()
++ for _i821 in xrange(_size817):
++ _elem822 = iprot.readString()
++ self.part_vals.append(_elem822)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21002,8 -21016,8 +21248,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter816 in self.part_vals:
-- oprot.writeString(iter816)
++ for iter823 in self.part_vals:
++ oprot.writeString(iter823)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@@ -21067,11 -21081,11 +21313,11 @@@ class get_partitions_ps_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype820, _size817) = iprot.readListBegin()
-- for _i821 in xrange(_size817):
-- _elem822 = Partition()
-- _elem822.read(iprot)
-- self.success.append(_elem822)
++ (_etype827, _size824) = iprot.readListBegin()
++ for _i828 in xrange(_size824):
++ _elem829 = Partition()
++ _elem829.read(iprot)
++ self.success.append(_elem829)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21100,8 -21114,8 +21346,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter823 in self.success:
-- iter823.write(oprot)
++ for iter830 in self.success:
++ iter830.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -21188,10 -21202,10 +21434,10 @@@ class get_partitions_ps_with_auth_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype827, _size824) = iprot.readListBegin()
-- for _i828 in xrange(_size824):
-- _elem829 = iprot.readString()
-- self.part_vals.append(_elem829)
++ (_etype834, _size831) = iprot.readListBegin()
++ for _i835 in xrange(_size831):
++ _elem836 = iprot.readString()
++ self.part_vals.append(_elem836)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21208,10 -21222,10 +21454,10 @@@
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
-- (_etype833, _size830) = iprot.readListBegin()
-- for _i834 in xrange(_size830):
-- _elem835 = iprot.readString()
-- self.group_names.append(_elem835)
++ (_etype840, _size837) = iprot.readListBegin()
++ for _i841 in xrange(_size837):
++ _elem842 = iprot.readString()
++ self.group_names.append(_elem842)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21236,8 -21250,8 +21482,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter836 in self.part_vals:
-- oprot.writeString(iter836)
++ for iter843 in self.part_vals:
++ oprot.writeString(iter843)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@@ -21251,8 -21265,8 +21497,8 @@@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 6)
oprot.writeListBegin(TType.STRING, len(self.group_names))
-- for iter837 in self.group_names:
-- oprot.writeString(iter837)
++ for iter844 in self.group_names:
++ oprot.writeString(iter844)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -21314,11 -21328,11 +21560,11 @@@ class get_partitions_ps_with_auth_resul
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype841, _size838) = iprot.readListBegin()
-- for _i842 in xrange(_size838):
-- _elem843 = Partition()
-- _elem843.read(iprot)
-- self.success.append(_elem843)
++ (_etype848, _size845) = iprot.readListBegin()
++ for _i849 in xrange(_size845):
++ _elem850 = Partition()
++ _elem850.read(iprot)
++ self.success.append(_elem850)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21347,8 -21361,8 +21593,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter844 in self.success:
-- iter844.write(oprot)
++ for iter851 in self.success:
++ iter851.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -21429,10 -21443,10 +21675,10 @@@ class get_partition_names_ps_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype848, _size845) = iprot.readListBegin()
-- for _i849 in xrange(_size845):
-- _elem850 = iprot.readString()
-- self.part_vals.append(_elem850)
++ (_etype855, _size852) = iprot.readListBegin()
++ for _i856 in xrange(_size852):
++ _elem857 = iprot.readString()
++ self.part_vals.append(_elem857)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21462,8 -21476,8 +21708,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter851 in self.part_vals:
-- oprot.writeString(iter851)
++ for iter858 in self.part_vals:
++ oprot.writeString(iter858)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@@ -21527,10 -21541,10 +21773,10 @@@ class get_partition_names_ps_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype855, _size852) = iprot.readListBegin()
-- for _i856 in xrange(_size852):
-- _elem857 = iprot.readString()
-- self.success.append(_elem857)
++ (_etype862, _size859) = iprot.readListBegin()
++ for _i863 in xrange(_size859):
++ _elem864 = iprot.readString()
++ self.success.append(_elem864)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21559,8 -21573,8 +21805,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter858 in self.success:
-- oprot.writeString(iter858)
++ for iter865 in self.success:
++ oprot.writeString(iter865)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -21731,11 -21745,11 +21977,11 @@@ class get_partitions_by_filter_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype862, _size859) = iprot.readListBegin()
-- for _i863 in xrange(_size859):
-- _elem864 = Partition()
-- _elem864.read(iprot)
-- self.success.append(_elem864)
++ (_etype869, _size866) = iprot.readListBegin()
++ for _i870 in xrange(_size866):
++ _elem871 = Partition()
++ _elem871.read(iprot)
++ self.success.append(_elem871)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21764,8 -21778,8 +22010,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter865 in self.success:
-- iter865.write(oprot)
++ for iter872 in self.success:
++ iter872.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -21936,11 -21950,11 +22182,11 @@@ class get_part_specs_by_filter_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype869, _size866) = iprot.readListBegin()
-- for _i870 in xrange(_size866):
-- _elem871 = PartitionSpec()
-- _elem871.read(iprot)
-- self.success.append(_elem871)
++ (_etype876, _size873) = iprot.readListBegin()
++ for _i877 in xrange(_size873):
++ _elem878 = PartitionSpec()
++ _elem878.read(iprot)
++ self.success.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -21969,8 -21983,8 +22215,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter872 in self.success:
-- iter872.write(oprot)
++ for iter879 in self.success:
++ iter879.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -22390,10 -22404,10 +22636,10 @@@ class get_partitions_by_names_args
elif fid == 3:
if ftype == TType.LIST:
self.names = []
-- (_etype876, _size873) = iprot.readListBegin()
-- for _i877 in xrange(_size873):
-- _elem878 = iprot.readString()
-- self.names.append(_elem878)
++ (_etype883, _size880) = iprot.readListBegin()
++ for _i884 in xrange(_size880):
++ _elem885 = iprot.readString()
++ self.names.append(_elem885)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -22418,8 -22432,8 +22664,8 @@@
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.names))
-- for iter879 in self.names:
-- oprot.writeString(iter879)
++ for iter886 in self.names:
++ oprot.writeString(iter886)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -22478,11 -22492,11 +22724,11 @@@ class get_partitions_by_names_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype883, _size880) = iprot.readListBegin()
-- for _i884 in xrange(_size880):
-- _elem885 = Partition()
-- _elem885.read(iprot)
-- self.success.append(_elem885)
++ (_etype890, _size887) = iprot.readListBegin()
++ for _i891 in xrange(_size887):
++ _elem892 = Partition()
++ _elem892.read(iprot)
++ self.success.append(_elem892)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -22511,8 -22525,8 +22757,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter886 in self.success:
-- iter886.write(oprot)
++ for iter893 in self.success:
++ iter893.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -22762,11 -22776,11 +23008,11 @@@ class alter_partitions_args
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
-- (_etype890, _size887) = iprot.readListBegin()
-- for _i891 in xrange(_size887):
-- _elem892 = Partition()
-- _elem892.read(iprot)
-- self.new_parts.append(_elem892)
++ (_etype897, _size894) = iprot.readListBegin()
++ for _i898 in xrange(_size894):
++ _elem899 = Partition()
++ _elem899.read(iprot)
++ self.new_parts.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -22791,8 -22805,8 +23037,8 @@@
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
-- for iter893 in self.new_parts:
-- iter893.write(oprot)
++ for iter900 in self.new_parts:
++ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -22945,11 -22959,11 +23191,11 @@@ class alter_partitions_with_environment
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
-- (_etype897, _size894) = iprot.readListBegin()
-- for _i898 in xrange(_size894):
-- _elem899 = Partition()
-- _elem899.read(iprot)
-- self.new_parts.append(_elem899)
++ (_etype904, _size901) = iprot.readListBegin()
++ for _i905 in xrange(_size901):
++ _elem906 = Partition()
++ _elem906.read(iprot)
++ self.new_parts.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -22980,8 -22994,8 +23226,8 @@@
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
-- for iter900 in self.new_parts:
-- iter900.write(oprot)
++ for iter907 in self.new_parts:
++ iter907.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@@ -23325,10 -23339,10 +23571,10 @@@ class rename_partition_args
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype904, _size901) = iprot.readListBegin()
-- for _i905 in xrange(_size901):
-- _elem906 = iprot.readString()
-- self.part_vals.append(_elem906)
++ (_etype911, _size908) = iprot.readListBegin()
++ for _i912 in xrange(_size908):
++ _elem913 = iprot.readString()
++ self.part_vals.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -23359,8 -23373,8 +23605,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter907 in self.part_vals:
-- oprot.writeString(iter907)
++ for iter914 in self.part_vals:
++ oprot.writeString(iter914)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@@ -23502,10 -23516,10 +23748,10 @@@ class partition_name_has_valid_characte
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
-- (_etype911, _size908) = iprot.readListBegin()
-- for _i912 in xrange(_size908):
-- _elem913 = iprot.readString()
-- self.part_vals.append(_elem913)
++ (_etype918, _size915) = iprot.readListBegin()
++ for _i919 in xrange(_size915):
++ _elem920 = iprot.readString()
++ self.part_vals.append(_elem920)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -23527,8 -23541,8 +23773,8 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
-- for iter914 in self.part_vals:
-- oprot.writeString(iter914)
++ for iter921 in self.part_vals:
++ oprot.writeString(iter921)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@@ -23886,10 -23900,10 +24132,10 @@@ class partition_name_to_vals_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype918, _size915) = iprot.readListBegin()
-- for _i919 in xrange(_size915):
-- _elem920 = iprot.readString()
-- self.success.append(_elem920)
++ (_etype925, _size922) = iprot.readListBegin()
++ for _i926 in xrange(_size922):
++ _elem927 = iprot.readString()
++ self.success.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -23912,8 -23926,8 +24158,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter921 in self.success:
-- oprot.writeString(iter921)
++ for iter928 in self.success:
++ oprot.writeString(iter928)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -24037,11 -24051,11 +24283,11 @@@ class partition_name_to_spec_result
if fid == 0:
if ftype == TType.MAP:
self.success = {}
-- (_ktype923, _vtype924, _size922 ) = iprot.readMapBegin()
-- for _i926 in xrange(_size922):
-- _key927 = iprot.readString()
-- _val928 = iprot.readString()
-- self.success[_key927] = _val928
++ (_ktype930, _vtype931, _size929 ) = iprot.readMapBegin()
++ for _i933 in xrange(_size929):
++ _key934 = iprot.readString()
++ _val935 = iprot.readString()
++ self.success[_key934] = _val935
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@@ -24064,9 -24078,9 +24310,9 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
-- for kiter929,viter930 in self.success.items():
-- oprot.writeString(kiter929)
-- oprot.writeString(viter930)
++ for kiter936,viter937 in self.success.items():
++ oprot.writeString(kiter936)
++ oprot.writeString(viter937)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -24142,11 -24156,11 +24388,11 @@@ class markPartitionForEvent_args
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
-- (_ktype932, _vtype933, _size931 ) = iprot.readMapBegin()
-- for _i935 in xrange(_size931):
-- _key936 = iprot.readString()
-- _val937 = iprot.readString()
-- self.part_vals[_key936] = _val937
++ (_ktype939, _vtype940, _size938 ) = iprot.readMapBegin()
++ for _i942 in xrange(_size938):
++ _key943 = iprot.readString()
++ _val944 = iprot.readString()
++ self.part_vals[_key943] = _val944
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@@ -24176,9 -24190,9 +24422,9 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
-- for kiter938,viter939 in self.part_vals.items():
-- oprot.writeString(kiter938)
-- oprot.writeString(viter939)
++ for kiter945,viter946 in self.part_vals.items():
++ oprot.writeString(kiter945)
++ oprot.writeString(viter946)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@@ -24392,11 -24406,11 +24638,11 @@@ class isPartitionMarkedForEvent_args
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
-- (_ktype941, _vtype942, _size940 ) = iprot.readMapBegin()
-- for _i944 in xrange(_size940):
-- _key945 = iprot.readString()
-- _val946 = iprot.readString()
-- self.part_vals[_key945] = _val946
++ (_ktype948, _vtype949, _size947 ) = iprot.readMapBegin()
++ for _i951 in xrange(_size947):
++ _key952 = iprot.readString()
++ _val953 = iprot.readString()
++ self.part_vals[_key952] = _val953
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@@ -24426,9 -24440,9 +24672,9 @@@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
-- for kiter947,viter948 in self.part_vals.items():
-- oprot.writeString(kiter947)
-- oprot.writeString(viter948)
++ for kiter954,viter955 in self.part_vals.items():
++ oprot.writeString(kiter954)
++ oprot.writeString(viter955)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@@ -25483,11 -25497,11 +25729,11 @@@ class get_indexes_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype952, _size949) = iprot.readListBegin()
-- for _i953 in xrange(_size949):
-- _elem954 = Index()
-- _elem954.read(iprot)
-- self.success.append(_elem954)
++ (_etype959, _size956) = iprot.readListBegin()
++ for _i960 in xrange(_size956):
++ _elem961 = Index()
++ _elem961.read(iprot)
++ self.success.append(_elem961)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -25516,8 -25530,8 +25762,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter955 in self.success:
-- iter955.write(oprot)
++ for iter962 in self.success:
++ iter962.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -25672,10 -25686,10 +25918,10 @@@ class get_index_names_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype959, _size956) = iprot.readListBegin()
-- for _i960 in xrange(_size956):
-- _elem961 = iprot.readString()
-- self.success.append(_elem961)
++ (_etype966, _size963) = iprot.readListBegin()
++ for _i967 in xrange(_size963):
++ _elem968 = iprot.readString()
++ self.success.append(_elem968)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -25698,8 -25712,8 +25944,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter962 in self.success:
-- oprot.writeString(iter962)
++ for iter969 in self.success:
++ oprot.writeString(iter969)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@@ -28565,10 -28579,10 +28811,10 @@@ class get_functions_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype966, _size963) = iprot.readListBegin()
-- for _i967 in xrange(_size963):
-- _elem968 = iprot.readString()
-- self.success.append(_elem968)
++ (_etype973, _size970) = iprot.readListBegin()
++ for _i974 in xrange(_size970):
++ _elem975 = iprot.readString()
++ self.success.append(_elem975)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -28591,8 -28605,8 +28837,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter969 in self.success:
-- oprot.writeString(iter969)
++ for iter976 in self.success:
++ oprot.writeString(iter976)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -29280,10 -29294,10 +29526,10 @@@ class get_role_names_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype973, _size970) = iprot.readListBegin()
-- for _i974 in xrange(_size970):
-- _elem975 = iprot.readString()
-- self.success.append(_elem975)
++ (_etype980, _size977) = iprot.readListBegin()
++ for _i981 in xrange(_size977):
++ _elem982 = iprot.readString()
++ self.success.append(_elem982)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -29306,8 -29320,8 +29552,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter976 in self.success:
-- oprot.writeString(iter976)
++ for iter983 in self.success:
++ oprot.writeString(iter983)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -29821,11 -29835,11 +30067,11 @@@ class list_roles_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype980, _size977) = iprot.readListBegin()
-- for _i981 in xrange(_size977):
-- _elem982 = Role()
-- _elem982.read(iprot)
-- self.success.append(_elem982)
++ (_etype987, _size984) = iprot.readListBegin()
++ for _i988 in xrange(_size984):
++ _elem989 = Role()
++ _elem989.read(iprot)
++ self.success.append(_elem989)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -29848,8 -29862,8 +30094,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter983 in self.success:
-- iter983.write(oprot)
++ for iter990 in self.success:
++ iter990.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -30358,10 -30372,10 +30604,10 @@@ class get_privilege_set_args
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
-- (_etype987, _size984) = iprot.readListBegin()
-- for _i988 in xrange(_size984):
-- _elem989 = iprot.readString()
-- self.group_names.append(_elem989)
++ (_etype994, _size991) = iprot.readListBegin()
++ for _i995 in xrange(_size991):
++ _elem996 = iprot.readString()
++ self.group_names.append(_elem996)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -30386,8 -30400,8 +30632,8 @@@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
-- for iter990 in self.group_names:
-- oprot.writeString(iter990)
++ for iter997 in self.group_names:
++ oprot.writeString(iter997)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -30614,11 -30628,11 +30860,11 @@@ class list_privileges_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype994, _size991) = iprot.readListBegin()
-- for _i995 in xrange(_size991):
-- _elem996 = HiveObjectPrivilege()
-- _elem996.read(iprot)
-- self.success.append(_elem996)
++ (_etype1001, _size998) = iprot.readListBegin()
++ for _i1002 in xrange(_size998):
++ _elem1003 = HiveObjectPrivilege()
++ _elem1003.read(iprot)
++ self.success.append(_elem1003)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -30641,8 -30655,8 +30887,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter997 in self.success:
-- iter997.write(oprot)
++ for iter1004 in self.success:
++ iter1004.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -31140,10 -31154,10 +31386,10 @@@ class set_ugi_args
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
-- (_etype1001, _size998) = iprot.readListBegin()
-- for _i1002 in xrange(_size998):
-- _elem1003 = iprot.readString()
-- self.group_names.append(_elem1003)
++ (_etype1008, _size1005) = iprot.readListBegin()
++ for _i1009 in xrange(_size1005):
++ _elem1010 = iprot.readString()
++ self.group_names.append(_elem1010)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -31164,8 -31178,8 +31410,8 @@@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
-- for iter1004 in self.group_names:
-- oprot.writeString(iter1004)
++ for iter1011 in self.group_names:
++ oprot.writeString(iter1011)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -31220,10 -31234,10 +31466,10 @@@ class set_ugi_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype1008, _size1005) = iprot.readListBegin()
-- for _i1009 in xrange(_size1005):
-- _elem1010 = iprot.readString()
-- self.success.append(_elem1010)
++ (_etype1015, _size1012) = iprot.readListBegin()
++ for _i1016 in xrange(_size1012):
++ _elem1017 = iprot.readString()
++ self.success.append(_elem1017)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -31246,8 -31260,8 +31492,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter1011 in self.success:
-- oprot.writeString(iter1011)
++ for iter1018 in self.success:
++ oprot.writeString(iter1018)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@@ -32179,10 -32193,10 +32425,10 @@@ class get_all_token_identifiers_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype1015, _size1012) = iprot.readListBegin()
-- for _i1016 in xrange(_size1012):
-- _elem1017 = iprot.readString()
-- self.success.append(_elem1017)
++ (_etype1022, _size1019) = iprot.readListBegin()
++ for _i1023 in xrange(_size1019):
++ _elem1024 = iprot.readString()
++ self.success.append(_elem1024)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -32199,8 -32213,8 +32445,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter1018 in self.success:
-- oprot.writeString(iter1018)
++ for iter1025 in self.success:
++ oprot.writeString(iter1025)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@@ -32727,10 -32741,10 +32973,10 @@@ class get_master_keys_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype1022, _size1019) = iprot.readListBegin()
-- for _i1023 in xrange(_size1019):
-- _elem1024 = iprot.readString()
-- self.success.append(_elem1024)
++ (_etype1029, _size1026) = iprot.readListBegin()
++ for _i1030 in xrange(_size1026):
++ _elem1031 = iprot.readString()
++ self.success.append(_elem1031)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -32747,8 -32761,8 +32993,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
-- for iter1025 in self.success:
-- oprot.writeString(iter1025)
++ for iter1032 in self.success:
++ oprot.writeString(iter1032)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
----------------------------------------------------------------------
diff --cc metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
index 0e7bdf2,530d2f4..9f16eb2
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
@@@ -47,7 -47,9 +47,8 @@@ import org.apache.hadoop.hive.common.me
import org.apache.hadoop.hive.common.metrics.common.MetricsVariable;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
+ import org.apache.hadoop.hive.metastore.TableType;
import org.apache.hadoop.hive.metastore.api.*;
-import org.apache.hadoop.hive.metastore.api.Table;
import org.apache.hadoop.hive.metastore.events.AddIndexEvent;
import org.apache.hadoop.hive.metastore.events.AddPartitionEvent;
import org.apache.hadoop.hive.metastore.events.AlterIndexEvent;
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
----------------------------------------------------------------------
diff --cc metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index 0325854,c32486f..73e14c4
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@@ -27,7 -27,105 +27,8 @@@ import org.apache.hadoop.hive.common.cl
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
import org.apache.hadoop.hive.conf.HiveConfUtil;
+import org.apache.hadoop.hive.metastore.api.*;
+ import org.apache.hadoop.hive.metastore.TableType;
-import org.apache.hadoop.hive.metastore.api.AbortTxnRequest;
-import org.apache.hadoop.hive.metastore.api.AbortTxnsRequest;
-import org.apache.hadoop.hive.metastore.api.AddDynamicPartitions;
-import org.apache.hadoop.hive.metastore.api.AddForeignKeyRequest;
-import org.apache.hadoop.hive.metastore.api.AddPartitionsRequest;
-import org.apache.hadoop.hive.metastore.api.AddPartitionsResult;
-import org.apache.hadoop.hive.metastore.api.AddPrimaryKeyRequest;
-import org.apache.hadoop.hive.metastore.api.AggrStats;
-import org.apache.hadoop.hive.metastore.api.AlreadyExistsException;
-import org.apache.hadoop.hive.metastore.api.CacheFileMetadataRequest;
-import org.apache.hadoop.hive.metastore.api.CacheFileMetadataResult;
-import org.apache.hadoop.hive.metastore.api.CheckLockRequest;
-import org.apache.hadoop.hive.metastore.api.ClearFileMetadataRequest;
-import org.apache.hadoop.hive.metastore.api.ColumnStatistics;
-import org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj;
-import org.apache.hadoop.hive.metastore.api.CommitTxnRequest;
-import org.apache.hadoop.hive.metastore.api.CompactionRequest;
-import org.apache.hadoop.hive.metastore.api.CompactionType;
-import org.apache.hadoop.hive.metastore.api.ConfigValSecurityException;
-import org.apache.hadoop.hive.metastore.api.CurrentNotificationEventId;
-import org.apache.hadoop.hive.metastore.api.DataOperationType;
-import org.apache.hadoop.hive.metastore.api.Database;
-import org.apache.hadoop.hive.metastore.api.DropConstraintRequest;
-import org.apache.hadoop.hive.metastore.api.DropPartitionsExpr;
-import org.apache.hadoop.hive.metastore.api.DropPartitionsRequest;
-import org.apache.hadoop.hive.metastore.api.EnvironmentContext;
-import org.apache.hadoop.hive.metastore.api.FieldSchema;
-import org.apache.hadoop.hive.metastore.api.FireEventRequest;
-import org.apache.hadoop.hive.metastore.api.FireEventResponse;
-import org.apache.hadoop.hive.metastore.api.ForeignKeysRequest;
-import org.apache.hadoop.hive.metastore.api.Function;
-import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse;
-import org.apache.hadoop.hive.metastore.api.GetFileMetadataByExprRequest;
-import org.apache.hadoop.hive.metastore.api.GetFileMetadataByExprResult;
-import org.apache.hadoop.hive.metastore.api.GetFileMetadataRequest;
-import org.apache.hadoop.hive.metastore.api.GetFileMetadataResult;
-import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse;
-import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest;
-import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleResponse;
-import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalRequest;
-import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalResponse;
-import org.apache.hadoop.hive.metastore.api.GrantRevokePrivilegeRequest;
-import org.apache.hadoop.hive.metastore.api.GrantRevokePrivilegeResponse;
-import org.apache.hadoop.hive.metastore.api.GrantRevokeRoleRequest;
-import org.apache.hadoop.hive.metastore.api.GrantRevokeRoleResponse;
-import org.apache.hadoop.hive.metastore.api.GrantRevokeType;
-import org.apache.hadoop.hive.metastore.api.HeartbeatRequest;
-import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeRequest;
-import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeResponse;
-import org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege;
-import org.apache.hadoop.hive.metastore.api.HiveObjectRef;
-import org.apache.hadoop.hive.metastore.api.Index;
-import org.apache.hadoop.hive.metastore.api.InvalidInputException;
-import org.apache.hadoop.hive.metastore.api.InvalidObjectException;
-import org.apache.hadoop.hive.metastore.api.InvalidOperationException;
-import org.apache.hadoop.hive.metastore.api.InvalidPartitionException;
-import org.apache.hadoop.hive.metastore.api.LockRequest;
-import org.apache.hadoop.hive.metastore.api.LockResponse;
-import org.apache.hadoop.hive.metastore.api.MetaException;
-import org.apache.hadoop.hive.metastore.api.MetadataPpdResult;
-import org.apache.hadoop.hive.metastore.api.NoSuchLockException;
-import org.apache.hadoop.hive.metastore.api.NoSuchObjectException;
-import org.apache.hadoop.hive.metastore.api.NoSuchTxnException;
-import org.apache.hadoop.hive.metastore.api.NotificationEvent;
-import org.apache.hadoop.hive.metastore.api.NotificationEventRequest;
-import org.apache.hadoop.hive.metastore.api.NotificationEventResponse;
-import org.apache.hadoop.hive.metastore.api.OpenTxnRequest;
-import org.apache.hadoop.hive.metastore.api.OpenTxnsResponse;
-import org.apache.hadoop.hive.metastore.api.Partition;
-import org.apache.hadoop.hive.metastore.api.PartitionEventType;
-import org.apache.hadoop.hive.metastore.api.PartitionsByExprRequest;
-import org.apache.hadoop.hive.metastore.api.PartitionsByExprResult;
-import org.apache.hadoop.hive.metastore.api.PartitionsStatsRequest;
-import org.apache.hadoop.hive.metastore.api.PrimaryKeysRequest;
-import org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet;
-import org.apache.hadoop.hive.metastore.api.PrincipalType;
-import org.apache.hadoop.hive.metastore.api.PrivilegeBag;
-import org.apache.hadoop.hive.metastore.api.PutFileMetadataRequest;
-import org.apache.hadoop.hive.metastore.api.RequestPartsSpec;
-import org.apache.hadoop.hive.metastore.api.Role;
-import org.apache.hadoop.hive.metastore.api.SQLForeignKey;
-import org.apache.hadoop.hive.metastore.api.SQLPrimaryKey;
-import org.apache.hadoop.hive.metastore.api.SetPartitionsStatsRequest;
-import org.apache.hadoop.hive.metastore.api.ShowCompactRequest;
-import org.apache.hadoop.hive.metastore.api.ShowCompactResponse;
-import org.apache.hadoop.hive.metastore.api.ShowLocksRequest;
-import org.apache.hadoop.hive.metastore.api.ShowLocksResponse;
-import org.apache.hadoop.hive.metastore.api.Table;
-import org.apache.hadoop.hive.metastore.api.TableMeta;
-import org.apache.hadoop.hive.metastore.api.TableStatsRequest;
-import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore;
-import org.apache.hadoop.hive.metastore.api.TxnAbortedException;
-import org.apache.hadoop.hive.metastore.api.TxnOpenException;
-import org.apache.hadoop.hive.metastore.api.Type;
-import org.apache.hadoop.hive.metastore.api.UnknownDBException;
-import org.apache.hadoop.hive.metastore.api.UnknownPartitionException;
-import org.apache.hadoop.hive.metastore.api.UnknownTableException;
-import org.apache.hadoop.hive.metastore.api.UnlockRequest;
import org.apache.hadoop.hive.metastore.partition.spec.PartitionSpecProxy;
import org.apache.hadoop.hive.metastore.txn.TxnUtils;
import org.apache.hadoop.hive.shims.ShimLoader;
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java
----------------------------------------------------------------------
diff --cc metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java
index ddc5a62,f9fad4c..e5b469b
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java
@@@ -33,8 -33,8 +33,9 @@@ import org.apache.hadoop.hive.metastore
import org.apache.hadoop.hive.metastore.PartFilterExprUtil;
import org.apache.hadoop.hive.metastore.PartitionExpressionProxy;
import org.apache.hadoop.hive.metastore.RawStore;
+ import org.apache.hadoop.hive.metastore.TableType;
import org.apache.hadoop.hive.metastore.Warehouse;
+import org.apache.hadoop.hive.metastore.RawStore.CanNotRetry;
import org.apache.hadoop.hive.metastore.api.AggrStats;
import org.apache.hadoop.hive.metastore.api.ColumnStatistics;
import org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj;
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java
----------------------------------------------------------------------