http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index e299906..9e460f0 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -775,6 +775,9 @@ class Iface(fb303.FacebookService.Iface): """ pass + def get_all_functions(self): + pass + def create_role(self, role): """ Parameters: @@ -4413,6 +4416,34 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_function failed: unknown result"); + def get_all_functions(self): + self.send_get_all_functions() + return self.recv_get_all_functions() + + def send_get_all_functions(self): + self._oprot.writeMessageBegin('get_all_functions', TMessageType.CALL, self._seqid) + args = get_all_functions_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_all_functions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_all_functions_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_functions failed: unknown result"); + def create_role(self, role): """ Parameters: @@ -5650,6 +5681,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["alter_function"] = Processor.process_alter_function self._processMap["get_functions"] = Processor.process_get_functions self._processMap["get_function"] = Processor.process_get_function + self._processMap["get_all_functions"] = Processor.process_get_all_functions self._processMap["create_role"] = Processor.process_create_role self._processMap["drop_role"] = Processor.process_drop_role self._processMap["get_role_names"] = Processor.process_get_role_names @@ -7179,6 +7211,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_get_all_functions(self, seqid, iprot, oprot): + args = get_all_functions_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_all_functions_result() + try: + result.success = self._handler.get_all_functions() + except MetaException, o1: + result.o1 = o1 + oprot.writeMessageBegin("get_all_functions", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_create_role(self, seqid, iprot, oprot): args = create_role_args() args.read(iprot) @@ -8541,10 +8587,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype465, _size462) = iprot.readListBegin() - for _i466 in xrange(_size462): - _elem467 = iprot.readString(); - self.success.append(_elem467) + (_etype472, _size469) = iprot.readListBegin() + for _i473 in xrange(_size469): + _elem474 = iprot.readString(); + self.success.append(_elem474) iprot.readListEnd() else: iprot.skip(ftype) @@ -8567,8 +8613,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 iter468 in self.success: - oprot.writeString(iter468) + for iter475 in self.success: + oprot.writeString(iter475) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8673,10 +8719,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype472, _size469) = iprot.readListBegin() - for _i473 in xrange(_size469): - _elem474 = iprot.readString(); - self.success.append(_elem474) + (_etype479, _size476) = iprot.readListBegin() + for _i480 in xrange(_size476): + _elem481 = iprot.readString(); + self.success.append(_elem481) iprot.readListEnd() else: iprot.skip(ftype) @@ -8699,8 +8745,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 iter475 in self.success: - oprot.writeString(iter475) + for iter482 in self.success: + oprot.writeString(iter482) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9470,12 +9516,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype477, _vtype478, _size476 ) = iprot.readMapBegin() - for _i480 in xrange(_size476): - _key481 = iprot.readString(); - _val482 = Type() - _val482.read(iprot) - self.success[_key481] = _val482 + (_ktype484, _vtype485, _size483 ) = iprot.readMapBegin() + for _i487 in xrange(_size483): + _key488 = iprot.readString(); + _val489 = Type() + _val489.read(iprot) + self.success[_key488] = _val489 iprot.readMapEnd() else: iprot.skip(ftype) @@ -9498,9 +9544,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 kiter483,viter484 in self.success.items(): - oprot.writeString(kiter483) - viter484.write(oprot) + for kiter490,viter491 in self.success.items(): + oprot.writeString(kiter490) + viter491.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -9643,11 +9689,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype488, _size485) = iprot.readListBegin() - for _i489 in xrange(_size485): - _elem490 = FieldSchema() - _elem490.read(iprot) - self.success.append(_elem490) + (_etype495, _size492) = iprot.readListBegin() + for _i496 in xrange(_size492): + _elem497 = FieldSchema() + _elem497.read(iprot) + self.success.append(_elem497) iprot.readListEnd() else: iprot.skip(ftype) @@ -9682,8 +9728,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 iter491 in self.success: - iter491.write(oprot) + for iter498 in self.success: + iter498.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9850,11 +9896,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype495, _size492) = iprot.readListBegin() - for _i496 in xrange(_size492): - _elem497 = FieldSchema() - _elem497.read(iprot) - self.success.append(_elem497) + (_etype502, _size499) = iprot.readListBegin() + for _i503 in xrange(_size499): + _elem504 = FieldSchema() + _elem504.read(iprot) + self.success.append(_elem504) iprot.readListEnd() else: iprot.skip(ftype) @@ -9889,8 +9935,8 @@ class get_fields_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter498 in self.success: - iter498.write(oprot) + for iter505 in self.success: + iter505.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10043,11 +10089,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype502, _size499) = iprot.readListBegin() - for _i503 in xrange(_size499): - _elem504 = FieldSchema() - _elem504.read(iprot) - self.success.append(_elem504) + (_etype509, _size506) = iprot.readListBegin() + for _i510 in xrange(_size506): + _elem511 = FieldSchema() + _elem511.read(iprot) + self.success.append(_elem511) iprot.readListEnd() else: iprot.skip(ftype) @@ -10082,8 +10128,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 iter505 in self.success: - iter505.write(oprot) + for iter512 in self.success: + iter512.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10250,11 +10296,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype509, _size506) = iprot.readListBegin() - for _i510 in xrange(_size506): - _elem511 = FieldSchema() - _elem511.read(iprot) - self.success.append(_elem511) + (_etype516, _size513) = iprot.readListBegin() + for _i517 in xrange(_size513): + _elem518 = FieldSchema() + _elem518.read(iprot) + self.success.append(_elem518) iprot.readListEnd() else: iprot.skip(ftype) @@ -10289,8 +10335,8 @@ class get_schema_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter512 in self.success: - iter512.write(oprot) + for iter519 in self.success: + iter519.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11155,10 +11201,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype516, _size513) = iprot.readListBegin() - for _i517 in xrange(_size513): - _elem518 = iprot.readString(); - self.success.append(_elem518) + (_etype523, _size520) = iprot.readListBegin() + for _i524 in xrange(_size520): + _elem525 = iprot.readString(); + self.success.append(_elem525) iprot.readListEnd() else: iprot.skip(ftype) @@ -11181,8 +11227,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 iter519 in self.success: - oprot.writeString(iter519) + for iter526 in self.success: + oprot.writeString(iter526) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11306,10 +11352,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype523, _size520) = iprot.readListBegin() - for _i524 in xrange(_size520): - _elem525 = iprot.readString(); - self.success.append(_elem525) + (_etype530, _size527) = iprot.readListBegin() + for _i531 in xrange(_size527): + _elem532 = iprot.readString(); + self.success.append(_elem532) iprot.readListEnd() else: iprot.skip(ftype) @@ -11332,8 +11378,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 iter526 in self.success: - oprot.writeString(iter526) + for iter533 in self.success: + oprot.writeString(iter533) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11569,10 +11615,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype530, _size527) = iprot.readListBegin() - for _i531 in xrange(_size527): - _elem532 = iprot.readString(); - self.tbl_names.append(_elem532) + (_etype537, _size534) = iprot.readListBegin() + for _i538 in xrange(_size534): + _elem539 = iprot.readString(); + self.tbl_names.append(_elem539) iprot.readListEnd() else: iprot.skip(ftype) @@ -11593,8 +11639,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 iter533 in self.tbl_names: - oprot.writeString(iter533) + for iter540 in self.tbl_names: + oprot.writeString(iter540) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11655,11 +11701,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype537, _size534) = iprot.readListBegin() - for _i538 in xrange(_size534): - _elem539 = Table() - _elem539.read(iprot) - self.success.append(_elem539) + (_etype544, _size541) = iprot.readListBegin() + for _i545 in xrange(_size541): + _elem546 = Table() + _elem546.read(iprot) + self.success.append(_elem546) iprot.readListEnd() else: iprot.skip(ftype) @@ -11694,8 +11740,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 iter540 in self.success: - iter540.write(oprot) + for iter547 in self.success: + iter547.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11861,10 +11907,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype544, _size541) = iprot.readListBegin() - for _i545 in xrange(_size541): - _elem546 = iprot.readString(); - self.success.append(_elem546) + (_etype551, _size548) = iprot.readListBegin() + for _i552 in xrange(_size548): + _elem553 = iprot.readString(); + self.success.append(_elem553) iprot.readListEnd() else: iprot.skip(ftype) @@ -11899,8 +11945,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 iter547 in self.success: - oprot.writeString(iter547) + for iter554 in self.success: + oprot.writeString(iter554) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -12870,11 +12916,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype551, _size548) = iprot.readListBegin() - for _i552 in xrange(_size548): - _elem553 = Partition() - _elem553.read(iprot) - self.new_parts.append(_elem553) + (_etype558, _size555) = iprot.readListBegin() + for _i559 in xrange(_size555): + _elem560 = Partition() + _elem560.read(iprot) + self.new_parts.append(_elem560) iprot.readListEnd() else: iprot.skip(ftype) @@ -12891,8 +12937,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 iter554 in self.new_parts: - iter554.write(oprot) + for iter561 in self.new_parts: + iter561.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13050,11 +13096,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype558, _size555) = iprot.readListBegin() - for _i559 in xrange(_size555): - _elem560 = PartitionSpec() - _elem560.read(iprot) - self.new_parts.append(_elem560) + (_etype565, _size562) = iprot.readListBegin() + for _i566 in xrange(_size562): + _elem567 = PartitionSpec() + _elem567.read(iprot) + self.new_parts.append(_elem567) iprot.readListEnd() else: iprot.skip(ftype) @@ -13071,8 +13117,8 @@ class add_partitions_pspec_args: if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) - for iter561 in self.new_parts: - iter561.write(oprot) + for iter568 in self.new_parts: + iter568.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13246,10 +13292,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype565, _size562) = iprot.readListBegin() - for _i566 in xrange(_size562): - _elem567 = iprot.readString(); - self.part_vals.append(_elem567) + (_etype572, _size569) = iprot.readListBegin() + for _i573 in xrange(_size569): + _elem574 = iprot.readString(); + self.part_vals.append(_elem574) iprot.readListEnd() else: iprot.skip(ftype) @@ -13274,8 +13320,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 iter568 in self.part_vals: - oprot.writeString(iter568) + for iter575 in self.part_vals: + oprot.writeString(iter575) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13628,10 +13674,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype572, _size569) = iprot.readListBegin() - for _i573 in xrange(_size569): - _elem574 = iprot.readString(); - self.part_vals.append(_elem574) + (_etype579, _size576) = iprot.readListBegin() + for _i580 in xrange(_size576): + _elem581 = iprot.readString(); + self.part_vals.append(_elem581) iprot.readListEnd() else: iprot.skip(ftype) @@ -13662,8 +13708,8 @@ class append_partition_with_environment_context_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter575 in self.part_vals: - oprot.writeString(iter575) + for iter582 in self.part_vals: + oprot.writeString(iter582) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -14258,10 +14304,10 @@ class drop_partition_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) + (_etype586, _size583) = iprot.readListBegin() + for _i587 in xrange(_size583): + _elem588 = iprot.readString(); + self.part_vals.append(_elem588) iprot.readListEnd() else: iprot.skip(ftype) @@ -14291,8 +14337,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 iter582 in self.part_vals: - oprot.writeString(iter582) + for iter589 in self.part_vals: + oprot.writeString(iter589) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -14465,10 +14511,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype586, _size583) = iprot.readListBegin() - for _i587 in xrange(_size583): - _elem588 = iprot.readString(); - self.part_vals.append(_elem588) + (_etype593, _size590) = iprot.readListBegin() + for _i594 in xrange(_size590): + _elem595 = iprot.readString(); + self.part_vals.append(_elem595) iprot.readListEnd() else: iprot.skip(ftype) @@ -14504,8 +14550,8 @@ class drop_partition_with_environment_context_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter589 in self.part_vals: - oprot.writeString(iter589) + for iter596 in self.part_vals: + oprot.writeString(iter596) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -15242,10 +15288,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype593, _size590) = iprot.readListBegin() - for _i594 in xrange(_size590): - _elem595 = iprot.readString(); - self.part_vals.append(_elem595) + (_etype600, _size597) = iprot.readListBegin() + for _i601 in xrange(_size597): + _elem602 = iprot.readString(); + self.part_vals.append(_elem602) iprot.readListEnd() else: iprot.skip(ftype) @@ -15270,8 +15316,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 iter596 in self.part_vals: - oprot.writeString(iter596) + for iter603 in self.part_vals: + oprot.writeString(iter603) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15430,11 +15476,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype598, _vtype599, _size597 ) = iprot.readMapBegin() - for _i601 in xrange(_size597): - _key602 = iprot.readString(); - _val603 = iprot.readString(); - self.partitionSpecs[_key602] = _val603 + (_ktype605, _vtype606, _size604 ) = iprot.readMapBegin() + for _i608 in xrange(_size604): + _key609 = iprot.readString(); + _val610 = iprot.readString(); + self.partitionSpecs[_key609] = _val610 iprot.readMapEnd() else: iprot.skip(ftype) @@ -15471,9 +15517,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 kiter604,viter605 in self.partitionSpecs.items(): - oprot.writeString(kiter604) - oprot.writeString(viter605) + for kiter611,viter612 in self.partitionSpecs.items(): + oprot.writeString(kiter611) + oprot.writeString(viter612) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -15688,10 +15734,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype609, _size606) = iprot.readListBegin() - for _i610 in xrange(_size606): - _elem611 = iprot.readString(); - self.part_vals.append(_elem611) + (_etype616, _size613) = iprot.readListBegin() + for _i617 in xrange(_size613): + _elem618 = iprot.readString(); + self.part_vals.append(_elem618) iprot.readListEnd() else: iprot.skip(ftype) @@ -15703,10 +15749,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype615, _size612) = iprot.readListBegin() - for _i616 in xrange(_size612): - _elem617 = iprot.readString(); - self.group_names.append(_elem617) + (_etype622, _size619) = iprot.readListBegin() + for _i623 in xrange(_size619): + _elem624 = iprot.readString(); + self.group_names.append(_elem624) iprot.readListEnd() else: iprot.skip(ftype) @@ -15731,8 +15777,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 iter618 in self.part_vals: - oprot.writeString(iter618) + for iter625 in self.part_vals: + oprot.writeString(iter625) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -15742,8 +15788,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 iter619 in self.group_names: - oprot.writeString(iter619) + for iter626 in self.group_names: + oprot.writeString(iter626) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16172,11 +16218,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype623, _size620) = iprot.readListBegin() - for _i624 in xrange(_size620): - _elem625 = Partition() - _elem625.read(iprot) - self.success.append(_elem625) + (_etype630, _size627) = iprot.readListBegin() + for _i631 in xrange(_size627): + _elem632 = Partition() + _elem632.read(iprot) + self.success.append(_elem632) iprot.readListEnd() else: iprot.skip(ftype) @@ -16205,8 +16251,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 iter626 in self.success: - iter626.write(oprot) + for iter633 in self.success: + iter633.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16300,10 +16346,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype630, _size627) = iprot.readListBegin() - for _i631 in xrange(_size627): - _elem632 = iprot.readString(); - self.group_names.append(_elem632) + (_etype637, _size634) = iprot.readListBegin() + for _i638 in xrange(_size634): + _elem639 = iprot.readString(); + self.group_names.append(_elem639) iprot.readListEnd() else: iprot.skip(ftype) @@ -16336,8 +16382,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 iter633 in self.group_names: - oprot.writeString(iter633) + for iter640 in self.group_names: + oprot.writeString(iter640) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16398,11 +16444,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype637, _size634) = iprot.readListBegin() - for _i638 in xrange(_size634): - _elem639 = Partition() - _elem639.read(iprot) - self.success.append(_elem639) + (_etype644, _size641) = iprot.readListBegin() + for _i645 in xrange(_size641): + _elem646 = Partition() + _elem646.read(iprot) + self.success.append(_elem646) iprot.readListEnd() else: iprot.skip(ftype) @@ -16431,8 +16477,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 iter640 in self.success: - iter640.write(oprot) + for iter647 in self.success: + iter647.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16590,11 +16636,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype644, _size641) = iprot.readListBegin() - for _i645 in xrange(_size641): - _elem646 = PartitionSpec() - _elem646.read(iprot) - self.success.append(_elem646) + (_etype651, _size648) = iprot.readListBegin() + for _i652 in xrange(_size648): + _elem653 = PartitionSpec() + _elem653.read(iprot) + self.success.append(_elem653) iprot.readListEnd() else: iprot.skip(ftype) @@ -16623,8 +16669,8 @@ class get_partitions_pspec_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter647 in self.success: - iter647.write(oprot) + for iter654 in self.success: + iter654.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16779,10 +16825,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype651, _size648) = iprot.readListBegin() - for _i652 in xrange(_size648): - _elem653 = iprot.readString(); - self.success.append(_elem653) + (_etype658, _size655) = iprot.readListBegin() + for _i659 in xrange(_size655): + _elem660 = iprot.readString(); + self.success.append(_elem660) iprot.readListEnd() else: iprot.skip(ftype) @@ -16805,8 +16851,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 iter654 in self.success: - oprot.writeString(iter654) + for iter661 in self.success: + oprot.writeString(iter661) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -16882,10 +16928,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype658, _size655) = iprot.readListBegin() - for _i659 in xrange(_size655): - _elem660 = iprot.readString(); - self.part_vals.append(_elem660) + (_etype665, _size662) = iprot.readListBegin() + for _i666 in xrange(_size662): + _elem667 = iprot.readString(); + self.part_vals.append(_elem667) iprot.readListEnd() else: iprot.skip(ftype) @@ -16915,8 +16961,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 iter661 in self.part_vals: - oprot.writeString(iter661) + for iter668 in self.part_vals: + oprot.writeString(iter668) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -16980,11 +17026,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype665, _size662) = iprot.readListBegin() - for _i666 in xrange(_size662): - _elem667 = Partition() - _elem667.read(iprot) - self.success.append(_elem667) + (_etype672, _size669) = iprot.readListBegin() + for _i673 in xrange(_size669): + _elem674 = Partition() + _elem674.read(iprot) + self.success.append(_elem674) iprot.readListEnd() else: iprot.skip(ftype) @@ -17013,8 +17059,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 iter668 in self.success: - iter668.write(oprot) + for iter675 in self.success: + iter675.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17101,10 +17147,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype672, _size669) = iprot.readListBegin() - for _i673 in xrange(_size669): - _elem674 = iprot.readString(); - self.part_vals.append(_elem674) + (_etype679, _size676) = iprot.readListBegin() + for _i680 in xrange(_size676): + _elem681 = iprot.readString(); + self.part_vals.append(_elem681) iprot.readListEnd() else: iprot.skip(ftype) @@ -17121,10 +17167,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype678, _size675) = iprot.readListBegin() - for _i679 in xrange(_size675): - _elem680 = iprot.readString(); - self.group_names.append(_elem680) + (_etype685, _size682) = iprot.readListBegin() + for _i686 in xrange(_size682): + _elem687 = iprot.readString(); + self.group_names.append(_elem687) iprot.readListEnd() else: iprot.skip(ftype) @@ -17149,8 +17195,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 iter681 in self.part_vals: - oprot.writeString(iter681) + for iter688 in self.part_vals: + oprot.writeString(iter688) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -17164,8 +17210,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 iter682 in self.group_names: - oprot.writeString(iter682) + for iter689 in self.group_names: + oprot.writeString(iter689) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17227,11 +17273,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype686, _size683) = iprot.readListBegin() - for _i687 in xrange(_size683): - _elem688 = Partition() - _elem688.read(iprot) - self.success.append(_elem688) + (_etype693, _size690) = iprot.readListBegin() + for _i694 in xrange(_size690): + _elem695 = Partition() + _elem695.read(iprot) + self.success.append(_elem695) iprot.readListEnd() else: iprot.skip(ftype) @@ -17260,8 +17306,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 iter689 in self.success: - iter689.write(oprot) + for iter696 in self.success: + iter696.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17342,10 +17388,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype693, _size690) = iprot.readListBegin() - for _i694 in xrange(_size690): - _elem695 = iprot.readString(); - self.part_vals.append(_elem695) + (_etype700, _size697) = iprot.readListBegin() + for _i701 in xrange(_size697): + _elem702 = iprot.readString(); + self.part_vals.append(_elem702) iprot.readListEnd() else: iprot.skip(ftype) @@ -17375,8 +17421,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 iter696 in self.part_vals: - oprot.writeString(iter696) + for iter703 in self.part_vals: + oprot.writeString(iter703) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -17440,10 +17486,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype700, _size697) = iprot.readListBegin() - for _i701 in xrange(_size697): - _elem702 = iprot.readString(); - self.success.append(_elem702) + (_etype707, _size704) = iprot.readListBegin() + for _i708 in xrange(_size704): + _elem709 = iprot.readString(); + self.success.append(_elem709) iprot.readListEnd() else: iprot.skip(ftype) @@ -17472,8 +17518,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 iter703 in self.success: - oprot.writeString(iter703) + for iter710 in self.success: + oprot.writeString(iter710) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17644,11 +17690,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype707, _size704) = iprot.readListBegin() - for _i708 in xrange(_size704): - _elem709 = Partition() - _elem709.read(iprot) - self.success.append(_elem709) + (_etype714, _size711) = iprot.readListBegin() + for _i715 in xrange(_size711): + _elem716 = Partition() + _elem716.read(iprot) + self.success.append(_elem716) iprot.readListEnd() else: iprot.skip(ftype) @@ -17677,8 +17723,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 iter710 in self.success: - iter710.write(oprot) + for iter717 in self.success: + iter717.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17849,11 +17895,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype714, _size711) = iprot.readListBegin() - for _i715 in xrange(_size711): - _elem716 = PartitionSpec() - _elem716.read(iprot) - self.success.append(_elem716) + (_etype721, _size718) = iprot.readListBegin() + for _i722 in xrange(_size718): + _elem723 = PartitionSpec() + _elem723.read(iprot) + self.success.append(_elem723) iprot.readListEnd() else: iprot.skip(ftype) @@ -17882,8 +17928,8 @@ class get_part_specs_by_filter_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter717 in self.success: - iter717.write(oprot) + for iter724 in self.success: + iter724.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18120,10 +18166,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype721, _size718) = iprot.readListBegin() - for _i722 in xrange(_size718): - _elem723 = iprot.readString(); - self.names.append(_elem723) + (_etype728, _size725) = iprot.readListBegin() + for _i729 in xrange(_size725): + _elem730 = iprot.readString(); + self.names.append(_elem730) iprot.readListEnd() else: iprot.skip(ftype) @@ -18148,8 +18194,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 iter724 in self.names: - oprot.writeString(iter724) + for iter731 in self.names: + oprot.writeString(iter731) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18208,11 +18254,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype728, _size725) = iprot.readListBegin() - for _i729 in xrange(_size725): - _elem730 = Partition() - _elem730.read(iprot) - self.success.append(_elem730) + (_etype735, _size732) = iprot.readListBegin() + for _i736 in xrange(_size732): + _elem737 = Partition() + _elem737.read(iprot) + self.success.append(_elem737) iprot.readListEnd() else: iprot.skip(ftype) @@ -18241,8 +18287,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 iter731 in self.success: - iter731.write(oprot) + for iter738 in self.success: + iter738.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18492,11 +18538,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype735, _size732) = iprot.readListBegin() - for _i736 in xrange(_size732): - _elem737 = Partition() - _elem737.read(iprot) - self.new_parts.append(_elem737) + (_etype742, _size739) = iprot.readListBegin() + for _i743 in xrange(_size739): + _elem744 = Partition() + _elem744.read(iprot) + self.new_parts.append(_elem744) iprot.readListEnd() else: iprot.skip(ftype) @@ -18521,8 +18567,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 iter738 in self.new_parts: - iter738.write(oprot) + for iter745 in self.new_parts: + iter745.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18861,10 +18907,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype742, _size739) = iprot.readListBegin() - for _i743 in xrange(_size739): - _elem744 = iprot.readString(); - self.part_vals.append(_elem744) + (_etype749, _size746) = iprot.readListBegin() + for _i750 in xrange(_size746): + _elem751 = iprot.readString(); + self.part_vals.append(_elem751) iprot.readListEnd() else: iprot.skip(ftype) @@ -18895,8 +18941,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 iter745 in self.part_vals: - oprot.writeString(iter745) + for iter752 in self.part_vals: + oprot.writeString(iter752) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -19038,10 +19084,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype749, _size746) = iprot.readListBegin() - for _i750 in xrange(_size746): - _elem751 = iprot.readString(); - self.part_vals.append(_elem751) + (_etype756, _size753) = iprot.readListBegin() + for _i757 in xrange(_size753): + _elem758 = iprot.readString(); + self.part_vals.append(_elem758) iprot.readListEnd() else: iprot.skip(ftype) @@ -19063,8 +19109,8 @@ class partition_name_has_valid_characters_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter752 in self.part_vals: - oprot.writeString(iter752) + for iter759 in self.part_vals: + oprot.writeString(iter759) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -19422,10 +19468,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype756, _size753) = iprot.readListBegin() - for _i757 in xrange(_size753): - _elem758 = iprot.readString(); - self.success.append(_elem758) + (_etype763, _size760) = iprot.readListBegin() + for _i764 in xrange(_size760): + _elem765 = iprot.readString(); + self.success.append(_elem765) iprot.readListEnd() else: iprot.skip(ftype) @@ -19448,8 +19494,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 iter759 in self.success: - oprot.writeString(iter759) + for iter766 in self.success: + oprot.writeString(iter766) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19573,11 +19619,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype761, _vtype762, _size760 ) = iprot.readMapBegin() - for _i764 in xrange(_size760): - _key765 = iprot.readString(); - _val766 = iprot.readString(); - self.success[_key765] = _val766 + (_ktype768, _vtype769, _size767 ) = iprot.readMapBegin() + for _i771 in xrange(_size767): + _key772 = iprot.readString(); + _val773 = iprot.readString(); + self.success[_key772] = _val773 iprot.readMapEnd() else: iprot.skip(ftype) @@ -19600,9 +19646,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 kiter767,viter768 in self.success.items(): - oprot.writeString(kiter767) - oprot.writeString(viter768) + for kiter774,viter775 in self.success.items(): + oprot.writeString(kiter774) + oprot.writeString(viter775) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19678,11 +19724,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype770, _vtype771, _size769 ) = iprot.readMapBegin() - for _i773 in xrange(_size769): - _key774 = iprot.readString(); - _val775 = iprot.readString(); - self.part_vals[_key774] = _val775 + (_ktype777, _vtype778, _size776 ) = iprot.readMapBegin() + for _i780 in xrange(_size776): + _key781 = iprot.readString(); + _val782 = iprot.readString(); + self.part_vals[_key781] = _val782 iprot.readMapEnd() else: iprot.skip(ftype) @@ -19712,9 +19758,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 kiter776,viter777 in self.part_vals.items(): - oprot.writeString(kiter776) - oprot.writeString(viter777) + for kiter783,viter784 in self.part_vals.items(): + oprot.writeString(kiter783) + oprot.writeString(viter784) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -19928,11 +19974,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype779, _vtype780, _size778 ) = iprot.readMapBegin() - for _i782 in xrange(_size778): - _key783 = iprot.readString(); - _val784 = iprot.readString(); - self.part_vals[_key783] = _val784 + (_ktype786, _vtype787, _size785 ) = iprot.readMapBegin() + for _i789 in xrange(_size785): + _key790 = iprot.readString(); + _val791 = iprot.readString(); + self.part_vals[_key790] = _val791 iprot.readMapEnd() else: iprot.skip(ftype) @@ -19962,9 +20008,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 kiter785,viter786 in self.part_vals.items(): - oprot.writeString(kiter785) - oprot.writeString(viter786) + for kiter792,viter793 in self.part_vals.items(): + oprot.writeString(kiter792) + oprot.writeString(viter793) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -21019,11 +21065,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype790, _size787) = iprot.readListBegin() - for _i791 in xrange(_size787): - _elem792 = Index() - _elem792.read(iprot) - self.success.append(_elem792) + (_etype797, _size794) = iprot.readListBegin() + for _i798 in xrange(_size794): + _elem799 = Index() + _elem799.read(iprot) + self.success.append(_elem799) iprot.readListEnd() else: iprot.skip(ftype) @@ -21052,8 +21098,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 iter793 in self.success: - iter793.write(oprot) + for iter800 in self.success: + iter800.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21208,10 +21254,10 @@ class get_index_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype797, _size794) = iprot.readListBegin() - for _i798 in xrange(_size794): - _elem799 = iprot.readString(); - self.success.append(_elem799) + (_etype804, _size801) = iprot.readListBegin() + for _i805 in xrange(_size801): + _elem806 = iprot.readString(); + self.success.append(_elem806) iprot.readListEnd() else: iprot.skip(ftype) @@ -21234,8 +21280,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 iter800 in self.success: - oprot.writeString(iter800) + for iter807 in self.success: + oprot.writeString(iter807) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -23783,10 +23829,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype804, _size801) = iprot.readListBegin() - for _i805 in xrange(_size801): - _elem806 = iprot.readString(); - self.success.append(_elem806) + (_etype811, _size808) = iprot.readListBegin() + for _i812 in xrange(_size808): + _elem813 = iprot.readString(); + self.success.append(_elem813) iprot.readListEnd() else: iprot.skip(ftype) @@ -23809,8 +23855,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 iter807 in self.success: - oprot.writeString(iter807) + for iter814 in self.success: + oprot.writeString(iter814) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24012,6 +24058,131 @@ class get_function_result: def __ne__(self, other): return not (self == other) +class get_all_functions_args: + + thrift_spec = ( + ) + + 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 + 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_all_functions_args') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + 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_all_functions_result: + """ + Attributes: + - success + - o1 + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (GetAllFunctionsResponse, GetAllFunctionsResponse.thrift_spec), 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.STRUCT: + self.success = GetAllFunctionsResponse() + self.success.read(iprot) + 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_all_functions_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + 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 create_role_args: """ Attributes: @@ -24373,10 +24544,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype811, _size808) = iprot.readListBegin() - for _i812 in xrange(_size808): - _elem813 = iprot.readString(); - self.success.append(_elem813) + (_etype818, _size815) = iprot.readListBegin() + for _i819 in xrange(_size815): + _elem820 = iprot.readString(); + self.success.append(_elem820) iprot.readListEnd() else: iprot.skip(ftype) @@ -24399,8 +24570,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 iter814 in self.success: - oprot.writeString(iter814) + for iter821 in self.success: + oprot.writeString(iter821) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24914,11 +25085,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype818, _size815) = iprot.readListBegin() - for _i819 in xrange(_size815): - _elem820 = Role() - _elem820.read(iprot) - self.success.append(_elem820) + (_etype825, _size822) = iprot.readListBegin() + for _i826 in xrange(_size822): + _elem827 = Role() + _elem827.read(iprot) + self.success.append(_elem827) iprot.readListEnd() else: iprot.skip(ftype) @@ -24941,8 +25112,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 iter821 in self.success: - iter821.write(oprot) + for iter828 in self.success: + iter828.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25451,10 +25622,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype825, _size822) = iprot.readListBegin() - for _i826 in xrange(_size822): - _elem827 = iprot.readString(); - self.group_names.append(_elem827) + (_etype832, _size829) = iprot.readListBegin() + for _i833 in xrange(_size829): + _elem834 = iprot.readString(); + self.group_names.append(_elem834) iprot.readListEnd() else: iprot.skip(ftype) @@ -25479,8 +25650,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 iter828 in self.group_names: - oprot.writeString(iter828) + for iter835 in self.group_names: + oprot.writeString(iter835) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25707,11 +25878,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype832, _size829) = iprot.readListBegin() - for _i833 in xrange(_size829): - _elem834 = HiveObjectPrivilege() - _elem834.read(iprot) - self.success.append(_elem834) + (_etype839, _size836) = iprot.readListBegin() + for _i840 in xrange(_size836): + _elem841 = HiveObjectPrivilege() + _elem841.read(iprot) + self.success.append(_elem841) iprot.readListEnd() else: iprot.skip(ftype) @@ -25734,8 +25905,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 iter835 in self.success: - iter835.write(oprot) + for iter842 in self.success: + iter842.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26233,10 +26404,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype839, _size836) = iprot.readListBegin() - for _i840 in xrange(_size836): - _elem841 = iprot.readString(); - self.group_names.append(_elem841) + (_etype846, _size843) = iprot.readListBegin() + for _i847 in xrange(_size843): + _elem848 = iprot.readString(); + self.group_names.append(_elem848) iprot.readListEnd() else: iprot.skip(ftype) @@ -26257,8 +26428,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 iter842 in self.group_names: - oprot.writeString(iter842) + for iter849 in self.group_names: + oprot.writeString(iter849) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -26313,10 +26484,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype846, _size843) = iprot.readListBegin() - for _i847 in xrange(_size843): - _elem848 = iprot.readString(); - self.success.append(_elem848) + (_etype853, _size850) = iprot.readListBegin() + for _i854 in xrange(_size850): + _elem855 = iprot.readString(); + self.success.append(_elem855) iprot.readListEnd() else: iprot.skip(ftype) @@ -26339,8 +26510,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 iter849 in self.success: - oprot.writeString(iter849) + for iter856 in self.success: + oprot.writeString(iter856) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None:
http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py index 64cd4a0..0b80390 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py @@ -9750,6 +9750,80 @@ class FireEventResponse: def __ne__(self, other): return not (self == other) +class GetAllFunctionsResponse: + """ + Attributes: + - functions + """ + + thrift_spec = ( + None, # 0 + (1, TType.LIST, 'functions', (TType.STRUCT,(Function, Function.thrift_spec)), None, ), # 1 + ) + + def __init__(self, functions=None,): + self.functions = functions + + 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.LIST: + self.functions = [] + (_etype465, _size462) = iprot.readListBegin() + for _i466 in xrange(_size462): + _elem467 = Function() + _elem467.read(iprot) + self.functions.append(_elem467) + iprot.readListEnd() + 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('GetAllFunctionsResponse') + if self.functions is not None: + oprot.writeFieldBegin('functions', TType.LIST, 1) + oprot.writeListBegin(TType.STRUCT, len(self.functions)) + for iter468 in self.functions: + iter468.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.functions) + 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 MetaException(TException): """ Attributes: http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb index a1622ae..4bd4302 100644 --- a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb +++ b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb @@ -2231,6 +2231,22 @@ class FireEventResponse ::Thrift::Struct.generate_accessors self end +class GetAllFunctionsResponse + include ::Thrift::Struct, ::Thrift::Struct_Union + FUNCTIONS = 1 + + FIELDS = { + FUNCTIONS => {:type => ::Thrift::Types::LIST, :name => 'functions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Function}, :optional => true} + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self +end + class MetaException < ::Thrift::Exception include ::Thrift::Struct, ::Thrift::Struct_Union def initialize(message=nil) http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb b/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb index 5645fe2..73a1d20 100644 --- a/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb +++ b/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb @@ -1523,6 +1523,22 @@ module ThriftHiveMetastore raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_function failed: unknown result') end + def get_all_functions() + send_get_all_functions() + return recv_get_all_functions() + end + + def send_get_all_functions() + send_message('get_all_functions', Get_all_functions_args) + end + + def recv_get_all_functions() + result = receive_message(Get_all_functions_result) + return result.success unless result.success.nil? + raise result.o1 unless result.o1.nil? + raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_all_functions failed: unknown result') + end + def create_role(role) send_create_role(role) return recv_create_role() @@ -3293,6 +3309,17 @@ module ThriftHiveMetastore write_result(result, oprot, 'get_function', seqid) end + def process_get_all_functions(seqid, iprot, oprot) + args = read_args(iprot, Get_all_functions_args) + result = Get_all_functions_result.new() + begin + result.success = @handler.get_all_functions() + rescue ::MetaException => o1 + result.o1 = o1 + end + write_result(result, oprot, 'get_all_functions', seqid) + end + def process_create_role(seqid, iprot, oprot) args = read_args(iprot, Create_role_args) result = Create_role_result.new() @@ -7143,6 +7170,39 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end + class Get_all_functions_args + include ::Thrift::Struct, ::Thrift::Struct_Union + + FIELDS = { + + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self + end + + class Get_all_functions_result + include ::Thrift::Struct, ::Thrift::Struct_Union + SUCCESS = 0 + O1 = 1 + + FIELDS = { + SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::GetAllFunctionsResponse}, + O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::MetaException} + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self + end + class Create_role_args include ::Thrift::Struct, ::Thrift::Struct_Union ROLE = 1 http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java ---------------------------------------------------------------------- diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 6c5de4e..8f6191e 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -68,6 +68,7 @@ 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.Function; +import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse; import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse; import org.apache.hadoop.hive.metastore.api.GetOpenTxnsResponse; import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest; @@ -5536,6 +5537,26 @@ public class HiveMetaStore extends ThriftHiveMetastore { } @Override + public GetAllFunctionsResponse get_all_functions() + throws MetaException { + GetAllFunctionsResponse response = new GetAllFunctionsResponse(); + startFunction("get_all_functions"); + RawStore ms = getMS(); + List<Function> allFunctions = null; + Exception ex = null; + try { + allFunctions = ms.getAllFunctions(); + } catch (Exception e) { + ex = e; + throw newMetaException(e); + } finally { + endFunction("get_all_functions", allFunctions != null, ex); + } + response.setFunctions(allFunctions); + return response; + } + + @Override public Function get_function(String dbName, String funcName) throws MetaException, NoSuchObjectException, TException { startFunction("get_function", ": " + dbName + "." + funcName); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java ---------------------------------------------------------------------- diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index a5f5053..1751bd6 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@ -76,6 +76,7 @@ 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.Function; +import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse; import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse; import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest; import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleResponse; @@ -2047,6 +2048,12 @@ public class HiveMetaStoreClient implements IMetaStoreClient { return client.get_functions(dbName, pattern); } + @Override + public GetAllFunctionsResponse getAllFunctions() + throws MetaException, TException { + return client.get_all_functions(); + } + protected void create_table_with_environment_context(Table tbl, EnvironmentContext envContext) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, TException { http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java ---------------------------------------------------------------------- diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java index 341b0ca..2bf5ece 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java @@ -59,6 +59,8 @@ import org.apache.hadoop.hive.metastore.api.ConfigValSecurityException; import org.apache.hadoop.hive.metastore.api.Database; import org.apache.hadoop.hive.metastore.api.FieldSchema; import org.apache.hadoop.hive.metastore.api.Function; +import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse; +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; @@ -1133,6 +1135,9 @@ public interface IMetaStoreClient { List<String> getFunctions(String dbName, String pattern) throws MetaException, TException; + GetAllFunctionsResponse getAllFunctions() + throws MetaException, TException; + /** * Get a structure that details valid transactions. * @return list of valid transactions http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java ---------------------------------------------------------------------- diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java index 39ab9e7..a37fbde 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -7098,6 +7098,17 @@ public class ObjectStore implements RawStore, Configurable { return func; } + private List<Function> convertToFunctions(List<MFunction> mfuncs) { + if (mfuncs == null) { + return null; + } + List<Function> functions = new ArrayList<>(); + for (MFunction mfunc : mfuncs) { + functions.add(convertToFunction(mfunc)); + } + return functions; + } + private MFunction convertToMFunction(Function func) throws InvalidObjectException { if (func == null) { return null; @@ -7257,6 +7268,23 @@ public class ObjectStore implements RawStore, Configurable { } @Override + public List<Function> getAllFunctions() throws MetaException { + boolean commited = false; + try { + openTransaction(); + Query query = pm.newQuery(MFunction.class); + List<MFunction> allFunctions = (List<MFunction>) query.execute(); + pm.retrieveAll(allFunctions); + commited = commitTransaction(); + return convertToFunctions(allFunctions); + } finally { + if (!commited) { + rollbackTransaction(); + } + } + } + + @Override public List<String> getFunctions(String dbName, String pattern) throws MetaException { boolean commited = false; Query query = null; http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java ---------------------------------------------------------------------- diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java index 2b49eab..7c85eea 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java @@ -551,6 +551,13 @@ public interface RawStore extends Configurable { public Function getFunction(String dbName, String funcName) throws MetaException; /** + * Retrieve all functions. + * @return + * @throws MetaException + */ + public List<Function> getAllFunctions() throws MetaException; + + /** * Retrieve list of function names based on name pattern. * @param dbName * @param pattern http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java ---------------------------------------------------------------------- diff --git a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java index cf068e4..f184c56 100644 --- a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java +++ b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java @@ -19,6 +19,7 @@ package org.apache.hadoop.hive.metastore; import java.util.ArrayList; +import java.util.Collections; import java.util.List; import java.util.Map; import java.util.SortedSet; @@ -719,6 +720,12 @@ public class DummyRawStoreControlledCommit implements RawStore, Configurable { } @Override + public List<Function> getAllFunctions() + throws MetaException { + return Collections.emptyList(); + } + + @Override public List<String> getFunctions(String dbName, String pattern) throws MetaException { return objectStore.getFunctions(dbName, pattern); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java ---------------------------------------------------------------------- diff --git a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java index ccf928a..83fb4bb 100644 --- a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java +++ b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java @@ -733,6 +733,12 @@ public class DummyRawStoreForJdoConnection implements RawStore { } @Override + public List<Function> getAllFunctions() + throws MetaException { + return Collections.emptyList(); + } + + @Override public List<String> getFunctions(String dbName, String pattern) throws MetaException { return Collections.emptyList(); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java ---------------------------------------------------------------------- diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java index b71f4ae..5ea9b6e 100644 --- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java +++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") public class Adjacency implements org.apache.thrift.TBase<Adjacency, Adjacency._Fields>, java.io.Serializable, Cloneable, Comparable<Adjacency> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Adjacency"); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java ---------------------------------------------------------------------- diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java index d02c86d..e621cfa 100644 --- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java +++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") public class Graph implements org.apache.thrift.TBase<Graph, Graph._Fields>, java.io.Serializable, Cloneable, Comparable<Graph> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Graph"); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java ---------------------------------------------------------------------- diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java index 52cccad..1b18aab 100644 --- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java +++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") public class Operator implements org.apache.thrift.TBase<Operator, Operator._Fields>, java.io.Serializable, Cloneable, Comparable<Operator> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Operator"); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java ---------------------------------------------------------------------- diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java index bd6c7ca..5c5e0f8 100644 --- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java +++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") public class Query implements org.apache.thrift.TBase<Query, Query._Fields>, java.io.Serializable, Cloneable, Comparable<Query> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Query"); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java ---------------------------------------------------------------------- diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java index 8bae7ad..d340d58 100644 --- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java +++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") public class QueryPlan implements org.apache.thrift.TBase<QueryPlan, QueryPlan._Fields>, java.io.Serializable, Cloneable, Comparable<QueryPlan> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("QueryPlan"); http://git-wip-us.apache.org/repos/asf/hive/blob/e934eba1/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java ---------------------------------------------------------------------- diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java index 82a2b92..7353933 100644 --- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java +++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") public class Stage implements org.apache.thrift.TBase<Stage, Stage._Fields>, java.io.Serializable, Cloneable, Comparable<Stage> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Stage");
