Modified: hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/ThriftHiveMetastore.php URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/ThriftHiveMetastore.php?rev=1200442&r1=1200441&r2=1200442&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/ThriftHiveMetastore.php (original) +++ hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/ThriftHiveMetastore.php Thu Nov 10 17:29:49 2011 @@ -47,7 +47,8 @@ interface ThriftHiveMetastoreIf extends public function get_partition_names_ps($db_name, $tbl_name, $part_vals, $max_parts); public function get_partitions_by_filter($db_name, $tbl_name, $filter, $max_parts); public function get_partitions_by_names($db_name, $tbl_name, $names); - public function alter_partition($db_name, $tbl_name, $part_vals, $new_part); + public function alter_partition($db_name, $tbl_name, $new_part); + public function rename_partition($db_name, $tbl_name, $part_vals, $new_part); public function get_config_value($name, $defaultValue); public function partition_name_to_vals($part_name); public function partition_name_to_spec($part_name); @@ -2240,18 +2241,17 @@ class ThriftHiveMetastoreClient extends throw new Exception("get_partitions_by_names failed: unknown result"); } - public function alter_partition($db_name, $tbl_name, $part_vals, $new_part) + public function alter_partition($db_name, $tbl_name, $new_part) { - $this->send_alter_partition($db_name, $tbl_name, $part_vals, $new_part); + $this->send_alter_partition($db_name, $tbl_name, $new_part); $this->recv_alter_partition(); } - public function send_alter_partition($db_name, $tbl_name, $part_vals, $new_part) + public function send_alter_partition($db_name, $tbl_name, $new_part) { $args = new ThriftHiveMetastore_alter_partition_args(); $args->db_name = $db_name; $args->tbl_name = $tbl_name; - $args->part_vals = $part_vals; $args->new_part = $new_part; $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) @@ -2297,6 +2297,63 @@ class ThriftHiveMetastoreClient extends return; } + public function rename_partition($db_name, $tbl_name, $part_vals, $new_part) + { + $this->send_rename_partition($db_name, $tbl_name, $part_vals, $new_part); + $this->recv_rename_partition(); + } + + public function send_rename_partition($db_name, $tbl_name, $part_vals, $new_part) + { + $args = new ThriftHiveMetastore_rename_partition_args(); + $args->db_name = $db_name; + $args->tbl_name = $tbl_name; + $args->part_vals = $part_vals; + $args->new_part = $new_part; + $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); + if ($bin_accel) + { + thrift_protocol_write_binary($this->output_, 'rename_partition', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + } + else + { + $this->output_->writeMessageBegin('rename_partition', TMessageType::CALL, $this->seqid_); + $args->write($this->output_); + $this->output_->writeMessageEnd(); + $this->output_->getTransport()->flush(); + } + } + + public function recv_rename_partition() + { + $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, 'ThriftHiveMetastore_rename_partition_result', $this->input_->isStrictRead()); + else + { + $rseqid = 0; + $fname = null; + $mtype = 0; + + $this->input_->readMessageBegin($fname, $mtype, $rseqid); + if ($mtype == TMessageType::EXCEPTION) { + $x = new TApplicationException(); + $x->read($this->input_); + $this->input_->readMessageEnd(); + throw $x; + } + $result = new ThriftHiveMetastore_rename_partition_result(); + $result->read($this->input_); + $this->input_->readMessageEnd(); + } + if ($result->o1 !== null) { + throw $result->o1; + } + if ($result->o2 !== null) { + throw $result->o2; + } + return; + } + public function get_config_value($name, $defaultValue) { $this->send_get_config_value($name, $defaultValue); @@ -12602,6 +12659,219 @@ class ThriftHiveMetastore_alter_partitio public $db_name = null; public $tbl_name = null; + public $new_part = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'db_name', + 'type' => TType::STRING, + ), + 2 => array( + 'var' => 'tbl_name', + 'type' => TType::STRING, + ), + 3 => array( + 'var' => 'new_part', + 'type' => TType::STRUCT, + 'class' => 'Partition', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['db_name'])) { + $this->db_name = $vals['db_name']; + } + if (isset($vals['tbl_name'])) { + $this->tbl_name = $vals['tbl_name']; + } + if (isset($vals['new_part'])) { + $this->new_part = $vals['new_part']; + } + } + } + + public function getName() { + return 'ThriftHiveMetastore_alter_partition_args'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->db_name); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->tbl_name); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRUCT) { + $this->new_part = new Partition(); + $xfer += $this->new_part->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_partition_args'); + if ($this->db_name !== null) { + $xfer += $output->writeFieldBegin('db_name', TType::STRING, 1); + $xfer += $output->writeString($this->db_name); + $xfer += $output->writeFieldEnd(); + } + if ($this->tbl_name !== null) { + $xfer += $output->writeFieldBegin('tbl_name', TType::STRING, 2); + $xfer += $output->writeString($this->tbl_name); + $xfer += $output->writeFieldEnd(); + } + if ($this->new_part !== null) { + if (!is_object($this->new_part)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('new_part', TType::STRUCT, 3); + $xfer += $this->new_part->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ThriftHiveMetastore_alter_partition_result { + static $_TSPEC; + + public $o1 = null; + public $o2 = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'o1', + 'type' => TType::STRUCT, + 'class' => 'InvalidOperationException', + ), + 2 => array( + 'var' => 'o2', + 'type' => TType::STRUCT, + 'class' => 'MetaException', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['o1'])) { + $this->o1 = $vals['o1']; + } + if (isset($vals['o2'])) { + $this->o2 = $vals['o2']; + } + } + } + + public function getName() { + return 'ThriftHiveMetastore_alter_partition_result'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::STRUCT) { + $this->o1 = new InvalidOperationException(); + $xfer += $this->o1->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRUCT) { + $this->o2 = new MetaException(); + $xfer += $this->o2->read($input); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_partition_result'); + if ($this->o1 !== null) { + $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1); + $xfer += $this->o1->write($output); + $xfer += $output->writeFieldEnd(); + } + if ($this->o2 !== null) { + $xfer += $output->writeFieldBegin('o2', TType::STRUCT, 2); + $xfer += $this->o2->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class ThriftHiveMetastore_rename_partition_args { + static $_TSPEC; + + public $db_name = null; + public $tbl_name = null; public $part_vals = null; public $new_part = null; @@ -12648,7 +12918,7 @@ class ThriftHiveMetastore_alter_partitio } public function getName() { - return 'ThriftHiveMetastore_alter_partition_args'; + return 'ThriftHiveMetastore_rename_partition_args'; } public function read($input) @@ -12717,7 +12987,7 @@ class ThriftHiveMetastore_alter_partitio public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_partition_args'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_rename_partition_args'); if ($this->db_name !== null) { $xfer += $output->writeFieldBegin('db_name', TType::STRING, 1); $xfer += $output->writeString($this->db_name); @@ -12760,7 +13030,7 @@ class ThriftHiveMetastore_alter_partitio } -class ThriftHiveMetastore_alter_partition_result { +class ThriftHiveMetastore_rename_partition_result { static $_TSPEC; public $o1 = null; @@ -12792,7 +13062,7 @@ class ThriftHiveMetastore_alter_partitio } public function getName() { - return 'ThriftHiveMetastore_alter_partition_result'; + return 'ThriftHiveMetastore_rename_partition_result'; } public function read($input) @@ -12838,7 +13108,7 @@ class ThriftHiveMetastore_alter_partitio public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_partition_result'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_rename_partition_result'); if ($this->o1 !== null) { $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1); $xfer += $this->o1->write($output);
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1200442&r1=1200441&r2=1200442&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Thu Nov 10 17:29:49 2011 @@ -58,7 +58,8 @@ if len(sys.argv) <= 1 or sys.argv[1] == print ' get_partition_names_ps(string db_name, string tbl_name, part_vals, i16 max_parts)' print ' get_partitions_by_filter(string db_name, string tbl_name, string filter, i16 max_parts)' print ' get_partitions_by_names(string db_name, string tbl_name, names)' - print ' void alter_partition(string db_name, string tbl_name, part_vals, Partition new_part)' + print ' void alter_partition(string db_name, string tbl_name, Partition new_part)' + print ' void rename_partition(string db_name, string tbl_name, part_vals, Partition new_part)' print ' string get_config_value(string name, string defaultValue)' print ' partition_name_to_vals(string part_name)' print ' partition_name_to_spec(string part_name)' @@ -356,10 +357,16 @@ elif cmd == 'get_partitions_by_names': pp.pprint(client.get_partitions_by_names(args[0],args[1],eval(args[2]),)) elif cmd == 'alter_partition': + if len(args) != 3: + print 'alter_partition requires 3 args' + sys.exit(1) + pp.pprint(client.alter_partition(args[0],args[1],eval(args[2]),)) + +elif cmd == 'rename_partition': if len(args) != 4: - print 'alter_partition requires 4 args' + print 'rename_partition requires 4 args' sys.exit(1) - pp.pprint(client.alter_partition(args[0],args[1],eval(args[2]),eval(args[3]),)) + pp.pprint(client.rename_partition(args[0],args[1],eval(args[2]),eval(args[3]),)) elif cmd == 'get_config_value': if len(args) != 2: 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=1200442&r1=1200441&r2=1200442&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 Thu Nov 10 17:29:49 2011 @@ -331,7 +331,16 @@ class Iface(fb303.FacebookService.Iface) """ pass - def alter_partition(self, db_name, tbl_name, part_vals, new_part): + def alter_partition(self, db_name, tbl_name, new_part): + """ + Parameters: + - db_name + - tbl_name + - new_part + """ + pass + + def rename_partition(self, db_name, tbl_name, part_vals, new_part): """ Parameters: - db_name @@ -1909,23 +1918,21 @@ class Client(fb303.FacebookService.Clien raise result.o2 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result"); - def alter_partition(self, db_name, tbl_name, part_vals, new_part): + def alter_partition(self, db_name, tbl_name, new_part): """ Parameters: - db_name - tbl_name - - part_vals - new_part """ - self.send_alter_partition(db_name, tbl_name, part_vals, new_part) + self.send_alter_partition(db_name, tbl_name, new_part) self.recv_alter_partition() - def send_alter_partition(self, db_name, tbl_name, part_vals, new_part): + def send_alter_partition(self, db_name, tbl_name, new_part): self._oprot.writeMessageBegin('alter_partition', TMessageType.CALL, self._seqid) args = alter_partition_args() args.db_name = db_name args.tbl_name = tbl_name - args.part_vals = part_vals args.new_part = new_part args.write(self._oprot) self._oprot.writeMessageEnd() @@ -1947,6 +1954,44 @@ class Client(fb303.FacebookService.Clien raise result.o2 return + def rename_partition(self, db_name, tbl_name, part_vals, new_part): + """ + Parameters: + - db_name + - tbl_name + - part_vals + - new_part + """ + self.send_rename_partition(db_name, tbl_name, part_vals, new_part) + self.recv_rename_partition() + + def send_rename_partition(self, db_name, tbl_name, part_vals, new_part): + self._oprot.writeMessageBegin('rename_partition', TMessageType.CALL, self._seqid) + args = rename_partition_args() + args.db_name = db_name + args.tbl_name = tbl_name + args.part_vals = part_vals + args.new_part = new_part + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_rename_partition(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = rename_partition_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + return + def get_config_value(self, name, defaultValue): """ Parameters: @@ -2844,6 +2889,7 @@ class Processor(fb303.FacebookService.Pr self._processMap["get_partitions_by_filter"] = Processor.process_get_partitions_by_filter self._processMap["get_partitions_by_names"] = Processor.process_get_partitions_by_names self._processMap["alter_partition"] = Processor.process_alter_partition + self._processMap["rename_partition"] = Processor.process_rename_partition self._processMap["get_config_value"] = Processor.process_get_config_value self._processMap["partition_name_to_vals"] = Processor.process_partition_name_to_vals self._processMap["partition_name_to_spec"] = Processor.process_partition_name_to_spec @@ -3492,7 +3538,7 @@ class Processor(fb303.FacebookService.Pr iprot.readMessageEnd() result = alter_partition_result() try: - self._handler.alter_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part) + self._handler.alter_partition(args.db_name, args.tbl_name, args.new_part) except InvalidOperationException, o1: result.o1 = o1 except MetaException, o2: @@ -3502,6 +3548,22 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() + def process_rename_partition(self, seqid, iprot, oprot): + args = rename_partition_args() + args.read(iprot) + iprot.readMessageEnd() + result = rename_partition_result() + try: + self._handler.rename_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part) + except InvalidOperationException, o1: + result.o1 = o1 + except MetaException, o2: + result.o2 = o2 + oprot.writeMessageBegin("rename_partition", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_get_config_value(self, seqid, iprot, oprot): args = get_config_value_args() args.read(iprot) @@ -10164,6 +10226,165 @@ class alter_partition_args: Attributes: - db_name - tbl_name + - new_part + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'tbl_name', None, None, ), # 2 + (3, TType.STRUCT, 'new_part', (Partition, Partition.thrift_spec), None, ), # 3 + ) + + def __init__(self, db_name=None, tbl_name=None, new_part=None,): + self.db_name = db_name + self.tbl_name = tbl_name + self.new_part = new_part + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.db_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.tbl_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.new_part = Partition() + self.new_part.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('alter_partition_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) + oprot.writeFieldEnd() + if self.new_part is not None: + oprot.writeFieldBegin('new_part', TType.STRUCT, 3) + self.new_part.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 alter_partition_result: + """ + Attributes: + - o1 + - o2 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 + ) + + def __init__(self, o1=None, o2=None,): + self.o1 = o1 + self.o2 = o2 + + 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.o1 = InvalidOperationException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = MetaException() + self.o2.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('alter_partition_result') + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.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 rename_partition_args: + """ + Attributes: + - db_name + - tbl_name - part_vals - new_part """ @@ -10226,7 +10447,7 @@ class alter_partition_args: 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('alter_partition_args') + oprot.writeStructBegin('rename_partition_args') if self.db_name is not None: oprot.writeFieldBegin('db_name', TType.STRING, 1) oprot.writeString(self.db_name) @@ -10264,7 +10485,7 @@ class alter_partition_args: def __ne__(self, other): return not (self == other) -class alter_partition_result: +class rename_partition_result: """ Attributes: - o1 @@ -10311,7 +10532,7 @@ class alter_partition_result: 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('alter_partition_result') + oprot.writeStructBegin('rename_partition_result') if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) self.o1.write(oprot) 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=1200442&r1=1200441&r2=1200442&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 Thu Nov 10 17:29:49 2011 @@ -640,13 +640,13 @@ module ThriftHiveMetastore raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_partitions_by_names failed: unknown result') end - def alter_partition(db_name, tbl_name, part_vals, new_part) - send_alter_partition(db_name, tbl_name, part_vals, new_part) + def alter_partition(db_name, tbl_name, new_part) + send_alter_partition(db_name, tbl_name, new_part) recv_alter_partition() end - def send_alter_partition(db_name, tbl_name, part_vals, new_part) - send_message('alter_partition', Alter_partition_args, :db_name => db_name, :tbl_name => tbl_name, :part_vals => part_vals, :new_part => new_part) + def send_alter_partition(db_name, tbl_name, new_part) + send_message('alter_partition', Alter_partition_args, :db_name => db_name, :tbl_name => tbl_name, :new_part => new_part) end def recv_alter_partition() @@ -656,6 +656,22 @@ module ThriftHiveMetastore return end + def rename_partition(db_name, tbl_name, part_vals, new_part) + send_rename_partition(db_name, tbl_name, part_vals, new_part) + recv_rename_partition() + end + + def send_rename_partition(db_name, tbl_name, part_vals, new_part) + send_message('rename_partition', Rename_partition_args, :db_name => db_name, :tbl_name => tbl_name, :part_vals => part_vals, :new_part => new_part) + end + + def recv_rename_partition() + result = receive_message(Rename_partition_result) + raise result.o1 unless result.o1.nil? + raise result.o2 unless result.o2.nil? + return + end + def get_config_value(name, defaultValue) send_get_config_value(name, defaultValue) return recv_get_config_value() @@ -1553,7 +1569,7 @@ module ThriftHiveMetastore args = read_args(iprot, Alter_partition_args) result = Alter_partition_result.new() begin - @handler.alter_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part) + @handler.alter_partition(args.db_name, args.tbl_name, args.new_part) rescue InvalidOperationException => o1 result.o1 = o1 rescue MetaException => o2 @@ -1562,6 +1578,19 @@ module ThriftHiveMetastore write_result(result, oprot, 'alter_partition', seqid) end + def process_rename_partition(seqid, iprot, oprot) + args = read_args(iprot, Rename_partition_args) + result = Rename_partition_result.new() + begin + @handler.rename_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part) + rescue InvalidOperationException => o1 + result.o1 = o1 + rescue MetaException => o2 + result.o2 = o2 + end + write_result(result, oprot, 'rename_partition', seqid) + end + def process_get_config_value(seqid, iprot, oprot) args = read_args(iprot, Get_config_value_args) result = Get_config_value_result.new() @@ -3307,6 +3336,44 @@ module ThriftHiveMetastore include ::Thrift::Struct, ::Thrift::Struct_Union DB_NAME = 1 TBL_NAME = 2 + NEW_PART = 3 + + FIELDS = { + DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, + TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'}, + NEW_PART => {:type => ::Thrift::Types::STRUCT, :name => 'new_part', :class => Partition} + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self + end + + class Alter_partition_result + include ::Thrift::Struct, ::Thrift::Struct_Union + O1 = 1 + O2 = 2 + + FIELDS = { + O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => InvalidOperationException}, + O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => MetaException} + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self + end + + class Rename_partition_args + include ::Thrift::Struct, ::Thrift::Struct_Union + DB_NAME = 1 + TBL_NAME = 2 PART_VALS = 3 NEW_PART = 4 @@ -3325,7 +3392,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class Alter_partition_result + class Rename_partition_result include ::Thrift::Struct, ::Thrift::Struct_Union O1 = 1 O2 = 2 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=1200442&r1=1200441&r2=1200442&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 Thu Nov 10 17:29:49 2011 @@ -1821,6 +1821,13 @@ public class HiveMetaStore extends Thrif } public void alter_partition(final String db_name, final String tbl_name, + final Partition new_part) + throws InvalidOperationException, MetaException, + TException { + rename_partition(db_name, tbl_name, null, new_part); + } + + public void rename_partition(final String db_name, final String tbl_name, final List<String> part_vals, final Partition new_part) throws InvalidOperationException, MetaException, TException { 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=1200442&r1=1200441&r2=1200442&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 Thu Nov 10 17:29:49 2011 @@ -180,7 +180,7 @@ public class HiveMetaStoreClient impleme */ public void renamePartition(final String dbname, final String name, final List<String> part_vals, final Partition newPart) throws InvalidOperationException, MetaException, TException { - client.alter_partition(dbname, name, part_vals, newPart); + client.rename_partition(dbname, name, part_vals, newPart); } private void open() throws MetaException { @@ -794,7 +794,7 @@ public class HiveMetaStoreClient impleme public void alter_partition(String dbName, String tblName, Partition newPart) throws InvalidOperationException, MetaException, TException { - client.alter_partition(dbName, tblName, null, newPart); + client.alter_partition(dbName, tblName, newPart); } public void alterDatabase(String dbName, Database db)
