You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2014/03/30 20:39:34 UTC
svn commit: r1583185 [7/7] - in /hive/trunk:
itests/hive-unit/src/test/java/org/apache/hadoop/hive/metastore/
metastore/if/ metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen/...
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Sun Mar 30 18:39:33 2014
@@ -876,6 +876,13 @@ class Iface(fb303.FacebookService.Iface)
"""
pass
+ def heartbeat_txn_range(self, txns):
+ """
+ Parameters:
+ - txns
+ """
+ pass
+
def compact(self, rqst):
"""
Parameters:
@@ -4670,6 +4677,36 @@ class Client(fb303.FacebookService.Clien
raise result.o3
return
+ def heartbeat_txn_range(self, txns):
+ """
+ Parameters:
+ - txns
+ """
+ self.send_heartbeat_txn_range(txns)
+ return self.recv_heartbeat_txn_range()
+
+ def send_heartbeat_txn_range(self, txns):
+ self._oprot.writeMessageBegin('heartbeat_txn_range', TMessageType.CALL, self._seqid)
+ args = heartbeat_txn_range_args()
+ args.txns = txns
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_heartbeat_txn_range(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = heartbeat_txn_range_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "heartbeat_txn_range failed: unknown result");
+
def compact(self, rqst):
"""
Parameters:
@@ -4836,6 +4873,7 @@ class Processor(fb303.FacebookService.Pr
self._processMap["unlock"] = Processor.process_unlock
self._processMap["show_locks"] = Processor.process_show_locks
self._processMap["heartbeat"] = Processor.process_heartbeat
+ self._processMap["heartbeat_txn_range"] = Processor.process_heartbeat_txn_range
self._processMap["compact"] = Processor.process_compact
self._processMap["show_compact"] = Processor.process_show_compact
@@ -6532,6 +6570,17 @@ class Processor(fb303.FacebookService.Pr
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_heartbeat_txn_range(self, seqid, iprot, oprot):
+ args = heartbeat_txn_range_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = heartbeat_txn_range_result()
+ result.success = self._handler.heartbeat_txn_range(args.txns)
+ oprot.writeMessageBegin("heartbeat_txn_range", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_compact(self, seqid, iprot, oprot):
args = compact_args()
args.read(iprot)
@@ -7110,10 +7159,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype379, _size376) = iprot.readListBegin()
- for _i380 in xrange(_size376):
- _elem381 = iprot.readString();
- self.success.append(_elem381)
+ (_etype393, _size390) = iprot.readListBegin()
+ for _i394 in xrange(_size390):
+ _elem395 = iprot.readString();
+ self.success.append(_elem395)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7136,8 +7185,8 @@ class get_databases_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter382 in self.success:
- oprot.writeString(iter382)
+ for iter396 in self.success:
+ oprot.writeString(iter396)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7232,10 +7281,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype386, _size383) = iprot.readListBegin()
- for _i387 in xrange(_size383):
- _elem388 = iprot.readString();
- self.success.append(_elem388)
+ (_etype400, _size397) = iprot.readListBegin()
+ for _i401 in xrange(_size397):
+ _elem402 = iprot.readString();
+ self.success.append(_elem402)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7258,8 +7307,8 @@ class get_all_databases_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter389 in self.success:
- oprot.writeString(iter389)
+ for iter403 in self.success:
+ oprot.writeString(iter403)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7969,12 +8018,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype391, _vtype392, _size390 ) = iprot.readMapBegin()
- for _i394 in xrange(_size390):
- _key395 = iprot.readString();
- _val396 = Type()
- _val396.read(iprot)
- self.success[_key395] = _val396
+ (_ktype405, _vtype406, _size404 ) = iprot.readMapBegin()
+ for _i408 in xrange(_size404):
+ _key409 = iprot.readString();
+ _val410 = Type()
+ _val410.read(iprot)
+ self.success[_key409] = _val410
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -7997,9 +8046,9 @@ class get_type_all_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter397,viter398 in self.success.items():
- oprot.writeString(kiter397)
- viter398.write(oprot)
+ for kiter411,viter412 in self.success.items():
+ oprot.writeString(kiter411)
+ viter412.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -8130,11 +8179,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype402, _size399) = iprot.readListBegin()
- for _i403 in xrange(_size399):
- _elem404 = FieldSchema()
- _elem404.read(iprot)
- self.success.append(_elem404)
+ (_etype416, _size413) = iprot.readListBegin()
+ for _i417 in xrange(_size413):
+ _elem418 = FieldSchema()
+ _elem418.read(iprot)
+ self.success.append(_elem418)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8169,8 +8218,8 @@ class get_fields_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter405 in self.success:
- iter405.write(oprot)
+ for iter419 in self.success:
+ iter419.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8309,11 +8358,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype409, _size406) = iprot.readListBegin()
- for _i410 in xrange(_size406):
- _elem411 = FieldSchema()
- _elem411.read(iprot)
- self.success.append(_elem411)
+ (_etype423, _size420) = iprot.readListBegin()
+ for _i424 in xrange(_size420):
+ _elem425 = FieldSchema()
+ _elem425.read(iprot)
+ self.success.append(_elem425)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8348,8 +8397,8 @@ class get_schema_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter412 in self.success:
- iter412.write(oprot)
+ for iter426 in self.success:
+ iter426.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9146,10 +9195,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype416, _size413) = iprot.readListBegin()
- for _i417 in xrange(_size413):
- _elem418 = iprot.readString();
- self.success.append(_elem418)
+ (_etype430, _size427) = iprot.readListBegin()
+ for _i431 in xrange(_size427):
+ _elem432 = iprot.readString();
+ self.success.append(_elem432)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9172,8 +9221,8 @@ class get_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter419 in self.success:
- oprot.writeString(iter419)
+ for iter433 in self.success:
+ oprot.writeString(iter433)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9286,10 +9335,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype423, _size420) = iprot.readListBegin()
- for _i424 in xrange(_size420):
- _elem425 = iprot.readString();
- self.success.append(_elem425)
+ (_etype437, _size434) = iprot.readListBegin()
+ for _i438 in xrange(_size434):
+ _elem439 = iprot.readString();
+ self.success.append(_elem439)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9312,8 +9361,8 @@ class get_all_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter426 in self.success:
- oprot.writeString(iter426)
+ for iter440 in self.success:
+ oprot.writeString(iter440)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9530,10 +9579,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype430, _size427) = iprot.readListBegin()
- for _i431 in xrange(_size427):
- _elem432 = iprot.readString();
- self.tbl_names.append(_elem432)
+ (_etype444, _size441) = iprot.readListBegin()
+ for _i445 in xrange(_size441):
+ _elem446 = iprot.readString();
+ self.tbl_names.append(_elem446)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9554,8 +9603,8 @@ class get_table_objects_by_name_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter433 in self.tbl_names:
- oprot.writeString(iter433)
+ for iter447 in self.tbl_names:
+ oprot.writeString(iter447)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9610,11 +9659,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype437, _size434) = iprot.readListBegin()
- for _i438 in xrange(_size434):
- _elem439 = Table()
- _elem439.read(iprot)
- self.success.append(_elem439)
+ (_etype451, _size448) = iprot.readListBegin()
+ for _i452 in xrange(_size448):
+ _elem453 = Table()
+ _elem453.read(iprot)
+ self.success.append(_elem453)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9649,8 +9698,8 @@ class get_table_objects_by_name_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter440 in self.success:
- iter440.write(oprot)
+ for iter454 in self.success:
+ iter454.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9801,10 +9850,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = iprot.readString();
- self.success.append(_elem446)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = iprot.readString();
+ self.success.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9839,8 +9888,8 @@ class get_table_names_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter447 in self.success:
- oprot.writeString(iter447)
+ for iter461 in self.success:
+ oprot.writeString(iter461)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10563,11 +10612,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = Partition()
- _elem453.read(iprot)
- self.new_parts.append(_elem453)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = Partition()
+ _elem467.read(iprot)
+ self.new_parts.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10584,8 +10633,8 @@ class add_partitions_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter454 in self.new_parts:
- iter454.write(oprot)
+ for iter468 in self.new_parts:
+ iter468.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10746,10 +10795,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = iprot.readString();
- self.part_vals.append(_elem460)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = iprot.readString();
+ self.part_vals.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10774,8 +10823,8 @@ class append_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter461 in self.part_vals:
- oprot.writeString(iter461)
+ for iter475 in self.part_vals:
+ oprot.writeString(iter475)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11100,10 +11149,10 @@ class append_partition_with_environment_
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = iprot.readString();
- self.part_vals.append(_elem467)
+ (_etype479, _size476) = iprot.readListBegin()
+ for _i480 in xrange(_size476):
+ _elem481 = iprot.readString();
+ self.part_vals.append(_elem481)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11134,8 +11183,8 @@ class append_partition_with_environment_
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter468 in self.part_vals:
- oprot.writeString(iter468)
+ for iter482 in self.part_vals:
+ oprot.writeString(iter482)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -11683,10 +11732,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = iprot.readString();
- self.part_vals.append(_elem474)
+ (_etype486, _size483) = iprot.readListBegin()
+ for _i487 in xrange(_size483):
+ _elem488 = iprot.readString();
+ self.part_vals.append(_elem488)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11716,8 +11765,8 @@ class drop_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter475 in self.part_vals:
- oprot.writeString(iter475)
+ for iter489 in self.part_vals:
+ oprot.writeString(iter489)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -11875,10 +11924,10 @@ class drop_partition_with_environment_co
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype479, _size476) = iprot.readListBegin()
- for _i480 in xrange(_size476):
- _elem481 = iprot.readString();
- self.part_vals.append(_elem481)
+ (_etype493, _size490) = iprot.readListBegin()
+ for _i494 in xrange(_size490):
+ _elem495 = iprot.readString();
+ self.part_vals.append(_elem495)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11914,8 +11963,8 @@ class drop_partition_with_environment_co
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter482 in self.part_vals:
- oprot.writeString(iter482)
+ for iter496 in self.part_vals:
+ oprot.writeString(iter496)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -12593,10 +12642,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype486, _size483) = iprot.readListBegin()
- for _i487 in xrange(_size483):
- _elem488 = iprot.readString();
- self.part_vals.append(_elem488)
+ (_etype500, _size497) = iprot.readListBegin()
+ for _i501 in xrange(_size497):
+ _elem502 = iprot.readString();
+ self.part_vals.append(_elem502)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12621,8 +12670,8 @@ class get_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter489 in self.part_vals:
- oprot.writeString(iter489)
+ for iter503 in self.part_vals:
+ oprot.writeString(iter503)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12767,11 +12816,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype491, _vtype492, _size490 ) = iprot.readMapBegin()
- for _i494 in xrange(_size490):
- _key495 = iprot.readString();
- _val496 = iprot.readString();
- self.partitionSpecs[_key495] = _val496
+ (_ktype505, _vtype506, _size504 ) = iprot.readMapBegin()
+ for _i508 in xrange(_size504):
+ _key509 = iprot.readString();
+ _val510 = iprot.readString();
+ self.partitionSpecs[_key509] = _val510
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12808,9 +12857,9 @@ class exchange_partition_args:
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
- for kiter497,viter498 in self.partitionSpecs.items():
- oprot.writeString(kiter497)
- oprot.writeString(viter498)
+ for kiter511,viter512 in self.partitionSpecs.items():
+ oprot.writeString(kiter511)
+ oprot.writeString(viter512)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -13007,10 +13056,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype502, _size499) = iprot.readListBegin()
- for _i503 in xrange(_size499):
- _elem504 = iprot.readString();
- self.part_vals.append(_elem504)
+ (_etype516, _size513) = iprot.readListBegin()
+ for _i517 in xrange(_size513):
+ _elem518 = iprot.readString();
+ self.part_vals.append(_elem518)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13022,10 +13071,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype508, _size505) = iprot.readListBegin()
- for _i509 in xrange(_size505):
- _elem510 = iprot.readString();
- self.group_names.append(_elem510)
+ (_etype522, _size519) = iprot.readListBegin()
+ for _i523 in xrange(_size519):
+ _elem524 = iprot.readString();
+ self.group_names.append(_elem524)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13050,8 +13099,8 @@ class get_partition_with_auth_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter511 in self.part_vals:
- oprot.writeString(iter511)
+ for iter525 in self.part_vals:
+ oprot.writeString(iter525)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -13061,8 +13110,8 @@ class get_partition_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter512 in self.group_names:
- oprot.writeString(iter512)
+ for iter526 in self.group_names:
+ oprot.writeString(iter526)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13454,11 +13503,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = Partition()
- _elem518.read(iprot)
- self.success.append(_elem518)
+ (_etype530, _size527) = iprot.readListBegin()
+ for _i531 in xrange(_size527):
+ _elem532 = Partition()
+ _elem532.read(iprot)
+ self.success.append(_elem532)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13487,8 +13536,8 @@ class get_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter519 in self.success:
- iter519.write(oprot)
+ for iter533 in self.success:
+ iter533.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13575,10 +13624,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype523, _size520) = iprot.readListBegin()
- for _i524 in xrange(_size520):
- _elem525 = iprot.readString();
- self.group_names.append(_elem525)
+ (_etype537, _size534) = iprot.readListBegin()
+ for _i538 in xrange(_size534):
+ _elem539 = iprot.readString();
+ self.group_names.append(_elem539)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13611,8 +13660,8 @@ class get_partitions_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter526 in self.group_names:
- oprot.writeString(iter526)
+ for iter540 in self.group_names:
+ oprot.writeString(iter540)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13664,11 +13713,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = Partition()
- _elem532.read(iprot)
- self.success.append(_elem532)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = Partition()
+ _elem546.read(iprot)
+ self.success.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13697,8 +13746,8 @@ class get_partitions_with_auth_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter533 in self.success:
- iter533.write(oprot)
+ for iter547 in self.success:
+ iter547.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13839,10 +13888,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = iprot.readString();
- self.success.append(_elem539)
+ (_etype551, _size548) = iprot.readListBegin()
+ for _i552 in xrange(_size548):
+ _elem553 = iprot.readString();
+ self.success.append(_elem553)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13865,8 +13914,8 @@ class get_partition_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter540 in self.success:
- oprot.writeString(iter540)
+ for iter554 in self.success:
+ oprot.writeString(iter554)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -13936,10 +13985,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype544, _size541) = iprot.readListBegin()
- for _i545 in xrange(_size541):
- _elem546 = iprot.readString();
- self.part_vals.append(_elem546)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = iprot.readString();
+ self.part_vals.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13969,8 +14018,8 @@ class get_partitions_ps_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter547 in self.part_vals:
- oprot.writeString(iter547)
+ for iter561 in self.part_vals:
+ oprot.writeString(iter561)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14026,11 +14075,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = Partition()
- _elem553.read(iprot)
- self.success.append(_elem553)
+ (_etype565, _size562) = iprot.readListBegin()
+ for _i566 in xrange(_size562):
+ _elem567 = Partition()
+ _elem567.read(iprot)
+ self.success.append(_elem567)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14059,8 +14108,8 @@ class get_partitions_ps_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter554 in self.success:
- iter554.write(oprot)
+ for iter568 in self.success:
+ iter568.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14140,10 +14189,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype558, _size555) = iprot.readListBegin()
- for _i559 in xrange(_size555):
- _elem560 = iprot.readString();
- self.part_vals.append(_elem560)
+ (_etype572, _size569) = iprot.readListBegin()
+ for _i573 in xrange(_size569):
+ _elem574 = iprot.readString();
+ self.part_vals.append(_elem574)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14160,10 +14209,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype564, _size561) = iprot.readListBegin()
- for _i565 in xrange(_size561):
- _elem566 = iprot.readString();
- self.group_names.append(_elem566)
+ (_etype578, _size575) = iprot.readListBegin()
+ for _i579 in xrange(_size575):
+ _elem580 = iprot.readString();
+ self.group_names.append(_elem580)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14188,8 +14237,8 @@ class get_partitions_ps_with_auth_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter567 in self.part_vals:
- oprot.writeString(iter567)
+ for iter581 in self.part_vals:
+ oprot.writeString(iter581)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14203,8 +14252,8 @@ class get_partitions_ps_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 6)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter568 in self.group_names:
- oprot.writeString(iter568)
+ for iter582 in self.group_names:
+ oprot.writeString(iter582)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14256,11 +14305,11 @@ class get_partitions_ps_with_auth_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype572, _size569) = iprot.readListBegin()
- for _i573 in xrange(_size569):
- _elem574 = Partition()
- _elem574.read(iprot)
- self.success.append(_elem574)
+ (_etype586, _size583) = iprot.readListBegin()
+ for _i587 in xrange(_size583):
+ _elem588 = Partition()
+ _elem588.read(iprot)
+ self.success.append(_elem588)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14289,8 +14338,8 @@ class get_partitions_ps_with_auth_result
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter575 in self.success:
- iter575.write(oprot)
+ for iter589 in self.success:
+ iter589.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14364,10 +14413,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype579, _size576) = iprot.readListBegin()
- for _i580 in xrange(_size576):
- _elem581 = iprot.readString();
- self.part_vals.append(_elem581)
+ (_etype593, _size590) = iprot.readListBegin()
+ for _i594 in xrange(_size590):
+ _elem595 = iprot.readString();
+ self.part_vals.append(_elem595)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14397,8 +14446,8 @@ class get_partition_names_ps_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter582 in self.part_vals:
- oprot.writeString(iter582)
+ for iter596 in self.part_vals:
+ oprot.writeString(iter596)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14454,10 +14503,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype586, _size583) = iprot.readListBegin()
- for _i587 in xrange(_size583):
- _elem588 = iprot.readString();
- self.success.append(_elem588)
+ (_etype600, _size597) = iprot.readListBegin()
+ for _i601 in xrange(_size597):
+ _elem602 = iprot.readString();
+ self.success.append(_elem602)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14486,8 +14535,8 @@ class get_partition_names_ps_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter589 in self.success:
- oprot.writeString(iter589)
+ for iter603 in self.success:
+ oprot.writeString(iter603)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14643,11 +14692,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = Partition()
- _elem595.read(iprot)
- self.success.append(_elem595)
+ (_etype607, _size604) = iprot.readListBegin()
+ for _i608 in xrange(_size604):
+ _elem609 = Partition()
+ _elem609.read(iprot)
+ self.success.append(_elem609)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14676,8 +14725,8 @@ class get_partitions_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter596 in self.success:
- iter596.write(oprot)
+ for iter610 in self.success:
+ iter610.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14895,10 +14944,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype600, _size597) = iprot.readListBegin()
- for _i601 in xrange(_size597):
- _elem602 = iprot.readString();
- self.names.append(_elem602)
+ (_etype614, _size611) = iprot.readListBegin()
+ for _i615 in xrange(_size611):
+ _elem616 = iprot.readString();
+ self.names.append(_elem616)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14923,8 +14972,8 @@ class get_partitions_by_names_args:
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.names))
- for iter603 in self.names:
- oprot.writeString(iter603)
+ for iter617 in self.names:
+ oprot.writeString(iter617)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14976,11 +15025,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype607, _size604) = iprot.readListBegin()
- for _i608 in xrange(_size604):
- _elem609 = Partition()
- _elem609.read(iprot)
- self.success.append(_elem609)
+ (_etype621, _size618) = iprot.readListBegin()
+ for _i622 in xrange(_size618):
+ _elem623 = Partition()
+ _elem623.read(iprot)
+ self.success.append(_elem623)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15009,8 +15058,8 @@ class get_partitions_by_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter610 in self.success:
- iter610.write(oprot)
+ for iter624 in self.success:
+ iter624.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15240,11 +15289,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype614, _size611) = iprot.readListBegin()
- for _i615 in xrange(_size611):
- _elem616 = Partition()
- _elem616.read(iprot)
- self.new_parts.append(_elem616)
+ (_etype628, _size625) = iprot.readListBegin()
+ for _i629 in xrange(_size625):
+ _elem630 = Partition()
+ _elem630.read(iprot)
+ self.new_parts.append(_elem630)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15269,8 +15318,8 @@ class alter_partitions_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter617 in self.new_parts:
- iter617.write(oprot)
+ for iter631 in self.new_parts:
+ iter631.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15582,10 +15631,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype621, _size618) = iprot.readListBegin()
- for _i622 in xrange(_size618):
- _elem623 = iprot.readString();
- self.part_vals.append(_elem623)
+ (_etype635, _size632) = iprot.readListBegin()
+ for _i636 in xrange(_size632):
+ _elem637 = iprot.readString();
+ self.part_vals.append(_elem637)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15616,8 +15665,8 @@ class rename_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter624 in self.part_vals:
- oprot.writeString(iter624)
+ for iter638 in self.part_vals:
+ oprot.writeString(iter638)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -15745,10 +15794,10 @@ class partition_name_has_valid_character
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype628, _size625) = iprot.readListBegin()
- for _i629 in xrange(_size625):
- _elem630 = iprot.readString();
- self.part_vals.append(_elem630)
+ (_etype642, _size639) = iprot.readListBegin()
+ for _i643 in xrange(_size639):
+ _elem644 = iprot.readString();
+ self.part_vals.append(_elem644)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15770,8 +15819,8 @@ class partition_name_has_valid_character
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter631 in self.part_vals:
- oprot.writeString(iter631)
+ for iter645 in self.part_vals:
+ oprot.writeString(iter645)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -16100,10 +16149,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype635, _size632) = iprot.readListBegin()
- for _i636 in xrange(_size632):
- _elem637 = iprot.readString();
- self.success.append(_elem637)
+ (_etype649, _size646) = iprot.readListBegin()
+ for _i650 in xrange(_size646):
+ _elem651 = iprot.readString();
+ self.success.append(_elem651)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16126,8 +16175,8 @@ class partition_name_to_vals_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter638 in self.success:
- oprot.writeString(iter638)
+ for iter652 in self.success:
+ oprot.writeString(iter652)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16240,11 +16289,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype640, _vtype641, _size639 ) = iprot.readMapBegin()
- for _i643 in xrange(_size639):
- _key644 = iprot.readString();
- _val645 = iprot.readString();
- self.success[_key644] = _val645
+ (_ktype654, _vtype655, _size653 ) = iprot.readMapBegin()
+ for _i657 in xrange(_size653):
+ _key658 = iprot.readString();
+ _val659 = iprot.readString();
+ self.success[_key658] = _val659
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16267,9 +16316,9 @@ class partition_name_to_spec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter646,viter647 in self.success.items():
- oprot.writeString(kiter646)
- oprot.writeString(viter647)
+ for kiter660,viter661 in self.success.items():
+ oprot.writeString(kiter660)
+ oprot.writeString(viter661)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16339,11 +16388,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype649, _vtype650, _size648 ) = iprot.readMapBegin()
- for _i652 in xrange(_size648):
- _key653 = iprot.readString();
- _val654 = iprot.readString();
- self.part_vals[_key653] = _val654
+ (_ktype663, _vtype664, _size662 ) = iprot.readMapBegin()
+ for _i666 in xrange(_size662):
+ _key667 = iprot.readString();
+ _val668 = iprot.readString();
+ self.part_vals[_key667] = _val668
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16373,9 +16422,9 @@ class markPartitionForEvent_args:
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 kiter655,viter656 in self.part_vals.items():
- oprot.writeString(kiter655)
- oprot.writeString(viter656)
+ for kiter669,viter670 in self.part_vals.items():
+ oprot.writeString(kiter669)
+ oprot.writeString(viter670)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -16571,11 +16620,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype658, _vtype659, _size657 ) = iprot.readMapBegin()
- for _i661 in xrange(_size657):
- _key662 = iprot.readString();
- _val663 = iprot.readString();
- self.part_vals[_key662] = _val663
+ (_ktype672, _vtype673, _size671 ) = iprot.readMapBegin()
+ for _i675 in xrange(_size671):
+ _key676 = iprot.readString();
+ _val677 = iprot.readString();
+ self.part_vals[_key676] = _val677
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16605,9 +16654,9 @@ class isPartitionMarkedForEvent_args:
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 kiter664,viter665 in self.part_vals.items():
- oprot.writeString(kiter664)
- oprot.writeString(viter665)
+ for kiter678,viter679 in self.part_vals.items():
+ oprot.writeString(kiter678)
+ oprot.writeString(viter679)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -17579,11 +17628,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype669, _size666) = iprot.readListBegin()
- for _i670 in xrange(_size666):
- _elem671 = Index()
- _elem671.read(iprot)
- self.success.append(_elem671)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = Index()
+ _elem685.read(iprot)
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17612,8 +17661,8 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter672 in self.success:
- iter672.write(oprot)
+ for iter686 in self.success:
+ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17754,10 +17803,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = iprot.readString();
- self.success.append(_elem678)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = iprot.readString();
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17780,8 +17829,8 @@ class get_index_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter679 in self.success:
- oprot.writeString(iter679)
+ for iter693 in self.success:
+ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -19816,10 +19865,10 @@ class get_functions_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)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = iprot.readString();
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19842,8 +19891,8 @@ class get_functions_result:
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 iter700 in self.success:
+ oprot.writeString(iter700)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20361,10 +20410,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = iprot.readString();
- self.success.append(_elem692)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = iprot.readString();
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20387,8 +20436,8 @@ class get_role_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter693 in self.success:
- oprot.writeString(iter693)
+ for iter707 in self.success:
+ oprot.writeString(iter707)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20861,11 +20910,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = Role()
- _elem699.read(iprot)
- self.success.append(_elem699)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = Role()
+ _elem713.read(iprot)
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20888,8 +20937,8 @@ class list_roles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter700 in self.success:
- iter700.write(oprot)
+ for iter714 in self.success:
+ iter714.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21225,10 +21274,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = iprot.readString();
- self.group_names.append(_elem706)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = iprot.readString();
+ self.group_names.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21253,8 +21302,8 @@ class get_privilege_set_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter707 in self.group_names:
- oprot.writeString(iter707)
+ for iter721 in self.group_names:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21461,11 +21510,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = HiveObjectPrivilege()
- _elem713.read(iprot)
- self.success.append(_elem713)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = HiveObjectPrivilege()
+ _elem727.read(iprot)
+ self.success.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21488,8 +21537,8 @@ class list_privileges_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter714 in self.success:
- iter714.write(oprot)
+ for iter728 in self.success:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21814,10 +21863,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = iprot.readString();
- self.group_names.append(_elem720)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString();
+ self.group_names.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21838,8 +21887,8 @@ class set_ugi_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter721 in self.group_names:
- oprot.writeString(iter721)
+ for iter735 in self.group_names:
+ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21888,10 +21937,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = iprot.readString();
- self.success.append(_elem727)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString();
+ self.success.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21914,8 +21963,8 @@ class set_ugi_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter728 in self.success:
- oprot.writeString(iter728)
+ for iter742 in self.success:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23630,6 +23679,127 @@ class heartbeat_result:
def __ne__(self, other):
return not (self == other)
+class heartbeat_txn_range_args:
+ """
+ Attributes:
+ - txns
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'txns', (HeartbeatTxnRangeRequest, HeartbeatTxnRangeRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, txns=None,):
+ self.txns = txns
+
+ 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.STRUCT:
+ self.txns = HeartbeatTxnRangeRequest()
+ self.txns.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('heartbeat_txn_range_args')
+ if self.txns is not None:
+ oprot.writeFieldBegin('txns', TType.STRUCT, 1)
+ self.txns.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ 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 heartbeat_txn_range_result:
+ """
+ Attributes:
+ - success
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (HeartbeatTxnRangeResponse, HeartbeatTxnRangeResponse.thrift_spec), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+ 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.STRUCT:
+ self.success = HeartbeatTxnRangeResponse()
+ self.success.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('heartbeat_txn_range_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ 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 compact_args:
"""
Attributes:
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py Sun Mar 30 18:39:33 2014
@@ -6689,6 +6689,174 @@ class HeartbeatRequest:
def __ne__(self, other):
return not (self == other)
+class HeartbeatTxnRangeRequest:
+ """
+ Attributes:
+ - min
+ - max
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I64, 'min', None, None, ), # 1
+ (2, TType.I64, 'max', None, None, ), # 2
+ )
+
+ def __init__(self, min=None, max=None,):
+ self.min = min
+ self.max = max
+
+ 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.I64:
+ self.min = iprot.readI64();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I64:
+ self.max = iprot.readI64();
+ 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('HeartbeatTxnRangeRequest')
+ if self.min is not None:
+ oprot.writeFieldBegin('min', TType.I64, 1)
+ oprot.writeI64(self.min)
+ oprot.writeFieldEnd()
+ if self.max is not None:
+ oprot.writeFieldBegin('max', TType.I64, 2)
+ oprot.writeI64(self.max)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.min is None:
+ raise TProtocol.TProtocolException(message='Required field min is unset!')
+ if self.max is None:
+ raise TProtocol.TProtocolException(message='Required field max is unset!')
+ return
+
+
+ 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 HeartbeatTxnRangeResponse:
+ """
+ Attributes:
+ - aborted
+ - nosuch
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.SET, 'aborted', (TType.I64,None), None, ), # 1
+ (2, TType.SET, 'nosuch', (TType.I64,None), None, ), # 2
+ )
+
+ def __init__(self, aborted=None, nosuch=None,):
+ self.aborted = aborted
+ self.nosuch = nosuch
+
+ 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.SET:
+ self.aborted = set()
+ (_etype372, _size369) = iprot.readSetBegin()
+ for _i373 in xrange(_size369):
+ _elem374 = iprot.readI64();
+ self.aborted.add(_elem374)
+ iprot.readSetEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.SET:
+ self.nosuch = set()
+ (_etype378, _size375) = iprot.readSetBegin()
+ for _i379 in xrange(_size375):
+ _elem380 = iprot.readI64();
+ self.nosuch.add(_elem380)
+ iprot.readSetEnd()
+ 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('HeartbeatTxnRangeResponse')
+ if self.aborted is not None:
+ oprot.writeFieldBegin('aborted', TType.SET, 1)
+ oprot.writeSetBegin(TType.I64, len(self.aborted))
+ for iter381 in self.aborted:
+ oprot.writeI64(iter381)
+ oprot.writeSetEnd()
+ oprot.writeFieldEnd()
+ if self.nosuch is not None:
+ oprot.writeFieldBegin('nosuch', TType.SET, 2)
+ oprot.writeSetBegin(TType.I64, len(self.nosuch))
+ for iter382 in self.nosuch:
+ oprot.writeI64(iter382)
+ oprot.writeSetEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.aborted is None:
+ raise TProtocol.TProtocolException(message='Required field aborted is unset!')
+ if self.nosuch is None:
+ raise TProtocol.TProtocolException(message='Required field nosuch is unset!')
+ return
+
+
+ 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 CompactionRequest:
"""
Attributes:
@@ -7031,11 +7199,11 @@ class ShowCompactResponse:
if fid == 1:
if ftype == TType.LIST:
self.compacts = []
- (_etype372, _size369) = iprot.readListBegin()
- for _i373 in xrange(_size369):
- _elem374 = ShowCompactResponseElement()
- _elem374.read(iprot)
- self.compacts.append(_elem374)
+ (_etype386, _size383) = iprot.readListBegin()
+ for _i387 in xrange(_size383):
+ _elem388 = ShowCompactResponseElement()
+ _elem388.read(iprot)
+ self.compacts.append(_elem388)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7052,8 +7220,8 @@ class ShowCompactResponse:
if self.compacts is not None:
oprot.writeFieldBegin('compacts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.compacts))
- for iter375 in self.compacts:
- iter375.write(oprot)
+ for iter389 in self.compacts:
+ iter389.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
Modified: hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb Sun Mar 30 18:39:33 2014
@@ -1631,6 +1631,46 @@ class HeartbeatRequest
::Thrift::Struct.generate_accessors self
end
+class HeartbeatTxnRangeRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ MIN = 1
+ MAX = 2
+
+ FIELDS = {
+ MIN => {:type => ::Thrift::Types::I64, :name => 'min'},
+ MAX => {:type => ::Thrift::Types::I64, :name => 'max'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field min is unset!') unless @min
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field max is unset!') unless @max
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class HeartbeatTxnRangeResponse
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ ABORTED = 1
+ NOSUCH = 2
+
+ FIELDS = {
+ ABORTED => {:type => ::Thrift::Types::SET, :name => 'aborted', :element => {:type => ::Thrift::Types::I64}},
+ NOSUCH => {:type => ::Thrift::Types::SET, :name => 'nosuch', :element => {:type => ::Thrift::Types::I64}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field aborted is unset!') unless @aborted
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field nosuch is unset!') unless @nosuch
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class CompactionRequest
include ::Thrift::Struct, ::Thrift::Struct_Union
DBNAME = 1
Modified: hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb Sun Mar 30 18:39:33 2014
@@ -1766,6 +1766,21 @@ module ThriftHiveMetastore
return
end
+ def heartbeat_txn_range(txns)
+ send_heartbeat_txn_range(txns)
+ return recv_heartbeat_txn_range()
+ end
+
+ def send_heartbeat_txn_range(txns)
+ send_message('heartbeat_txn_range', Heartbeat_txn_range_args, :txns => txns)
+ end
+
+ def recv_heartbeat_txn_range()
+ result = receive_message(Heartbeat_txn_range_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'heartbeat_txn_range failed: unknown result')
+ end
+
def compact(rqst)
send_compact(rqst)
recv_compact()
@@ -3162,6 +3177,13 @@ module ThriftHiveMetastore
write_result(result, oprot, 'heartbeat', seqid)
end
+ def process_heartbeat_txn_range(seqid, iprot, oprot)
+ args = read_args(iprot, Heartbeat_txn_range_args)
+ result = Heartbeat_txn_range_result.new()
+ result.success = @handler.heartbeat_txn_range(args.txns)
+ write_result(result, oprot, 'heartbeat_txn_range', seqid)
+ end
+
def process_compact(seqid, iprot, oprot)
args = read_args(iprot, Compact_args)
result = Compact_result.new()
@@ -7197,6 +7219,38 @@ module ThriftHiveMetastore
::Thrift::Struct.generate_accessors self
end
+ class Heartbeat_txn_range_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ TXNS = 1
+
+ FIELDS = {
+ TXNS => {:type => ::Thrift::Types::STRUCT, :name => 'txns', :class => ::HeartbeatTxnRangeRequest}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Heartbeat_txn_range_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::HeartbeatTxnRangeResponse}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
class Compact_args
include ::Thrift::Struct, ::Thrift::Struct_Union
RQST = 1
Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (original)
+++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java Sun Mar 30 18:39:33 2014
@@ -83,6 +83,8 @@ import org.apache.hadoop.hive.metastore.
import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalRequest;
import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalResponse;
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.HiveObjectType;
@@ -4862,6 +4864,16 @@ public class HiveMetaStore extends Thrif
}
@Override
+ public HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest rqst)
+ throws TException {
+ try {
+ return getTxnHandler().heartbeatTxnRange(rqst);
+ } catch (MetaException e) {
+ throw new TException(e);
+ }
+ }
+
+ @Override
public void compact(CompactionRequest rqst) throws TException {
try {
getTxnHandler().compact(rqst);
Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java (original)
+++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java Sun Mar 30 18:39:33 2014
@@ -74,6 +74,8 @@ import org.apache.hadoop.hive.metastore.
import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalRequest;
import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalResponse;
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;
@@ -1612,6 +1614,13 @@ public class HiveMetaStoreClient impleme
}
@Override
+ public HeartbeatTxnRangeResponse heartbeatTxnRange(long min, long max)
+ throws NoSuchTxnException, TxnAbortedException, TException {
+ HeartbeatTxnRangeRequest rqst = new HeartbeatTxnRangeRequest(min, max);
+ return client.heartbeat_txn_range(rqst);
+ }
+
+ @Override
public void compact(String dbname, String tableName, String partitionName, CompactionType type)
throws TException {
CompactionRequest cr = new CompactionRequest();
Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java (original)
+++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java Sun Mar 30 18:39:33 2014
@@ -22,6 +22,7 @@ import org.apache.hadoop.hive.common.Val
import org.apache.hadoop.hive.metastore.api.CompactionType;
import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse;
import org.apache.hadoop.hive.metastore.api.GetOpenTxnsResponse;
+import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeResponse;
import org.apache.hadoop.hive.metastore.api.LockRequest;
import org.apache.hadoop.hive.metastore.api.LockResponse;
import org.apache.hadoop.hive.metastore.api.NoSuchLockException;
@@ -1232,6 +1233,18 @@ public interface IMetaStoreClient {
TException;
/**
+ * Send heartbeats for a range of transactions. This is for the streaming ingest client that
+ * will have many transactions open at once. Everyone else should use
+ * {@link #heartbeat(long, long)}.
+ * @param min minimum transaction id to heartbeat, inclusive
+ * @param max maximum transaction id to heartbeat, inclusive
+ * @return a pair of lists that tell which transactions in the list did not exist (they may
+ * have already been closed) and which were aborted.
+ * @throws TException
+ */
+ public HeartbeatTxnRangeResponse heartbeatTxnRange(long min, long max) throws TException;
+
+ /**
* Send a request to compact a table or partition. This will not block until the compaction is
* complete. It will instead put a request on the queue for that table or partition to be
* compacted. No checking is done on the dbname, tableName, or partitionName to make sure they
Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java (original)
+++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java Sun Mar 30 18:39:33 2014
@@ -600,6 +600,43 @@ public class TxnHandler {
}
}
+ public HeartbeatTxnRangeResponse heartbeatTxnRange(HeartbeatTxnRangeRequest rqst)
+ throws MetaException {
+ try {
+ Connection dbConn = getDbConn();
+ HeartbeatTxnRangeResponse rsp = new HeartbeatTxnRangeResponse();
+ Set<Long> nosuch = new HashSet<Long>();
+ Set<Long> aborted = new HashSet<Long>();
+ rsp.setNosuch(nosuch);
+ rsp.setAborted(aborted);
+ try {
+ for (long txn = rqst.getMin(); txn <= rqst.getMax(); txn++) {
+ try {
+ heartbeatTxn(dbConn, txn);
+ } catch (NoSuchTxnException e) {
+ nosuch.add(txn);
+ } catch (TxnAbortedException e) {
+ aborted.add(txn);
+ }
+ }
+ return rsp;
+ } catch (SQLException e) {
+ try {
+ LOG.debug("Going to rollback");
+ dbConn.rollback();
+ } catch (SQLException e1) {
+ }
+ detectDeadlock(e, "heartbeatTxnRange");
+ throw new MetaException("Unable to select from transaction database " +
+ StringUtils.stringifyException(e));
+ } finally {
+ closeDbConn(dbConn);
+ }
+ } catch (DeadlockException e) {
+ return heartbeatTxnRange(rqst);
+ }
+ }
+
public void compact(CompactionRequest rqst) throws MetaException {
// Put a compaction request in the queue.
try {
Modified: hive/trunk/metastore/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java (original)
+++ hive/trunk/metastore/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java Sun Mar 30 18:39:33 2014
@@ -889,6 +889,48 @@ public class TestTxnHandler {
}
@Test
+ public void heartbeatTxnRange() throws Exception {
+ long txnid = openTxn();
+ assertEquals(1, txnid);
+ txnid = openTxn();
+ txnid = openTxn();
+ HeartbeatTxnRangeResponse rsp =
+ txnHandler.heartbeatTxnRange(new HeartbeatTxnRangeRequest(1, 3));
+ assertEquals(0, rsp.getAborted().size());
+ assertEquals(0, rsp.getNosuch().size());
+ }
+
+ @Test
+ public void heartbeatTxnRangeOneCommitted() throws Exception {
+ long txnid = openTxn();
+ assertEquals(1, txnid);
+ txnHandler.commitTxn(new CommitTxnRequest(1));
+ txnid = openTxn();
+ txnid = openTxn();
+ HeartbeatTxnRangeResponse rsp =
+ txnHandler.heartbeatTxnRange(new HeartbeatTxnRangeRequest(1, 3));
+ assertEquals(1, rsp.getNosuchSize());
+ Long txn = rsp.getNosuch().iterator().next();
+ assertEquals(1L, (long)txn);
+ assertEquals(0, rsp.getAborted().size());
+ }
+
+ @Test
+ public void heartbeatTxnRangeOneAborted() throws Exception {
+ long txnid = openTxn();
+ assertEquals(1, txnid);
+ txnid = openTxn();
+ txnid = openTxn();
+ txnHandler.abortTxn(new AbortTxnRequest(3));
+ HeartbeatTxnRangeResponse rsp =
+ txnHandler.heartbeatTxnRange(new HeartbeatTxnRangeRequest(1, 3));
+ assertEquals(1, rsp.getAbortedSize());
+ Long txn = rsp.getAborted().iterator().next();
+ assertEquals(3L, (long)txn);
+ assertEquals(0, rsp.getNosuch().size());
+ }
+
+ @Test
public void testLockTimeout() throws Exception {
long timeout = txnHandler.setTimeout(1);
LockComponent comp = new LockComponent(LockType.EXCLUSIVE, LockLevel.DB, "mydb");