You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sd...@apache.org on 2011/10/29 02:07:12 UTC
svn commit: r1190696 [1/3] - in /hive/trunk: metastore/if/
metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen/thrift/gen-php/hive_metastore/
metastore/src/gen/thrift/gen-py/hi...
Author: sdong
Date: Sat Oct 29 00:07:10 2011
New Revision: 1190696
URL: http://svn.apache.org/viewvc?rev=1190696&view=rev
Log:
HIVE-2247 ALTER TABLE RENAME PARTITION (Weiyan Wang via. Siying Dong)
Added:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/RenamePartitionDesc.java
hive/trunk/ql/src/test/queries/clientnegative/alter_rename_partition_failure.q
hive/trunk/ql/src/test/queries/clientnegative/alter_rename_partition_failure2.q
hive/trunk/ql/src/test/queries/clientnegative/alter_rename_partition_failure3.q
hive/trunk/ql/src/test/queries/clientpositive/alter_rename_partition.q
hive/trunk/ql/src/test/queries/clientpositive/alter_rename_partition_authorization.q
hive/trunk/ql/src/test/results/clientnegative/alter_rename_partition_failure.q.out
hive/trunk/ql/src/test/results/clientnegative/alter_rename_partition_failure2.q.out
hive/trunk/ql/src/test/results/clientnegative/alter_rename_partition_failure3.q.out
hive/trunk/ql/src/test/results/clientpositive/alter_rename_partition.q.out
hive/trunk/ql/src/test/results/clientpositive/alter_rename_partition_authorization.q.out
Modified:
hive/trunk/metastore/if/hive_metastore.thrift
hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp
hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
hive/trunk/metastore/src/gen/thrift/gen-php/hive_metastore/ThriftHiveMetastore.php
hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
hive/trunk/metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/metadata/Partition.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/Hive.g
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzerFactory.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/AlterTableDesc.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/DDLWork.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/HiveOperation.java
Modified: hive/trunk/metastore/if/hive_metastore.thrift
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/if/hive_metastore.thrift?rev=1190696&r1=1190695&r2=1190696&view=diff
==============================================================================
--- hive/trunk/metastore/if/hive_metastore.thrift (original)
+++ hive/trunk/metastore/if/hive_metastore.thrift Sat Oct 29 00:07:10 2011
@@ -366,10 +366,10 @@ service ThriftHiveMetastore extends fb30
throws(1:MetaException o1, 2:NoSuchObjectException o2)
// changes the partition to the new partition object. partition is identified from the part values
- // in the new_part
+ // in the new_part if part_vals == null, otherwise, partition is identified from part_vals
// * See notes on DDL_TIME
- void alter_partition(1:string db_name, 2:string tbl_name, 3:Partition new_part)
- throws(1:InvalidOperationException o1, 2:MetaException o2)
+ void alter_partition(1:string db_name, 2:string tbl_name, 3:list<string> part_vals, 4:Partition new_part)
+ throws (1:InvalidOperationException o1, 2:MetaException o2)
// gets the value of the configuration key in the metastore server. returns
// defaultValue if the key does not exist. if the configuration key does not
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp?rev=1190696&r1=1190695&r2=1190696&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp Sat Oct 29 00:07:10 2011
@@ -9035,6 +9035,26 @@ uint32_t ThriftHiveMetastore_alter_parti
}
break;
case 3:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->part_vals.clear();
+ uint32_t _size437;
+ ::apache::thrift::protocol::TType _etype440;
+ iprot->readListBegin(_etype440, _size437);
+ this->part_vals.resize(_size437);
+ uint32_t _i441;
+ for (_i441 = 0; _i441 < _size437; ++_i441)
+ {
+ xfer += iprot->readString(this->part_vals[_i441]);
+ }
+ iprot->readListEnd();
+ }
+ this->__isset.part_vals = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
if (ftype == ::apache::thrift::protocol::T_STRUCT) {
xfer += this->new_part.read(iprot);
this->__isset.new_part = true;
@@ -9063,7 +9083,18 @@ uint32_t ThriftHiveMetastore_alter_parti
xfer += oprot->writeFieldBegin("tbl_name", ::apache::thrift::protocol::T_STRING, 2);
xfer += oprot->writeString(this->tbl_name);
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("new_part", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->part_vals.size()));
+ std::vector<std::string> ::const_iterator _iter442;
+ for (_iter442 = this->part_vals.begin(); _iter442 != this->part_vals.end(); ++_iter442)
+ {
+ xfer += oprot->writeString((*_iter442));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("new_part", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += this->new_part.write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -9080,7 +9111,18 @@ uint32_t ThriftHiveMetastore_alter_parti
xfer += oprot->writeFieldBegin("tbl_name", ::apache::thrift::protocol::T_STRING, 2);
xfer += oprot->writeString((*(this->tbl_name)));
xfer += oprot->writeFieldEnd();
- xfer += oprot->writeFieldBegin("new_part", ::apache::thrift::protocol::T_STRUCT, 3);
+ xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>((*(this->part_vals)).size()));
+ std::vector<std::string> ::const_iterator _iter443;
+ for (_iter443 = (*(this->part_vals)).begin(); _iter443 != (*(this->part_vals)).end(); ++_iter443)
+ {
+ xfer += oprot->writeString((*_iter443));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("new_part", ::apache::thrift::protocol::T_STRUCT, 4);
xfer += (*(this->new_part)).write(oprot);
xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
@@ -9482,14 +9524,14 @@ uint32_t ThriftHiveMetastore_partition_n
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size437;
- ::apache::thrift::protocol::TType _etype440;
- iprot->readListBegin(_etype440, _size437);
- this->success.resize(_size437);
- uint32_t _i441;
- for (_i441 = 0; _i441 < _size437; ++_i441)
+ uint32_t _size444;
+ ::apache::thrift::protocol::TType _etype447;
+ iprot->readListBegin(_etype447, _size444);
+ this->success.resize(_size444);
+ uint32_t _i448;
+ for (_i448 = 0; _i448 < _size444; ++_i448)
{
- xfer += iprot->readString(this->success[_i441]);
+ xfer += iprot->readString(this->success[_i448]);
}
iprot->readListEnd();
}
@@ -9528,10 +9570,10 @@ uint32_t ThriftHiveMetastore_partition_n
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::vector<std::string> ::const_iterator _iter442;
- for (_iter442 = this->success.begin(); _iter442 != this->success.end(); ++_iter442)
+ std::vector<std::string> ::const_iterator _iter449;
+ for (_iter449 = this->success.begin(); _iter449 != this->success.end(); ++_iter449)
{
- xfer += oprot->writeString((*_iter442));
+ xfer += oprot->writeString((*_iter449));
}
xfer += oprot->writeListEnd();
}
@@ -9570,14 +9612,14 @@ uint32_t ThriftHiveMetastore_partition_n
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size443;
- ::apache::thrift::protocol::TType _etype446;
- iprot->readListBegin(_etype446, _size443);
- (*(this->success)).resize(_size443);
- uint32_t _i447;
- for (_i447 = 0; _i447 < _size443; ++_i447)
+ uint32_t _size450;
+ ::apache::thrift::protocol::TType _etype453;
+ iprot->readListBegin(_etype453, _size450);
+ (*(this->success)).resize(_size450);
+ uint32_t _i454;
+ for (_i454 = 0; _i454 < _size450; ++_i454)
{
- xfer += iprot->readString((*(this->success))[_i447]);
+ xfer += iprot->readString((*(this->success))[_i454]);
}
iprot->readListEnd();
}
@@ -9692,17 +9734,17 @@ uint32_t ThriftHiveMetastore_partition_n
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size448;
- ::apache::thrift::protocol::TType _ktype449;
- ::apache::thrift::protocol::TType _vtype450;
- iprot->readMapBegin(_ktype449, _vtype450, _size448);
- uint32_t _i452;
- for (_i452 = 0; _i452 < _size448; ++_i452)
+ uint32_t _size455;
+ ::apache::thrift::protocol::TType _ktype456;
+ ::apache::thrift::protocol::TType _vtype457;
+ iprot->readMapBegin(_ktype456, _vtype457, _size455);
+ uint32_t _i459;
+ for (_i459 = 0; _i459 < _size455; ++_i459)
{
- std::string _key453;
- xfer += iprot->readString(_key453);
- std::string& _val454 = this->success[_key453];
- xfer += iprot->readString(_val454);
+ std::string _key460;
+ xfer += iprot->readString(_key460);
+ std::string& _val461 = this->success[_key460];
+ xfer += iprot->readString(_val461);
}
iprot->readMapEnd();
}
@@ -9741,11 +9783,11 @@ uint32_t ThriftHiveMetastore_partition_n
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::map<std::string, std::string> ::const_iterator _iter455;
- for (_iter455 = this->success.begin(); _iter455 != this->success.end(); ++_iter455)
+ std::map<std::string, std::string> ::const_iterator _iter462;
+ for (_iter462 = this->success.begin(); _iter462 != this->success.end(); ++_iter462)
{
- xfer += oprot->writeString(_iter455->first);
- xfer += oprot->writeString(_iter455->second);
+ xfer += oprot->writeString(_iter462->first);
+ xfer += oprot->writeString(_iter462->second);
}
xfer += oprot->writeMapEnd();
}
@@ -9784,17 +9826,17 @@ uint32_t ThriftHiveMetastore_partition_n
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size456;
- ::apache::thrift::protocol::TType _ktype457;
- ::apache::thrift::protocol::TType _vtype458;
- iprot->readMapBegin(_ktype457, _vtype458, _size456);
- uint32_t _i460;
- for (_i460 = 0; _i460 < _size456; ++_i460)
+ uint32_t _size463;
+ ::apache::thrift::protocol::TType _ktype464;
+ ::apache::thrift::protocol::TType _vtype465;
+ iprot->readMapBegin(_ktype464, _vtype465, _size463);
+ uint32_t _i467;
+ for (_i467 = 0; _i467 < _size463; ++_i467)
{
- std::string _key461;
- xfer += iprot->readString(_key461);
- std::string& _val462 = (*(this->success))[_key461];
- xfer += iprot->readString(_val462);
+ std::string _key468;
+ xfer += iprot->readString(_key468);
+ std::string& _val469 = (*(this->success))[_key468];
+ xfer += iprot->readString(_val469);
}
iprot->readMapEnd();
}
@@ -9863,17 +9905,17 @@ uint32_t ThriftHiveMetastore_markPartiti
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->part_vals.clear();
- uint32_t _size463;
- ::apache::thrift::protocol::TType _ktype464;
- ::apache::thrift::protocol::TType _vtype465;
- iprot->readMapBegin(_ktype464, _vtype465, _size463);
- uint32_t _i467;
- for (_i467 = 0; _i467 < _size463; ++_i467)
+ uint32_t _size470;
+ ::apache::thrift::protocol::TType _ktype471;
+ ::apache::thrift::protocol::TType _vtype472;
+ iprot->readMapBegin(_ktype471, _vtype472, _size470);
+ uint32_t _i474;
+ for (_i474 = 0; _i474 < _size470; ++_i474)
{
- std::string _key468;
- xfer += iprot->readString(_key468);
- std::string& _val469 = this->part_vals[_key468];
- xfer += iprot->readString(_val469);
+ std::string _key475;
+ xfer += iprot->readString(_key475);
+ std::string& _val476 = this->part_vals[_key475];
+ xfer += iprot->readString(_val476);
}
iprot->readMapEnd();
}
@@ -9884,9 +9926,9 @@ uint32_t ThriftHiveMetastore_markPartiti
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast470;
- xfer += iprot->readI32(ecast470);
- this->eventType = (PartitionEventType::type)ecast470;
+ int32_t ecast477;
+ xfer += iprot->readI32(ecast477);
+ this->eventType = (PartitionEventType::type)ecast477;
this->__isset.eventType = true;
} else {
xfer += iprot->skip(ftype);
@@ -9916,11 +9958,11 @@ uint32_t ThriftHiveMetastore_markPartiti
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->part_vals.size()));
- std::map<std::string, std::string> ::const_iterator _iter471;
- for (_iter471 = this->part_vals.begin(); _iter471 != this->part_vals.end(); ++_iter471)
+ std::map<std::string, std::string> ::const_iterator _iter478;
+ for (_iter478 = this->part_vals.begin(); _iter478 != this->part_vals.end(); ++_iter478)
{
- xfer += oprot->writeString(_iter471->first);
- xfer += oprot->writeString(_iter471->second);
+ xfer += oprot->writeString(_iter478->first);
+ xfer += oprot->writeString(_iter478->second);
}
xfer += oprot->writeMapEnd();
}
@@ -9945,11 +9987,11 @@ uint32_t ThriftHiveMetastore_markPartiti
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>((*(this->part_vals)).size()));
- std::map<std::string, std::string> ::const_iterator _iter472;
- for (_iter472 = (*(this->part_vals)).begin(); _iter472 != (*(this->part_vals)).end(); ++_iter472)
+ std::map<std::string, std::string> ::const_iterator _iter479;
+ for (_iter479 = (*(this->part_vals)).begin(); _iter479 != (*(this->part_vals)).end(); ++_iter479)
{
- xfer += oprot->writeString(_iter472->first);
- xfer += oprot->writeString(_iter472->second);
+ xfer += oprot->writeString(_iter479->first);
+ xfer += oprot->writeString(_iter479->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10198,17 +10240,17 @@ uint32_t ThriftHiveMetastore_isPartition
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->part_vals.clear();
- uint32_t _size473;
- ::apache::thrift::protocol::TType _ktype474;
- ::apache::thrift::protocol::TType _vtype475;
- iprot->readMapBegin(_ktype474, _vtype475, _size473);
- uint32_t _i477;
- for (_i477 = 0; _i477 < _size473; ++_i477)
+ uint32_t _size480;
+ ::apache::thrift::protocol::TType _ktype481;
+ ::apache::thrift::protocol::TType _vtype482;
+ iprot->readMapBegin(_ktype481, _vtype482, _size480);
+ uint32_t _i484;
+ for (_i484 = 0; _i484 < _size480; ++_i484)
{
- std::string _key478;
- xfer += iprot->readString(_key478);
- std::string& _val479 = this->part_vals[_key478];
- xfer += iprot->readString(_val479);
+ std::string _key485;
+ xfer += iprot->readString(_key485);
+ std::string& _val486 = this->part_vals[_key485];
+ xfer += iprot->readString(_val486);
}
iprot->readMapEnd();
}
@@ -10219,9 +10261,9 @@ uint32_t ThriftHiveMetastore_isPartition
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast480;
- xfer += iprot->readI32(ecast480);
- this->eventType = (PartitionEventType::type)ecast480;
+ int32_t ecast487;
+ xfer += iprot->readI32(ecast487);
+ this->eventType = (PartitionEventType::type)ecast487;
this->__isset.eventType = true;
} else {
xfer += iprot->skip(ftype);
@@ -10251,11 +10293,11 @@ uint32_t ThriftHiveMetastore_isPartition
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->part_vals.size()));
- std::map<std::string, std::string> ::const_iterator _iter481;
- for (_iter481 = this->part_vals.begin(); _iter481 != this->part_vals.end(); ++_iter481)
+ std::map<std::string, std::string> ::const_iterator _iter488;
+ for (_iter488 = this->part_vals.begin(); _iter488 != this->part_vals.end(); ++_iter488)
{
- xfer += oprot->writeString(_iter481->first);
- xfer += oprot->writeString(_iter481->second);
+ xfer += oprot->writeString(_iter488->first);
+ xfer += oprot->writeString(_iter488->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10280,11 +10322,11 @@ uint32_t ThriftHiveMetastore_isPartition
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>((*(this->part_vals)).size()));
- std::map<std::string, std::string> ::const_iterator _iter482;
- for (_iter482 = (*(this->part_vals)).begin(); _iter482 != (*(this->part_vals)).end(); ++_iter482)
+ std::map<std::string, std::string> ::const_iterator _iter489;
+ for (_iter489 = (*(this->part_vals)).begin(); _iter489 != (*(this->part_vals)).end(); ++_iter489)
{
- xfer += oprot->writeString(_iter482->first);
- xfer += oprot->writeString(_iter482->second);
+ xfer += oprot->writeString(_iter489->first);
+ xfer += oprot->writeString(_iter489->second);
}
xfer += oprot->writeMapEnd();
}
@@ -11545,14 +11587,14 @@ uint32_t ThriftHiveMetastore_get_indexes
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size483;
- ::apache::thrift::protocol::TType _etype486;
- iprot->readListBegin(_etype486, _size483);
- this->success.resize(_size483);
- uint32_t _i487;
- for (_i487 = 0; _i487 < _size483; ++_i487)
+ uint32_t _size490;
+ ::apache::thrift::protocol::TType _etype493;
+ iprot->readListBegin(_etype493, _size490);
+ this->success.resize(_size490);
+ uint32_t _i494;
+ for (_i494 = 0; _i494 < _size490; ++_i494)
{
- xfer += this->success[_i487].read(iprot);
+ xfer += this->success[_i494].read(iprot);
}
iprot->readListEnd();
}
@@ -11599,10 +11641,10 @@ uint32_t ThriftHiveMetastore_get_indexes
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector<Index> ::const_iterator _iter488;
- for (_iter488 = this->success.begin(); _iter488 != this->success.end(); ++_iter488)
+ std::vector<Index> ::const_iterator _iter495;
+ for (_iter495 = this->success.begin(); _iter495 != this->success.end(); ++_iter495)
{
- xfer += (*_iter488).write(oprot);
+ xfer += (*_iter495).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11645,14 +11687,14 @@ uint32_t ThriftHiveMetastore_get_indexes
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size489;
- ::apache::thrift::protocol::TType _etype492;
- iprot->readListBegin(_etype492, _size489);
- (*(this->success)).resize(_size489);
- uint32_t _i493;
- for (_i493 = 0; _i493 < _size489; ++_i493)
+ uint32_t _size496;
+ ::apache::thrift::protocol::TType _etype499;
+ iprot->readListBegin(_etype499, _size496);
+ (*(this->success)).resize(_size496);
+ uint32_t _i500;
+ for (_i500 = 0; _i500 < _size496; ++_i500)
{
- xfer += (*(this->success))[_i493].read(iprot);
+ xfer += (*(this->success))[_i500].read(iprot);
}
iprot->readListEnd();
}
@@ -11803,14 +11845,14 @@ uint32_t ThriftHiveMetastore_get_index_n
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size494;
- ::apache::thrift::protocol::TType _etype497;
- iprot->readListBegin(_etype497, _size494);
- this->success.resize(_size494);
- uint32_t _i498;
- for (_i498 = 0; _i498 < _size494; ++_i498)
+ uint32_t _size501;
+ ::apache::thrift::protocol::TType _etype504;
+ iprot->readListBegin(_etype504, _size501);
+ this->success.resize(_size501);
+ uint32_t _i505;
+ for (_i505 = 0; _i505 < _size501; ++_i505)
{
- xfer += iprot->readString(this->success[_i498]);
+ xfer += iprot->readString(this->success[_i505]);
}
iprot->readListEnd();
}
@@ -11849,10 +11891,10 @@ uint32_t ThriftHiveMetastore_get_index_n
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::vector<std::string> ::const_iterator _iter499;
- for (_iter499 = this->success.begin(); _iter499 != this->success.end(); ++_iter499)
+ std::vector<std::string> ::const_iterator _iter506;
+ for (_iter506 = this->success.begin(); _iter506 != this->success.end(); ++_iter506)
{
- xfer += oprot->writeString((*_iter499));
+ xfer += oprot->writeString((*_iter506));
}
xfer += oprot->writeListEnd();
}
@@ -11891,14 +11933,14 @@ uint32_t ThriftHiveMetastore_get_index_n
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size500;
- ::apache::thrift::protocol::TType _etype503;
- iprot->readListBegin(_etype503, _size500);
- (*(this->success)).resize(_size500);
- uint32_t _i504;
- for (_i504 = 0; _i504 < _size500; ++_i504)
+ uint32_t _size507;
+ ::apache::thrift::protocol::TType _etype510;
+ iprot->readListBegin(_etype510, _size507);
+ (*(this->success)).resize(_size507);
+ uint32_t _i511;
+ for (_i511 = 0; _i511 < _size507; ++_i511)
{
- xfer += iprot->readString((*(this->success))[_i504]);
+ xfer += iprot->readString((*(this->success))[_i511]);
}
iprot->readListEnd();
}
@@ -12355,14 +12397,14 @@ uint32_t ThriftHiveMetastore_get_role_na
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size505;
- ::apache::thrift::protocol::TType _etype508;
- iprot->readListBegin(_etype508, _size505);
- this->success.resize(_size505);
- uint32_t _i509;
- for (_i509 = 0; _i509 < _size505; ++_i509)
+ uint32_t _size512;
+ ::apache::thrift::protocol::TType _etype515;
+ iprot->readListBegin(_etype515, _size512);
+ this->success.resize(_size512);
+ uint32_t _i516;
+ for (_i516 = 0; _i516 < _size512; ++_i516)
{
- xfer += iprot->readString(this->success[_i509]);
+ xfer += iprot->readString(this->success[_i516]);
}
iprot->readListEnd();
}
@@ -12401,10 +12443,10 @@ uint32_t ThriftHiveMetastore_get_role_na
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size()));
- std::vector<std::string> ::const_iterator _iter510;
- for (_iter510 = this->success.begin(); _iter510 != this->success.end(); ++_iter510)
+ std::vector<std::string> ::const_iterator _iter517;
+ for (_iter517 = this->success.begin(); _iter517 != this->success.end(); ++_iter517)
{
- xfer += oprot->writeString((*_iter510));
+ xfer += oprot->writeString((*_iter517));
}
xfer += oprot->writeListEnd();
}
@@ -12443,14 +12485,14 @@ uint32_t ThriftHiveMetastore_get_role_na
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size511;
- ::apache::thrift::protocol::TType _etype514;
- iprot->readListBegin(_etype514, _size511);
- (*(this->success)).resize(_size511);
- uint32_t _i515;
- for (_i515 = 0; _i515 < _size511; ++_i515)
+ uint32_t _size518;
+ ::apache::thrift::protocol::TType _etype521;
+ iprot->readListBegin(_etype521, _size518);
+ (*(this->success)).resize(_size518);
+ uint32_t _i522;
+ for (_i522 = 0; _i522 < _size518; ++_i522)
{
- xfer += iprot->readString((*(this->success))[_i515]);
+ xfer += iprot->readString((*(this->success))[_i522]);
}
iprot->readListEnd();
}
@@ -12517,9 +12559,9 @@ uint32_t ThriftHiveMetastore_grant_role_
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast516;
- xfer += iprot->readI32(ecast516);
- this->principal_type = (PrincipalType::type)ecast516;
+ int32_t ecast523;
+ xfer += iprot->readI32(ecast523);
+ this->principal_type = (PrincipalType::type)ecast523;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -12535,9 +12577,9 @@ uint32_t ThriftHiveMetastore_grant_role_
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast517;
- xfer += iprot->readI32(ecast517);
- this->grantorType = (PrincipalType::type)ecast517;
+ int32_t ecast524;
+ xfer += iprot->readI32(ecast524);
+ this->grantorType = (PrincipalType::type)ecast524;
this->__isset.grantorType = true;
} else {
xfer += iprot->skip(ftype);
@@ -12769,9 +12811,9 @@ uint32_t ThriftHiveMetastore_revoke_role
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast518;
- xfer += iprot->readI32(ecast518);
- this->principal_type = (PrincipalType::type)ecast518;
+ int32_t ecast525;
+ xfer += iprot->readI32(ecast525);
+ this->principal_type = (PrincipalType::type)ecast525;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -12969,9 +13011,9 @@ uint32_t ThriftHiveMetastore_list_roles_
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast519;
- xfer += iprot->readI32(ecast519);
- this->principal_type = (PrincipalType::type)ecast519;
+ int32_t ecast526;
+ xfer += iprot->readI32(ecast526);
+ this->principal_type = (PrincipalType::type)ecast526;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -13041,14 +13083,14 @@ uint32_t ThriftHiveMetastore_list_roles_
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size520;
- ::apache::thrift::protocol::TType _etype523;
- iprot->readListBegin(_etype523, _size520);
- this->success.resize(_size520);
- uint32_t _i524;
- for (_i524 = 0; _i524 < _size520; ++_i524)
+ uint32_t _size527;
+ ::apache::thrift::protocol::TType _etype530;
+ iprot->readListBegin(_etype530, _size527);
+ this->success.resize(_size527);
+ uint32_t _i531;
+ for (_i531 = 0; _i531 < _size527; ++_i531)
{
- xfer += this->success[_i524].read(iprot);
+ xfer += this->success[_i531].read(iprot);
}
iprot->readListEnd();
}
@@ -13087,10 +13129,10 @@ uint32_t ThriftHiveMetastore_list_roles_
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector<Role> ::const_iterator _iter525;
- for (_iter525 = this->success.begin(); _iter525 != this->success.end(); ++_iter525)
+ std::vector<Role> ::const_iterator _iter532;
+ for (_iter532 = this->success.begin(); _iter532 != this->success.end(); ++_iter532)
{
- xfer += (*_iter525).write(oprot);
+ xfer += (*_iter532).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -13129,14 +13171,14 @@ uint32_t ThriftHiveMetastore_list_roles_
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size526;
- ::apache::thrift::protocol::TType _etype529;
- iprot->readListBegin(_etype529, _size526);
- (*(this->success)).resize(_size526);
- uint32_t _i530;
- for (_i530 = 0; _i530 < _size526; ++_i530)
+ uint32_t _size533;
+ ::apache::thrift::protocol::TType _etype536;
+ iprot->readListBegin(_etype536, _size533);
+ (*(this->success)).resize(_size533);
+ uint32_t _i537;
+ for (_i537 = 0; _i537 < _size533; ++_i537)
{
- xfer += (*(this->success))[_i530].read(iprot);
+ xfer += (*(this->success))[_i537].read(iprot);
}
iprot->readListEnd();
}
@@ -13205,14 +13247,14 @@ uint32_t ThriftHiveMetastore_get_privile
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->group_names.clear();
- uint32_t _size531;
- ::apache::thrift::protocol::TType _etype534;
- iprot->readListBegin(_etype534, _size531);
- this->group_names.resize(_size531);
- uint32_t _i535;
- for (_i535 = 0; _i535 < _size531; ++_i535)
+ uint32_t _size538;
+ ::apache::thrift::protocol::TType _etype541;
+ iprot->readListBegin(_etype541, _size538);
+ this->group_names.resize(_size538);
+ uint32_t _i542;
+ for (_i542 = 0; _i542 < _size538; ++_i542)
{
- xfer += iprot->readString(this->group_names[_i535]);
+ xfer += iprot->readString(this->group_names[_i542]);
}
iprot->readListEnd();
}
@@ -13245,10 +13287,10 @@ uint32_t ThriftHiveMetastore_get_privile
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->group_names.size()));
- std::vector<std::string> ::const_iterator _iter536;
- for (_iter536 = this->group_names.begin(); _iter536 != this->group_names.end(); ++_iter536)
+ std::vector<std::string> ::const_iterator _iter543;
+ for (_iter543 = this->group_names.begin(); _iter543 != this->group_names.end(); ++_iter543)
{
- xfer += oprot->writeString((*_iter536));
+ xfer += oprot->writeString((*_iter543));
}
xfer += oprot->writeListEnd();
}
@@ -13270,10 +13312,10 @@ uint32_t ThriftHiveMetastore_get_privile
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>((*(this->group_names)).size()));
- std::vector<std::string> ::const_iterator _iter537;
- for (_iter537 = (*(this->group_names)).begin(); _iter537 != (*(this->group_names)).end(); ++_iter537)
+ std::vector<std::string> ::const_iterator _iter544;
+ for (_iter544 = (*(this->group_names)).begin(); _iter544 != (*(this->group_names)).end(); ++_iter544)
{
- xfer += oprot->writeString((*_iter537));
+ xfer += oprot->writeString((*_iter544));
}
xfer += oprot->writeListEnd();
}
@@ -13429,9 +13471,9 @@ uint32_t ThriftHiveMetastore_list_privil
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast538;
- xfer += iprot->readI32(ecast538);
- this->principal_type = (PrincipalType::type)ecast538;
+ int32_t ecast545;
+ xfer += iprot->readI32(ecast545);
+ this->principal_type = (PrincipalType::type)ecast545;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -13515,14 +13557,14 @@ uint32_t ThriftHiveMetastore_list_privil
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size539;
- ::apache::thrift::protocol::TType _etype542;
- iprot->readListBegin(_etype542, _size539);
- this->success.resize(_size539);
- uint32_t _i543;
- for (_i543 = 0; _i543 < _size539; ++_i543)
+ uint32_t _size546;
+ ::apache::thrift::protocol::TType _etype549;
+ iprot->readListBegin(_etype549, _size546);
+ this->success.resize(_size546);
+ uint32_t _i550;
+ for (_i550 = 0; _i550 < _size546; ++_i550)
{
- xfer += this->success[_i543].read(iprot);
+ xfer += this->success[_i550].read(iprot);
}
iprot->readListEnd();
}
@@ -13561,10 +13603,10 @@ uint32_t ThriftHiveMetastore_list_privil
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->success.size()));
- std::vector<HiveObjectPrivilege> ::const_iterator _iter544;
- for (_iter544 = this->success.begin(); _iter544 != this->success.end(); ++_iter544)
+ std::vector<HiveObjectPrivilege> ::const_iterator _iter551;
+ for (_iter551 = this->success.begin(); _iter551 != this->success.end(); ++_iter551)
{
- xfer += (*_iter544).write(oprot);
+ xfer += (*_iter551).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -13603,14 +13645,14 @@ uint32_t ThriftHiveMetastore_list_privil
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size545;
- ::apache::thrift::protocol::TType _etype548;
- iprot->readListBegin(_etype548, _size545);
- (*(this->success)).resize(_size545);
- uint32_t _i549;
- for (_i549 = 0; _i549 < _size545; ++_i549)
+ uint32_t _size552;
+ ::apache::thrift::protocol::TType _etype555;
+ iprot->readListBegin(_etype555, _size552);
+ (*(this->success)).resize(_size552);
+ uint32_t _i556;
+ for (_i556 = 0; _i556 < _size552; ++_i556)
{
- xfer += (*(this->success))[_i549].read(iprot);
+ xfer += (*(this->success))[_i556].read(iprot);
}
iprot->readListEnd();
}
@@ -16931,13 +16973,13 @@ void ThriftHiveMetastoreClient::recv_get
throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "get_partitions_by_names failed: unknown result");
}
-void ThriftHiveMetastoreClient::alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part)
+void ThriftHiveMetastoreClient::alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part)
{
- send_alter_partition(db_name, tbl_name, new_part);
+ send_alter_partition(db_name, tbl_name, part_vals, new_part);
recv_alter_partition();
}
-void ThriftHiveMetastoreClient::send_alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part)
+void ThriftHiveMetastoreClient::send_alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part)
{
int32_t cseqid = 0;
oprot_->writeMessageBegin("alter_partition", ::apache::thrift::protocol::T_CALL, cseqid);
@@ -16945,6 +16987,7 @@ void ThriftHiveMetastoreClient::send_alt
ThriftHiveMetastore_alter_partition_pargs args;
args.db_name = &db_name;
args.tbl_name = &tbl_name;
+ args.part_vals = &part_vals;
args.new_part = &new_part;
args.write(oprot_);
@@ -20809,7 +20852,7 @@ void ThriftHiveMetastoreProcessor::proce
ThriftHiveMetastore_alter_partition_result result;
try {
- iface_->alter_partition(args.db_name, args.tbl_name, args.new_part);
+ iface_->alter_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part);
} catch (InvalidOperationException &o1) {
result.o1 = o1;
result.__isset.o1 = true;
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h?rev=1190696&r1=1190695&r2=1190696&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h Sat Oct 29 00:07:10 2011
@@ -52,7 +52,7 @@ class ThriftHiveMetastoreIf : virtual pu
virtual void get_partition_names_ps(std::vector<std::string> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts) = 0;
virtual void get_partitions_by_filter(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int16_t max_parts) = 0;
virtual void get_partitions_by_names(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & names) = 0;
- virtual void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part) = 0;
+ virtual void alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part) = 0;
virtual void get_config_value(std::string& _return, const std::string& name, const std::string& defaultValue) = 0;
virtual void partition_name_to_vals(std::vector<std::string> & _return, const std::string& part_name) = 0;
virtual void partition_name_to_spec(std::map<std::string, std::string> & _return, const std::string& part_name) = 0;
@@ -198,7 +198,7 @@ class ThriftHiveMetastoreNull : virtual
void get_partitions_by_names(std::vector<Partition> & /* _return */, const std::string& /* db_name */, const std::string& /* tbl_name */, const std::vector<std::string> & /* names */) {
return;
}
- void alter_partition(const std::string& /* db_name */, const std::string& /* tbl_name */, const Partition& /* new_part */) {
+ void alter_partition(const std::string& /* db_name */, const std::string& /* tbl_name */, const std::vector<std::string> & /* part_vals */, const Partition& /* new_part */) {
return;
}
void get_config_value(std::string& /* _return */, const std::string& /* name */, const std::string& /* defaultValue */) {
@@ -5501,9 +5501,10 @@ class ThriftHiveMetastore_get_partitions
};
typedef struct _ThriftHiveMetastore_alter_partition_args__isset {
- _ThriftHiveMetastore_alter_partition_args__isset() : db_name(false), tbl_name(false), new_part(false) {}
+ _ThriftHiveMetastore_alter_partition_args__isset() : db_name(false), tbl_name(false), part_vals(false), new_part(false) {}
bool db_name;
bool tbl_name;
+ bool part_vals;
bool new_part;
} _ThriftHiveMetastore_alter_partition_args__isset;
@@ -5517,6 +5518,7 @@ class ThriftHiveMetastore_alter_partitio
std::string db_name;
std::string tbl_name;
+ std::vector<std::string> part_vals;
Partition new_part;
_ThriftHiveMetastore_alter_partition_args__isset __isset;
@@ -5529,6 +5531,10 @@ class ThriftHiveMetastore_alter_partitio
tbl_name = val;
}
+ void __set_part_vals(const std::vector<std::string> & val) {
+ part_vals = val;
+ }
+
void __set_new_part(const Partition& val) {
new_part = val;
}
@@ -5539,6 +5545,8 @@ class ThriftHiveMetastore_alter_partitio
return false;
if (!(tbl_name == rhs.tbl_name))
return false;
+ if (!(part_vals == rhs.part_vals))
+ return false;
if (!(new_part == rhs.new_part))
return false;
return true;
@@ -5563,6 +5571,7 @@ class ThriftHiveMetastore_alter_partitio
const std::string* db_name;
const std::string* tbl_name;
+ const std::vector<std::string> * part_vals;
const Partition* new_part;
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
@@ -9004,8 +9013,8 @@ class ThriftHiveMetastoreClient : virtua
void get_partitions_by_names(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & names);
void send_get_partitions_by_names(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & names);
void recv_get_partitions_by_names(std::vector<Partition> & _return);
- void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part);
- void send_alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part);
+ void alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part);
+ void send_alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part);
void recv_alter_partition();
void get_config_value(std::string& _return, const std::string& name, const std::string& defaultValue);
void send_get_config_value(const std::string& name, const std::string& defaultValue);
@@ -9647,10 +9656,10 @@ class ThriftHiveMetastoreMultiface : vir
}
}
- void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part) {
+ void alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part) {
size_t sz = ifaces_.size();
for (size_t i = 0; i < sz; ++i) {
- ifaces_[i]->alter_partition(db_name, tbl_name, new_part);
+ ifaces_[i]->alter_partition(db_name, tbl_name, part_vals, new_part);
}
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp?rev=1190696&r1=1190695&r2=1190696&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp Sat Oct 29 00:07:10 2011
@@ -207,7 +207,7 @@ class ThriftHiveMetastoreHandler : virtu
printf("get_partitions_by_names\n");
}
- void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part) {
+ void alter_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part) {
// Your implementation goes here
printf("alter_partition\n");
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java?rev=1190696&r1=1190695&r2=1190696&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java Sat Oct 29 00:07:10 2011
@@ -101,7 +101,7 @@ public class ThriftHiveMetastore {
public List<Partition> get_partitions_by_names(String db_name, String tbl_name, List<String> names) throws MetaException, NoSuchObjectException, org.apache.thrift.TException;
- public void alter_partition(String db_name, String tbl_name, Partition new_part) throws InvalidOperationException, MetaException, org.apache.thrift.TException;
+ public void alter_partition(String db_name, String tbl_name, List<String> part_vals, Partition new_part) throws InvalidOperationException, MetaException, org.apache.thrift.TException;
public String get_config_value(String name, String defaultValue) throws ConfigValSecurityException, org.apache.thrift.TException;
@@ -229,7 +229,7 @@ public class ThriftHiveMetastore {
public void get_partitions_by_names(String db_name, String tbl_name, List<String> names, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_partitions_by_names_call> resultHandler) throws org.apache.thrift.TException;
- public void alter_partition(String db_name, String tbl_name, Partition new_part, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.alter_partition_call> resultHandler) throws org.apache.thrift.TException;
+ public void alter_partition(String db_name, String tbl_name, List<String> part_vals, Partition new_part, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.alter_partition_call> resultHandler) throws org.apache.thrift.TException;
public void get_config_value(String name, String defaultValue, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_config_value_call> resultHandler) throws org.apache.thrift.TException;
@@ -1426,17 +1426,18 @@ public class ThriftHiveMetastore {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result");
}
- public void alter_partition(String db_name, String tbl_name, Partition new_part) throws InvalidOperationException, MetaException, org.apache.thrift.TException
+ public void alter_partition(String db_name, String tbl_name, List<String> part_vals, Partition new_part) throws InvalidOperationException, MetaException, org.apache.thrift.TException
{
- send_alter_partition(db_name, tbl_name, new_part);
+ send_alter_partition(db_name, tbl_name, part_vals, new_part);
recv_alter_partition();
}
- public void send_alter_partition(String db_name, String tbl_name, Partition new_part) throws org.apache.thrift.TException
+ public void send_alter_partition(String db_name, String tbl_name, List<String> part_vals, Partition new_part) throws org.apache.thrift.TException
{
alter_partition_args args = new alter_partition_args();
args.setDb_name(db_name);
args.setTbl_name(tbl_name);
+ args.setPart_vals(part_vals);
args.setNew_part(new_part);
sendBase("alter_partition", args);
}
@@ -3516,9 +3517,9 @@ public class ThriftHiveMetastore {
}
}
- public void alter_partition(String db_name, String tbl_name, Partition new_part, org.apache.thrift.async.AsyncMethodCallback<alter_partition_call> resultHandler) throws org.apache.thrift.TException {
+ public void alter_partition(String db_name, String tbl_name, List<String> part_vals, Partition new_part, org.apache.thrift.async.AsyncMethodCallback<alter_partition_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- alter_partition_call method_call = new alter_partition_call(db_name, tbl_name, new_part, resultHandler, this, ___protocolFactory, ___transport);
+ alter_partition_call method_call = new alter_partition_call(db_name, tbl_name, part_vals, new_part, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -3526,11 +3527,13 @@ public class ThriftHiveMetastore {
public static class alter_partition_call extends org.apache.thrift.async.TAsyncMethodCall {
private String db_name;
private String tbl_name;
+ private List<String> part_vals;
private Partition new_part;
- public alter_partition_call(String db_name, String tbl_name, Partition new_part, org.apache.thrift.async.AsyncMethodCallback<alter_partition_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public alter_partition_call(String db_name, String tbl_name, List<String> part_vals, Partition new_part, org.apache.thrift.async.AsyncMethodCallback<alter_partition_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.db_name = db_name;
this.tbl_name = tbl_name;
+ this.part_vals = part_vals;
this.new_part = new_part;
}
@@ -3539,6 +3542,7 @@ public class ThriftHiveMetastore {
alter_partition_args args = new alter_partition_args();
args.setDb_name(db_name);
args.setTbl_name(tbl_name);
+ args.setPart_vals(part_vals);
args.setNew_part(new_part);
args.write(prot);
prot.writeMessageEnd();
@@ -5337,7 +5341,7 @@ public class ThriftHiveMetastore {
protected alter_partition_result getResult(I iface, alter_partition_args args) throws org.apache.thrift.TException {
alter_partition_result result = new alter_partition_result();
try {
- iface.alter_partition(args.db_name, args.tbl_name, args.new_part);
+ iface.alter_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part);
} catch (InvalidOperationException o1) {
result.o1 = o1;
} catch (MetaException o2) {
@@ -40013,17 +40017,20 @@ public class ThriftHiveMetastore {
private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2);
- private static final org.apache.thrift.protocol.TField NEW_PART_FIELD_DESC = new org.apache.thrift.protocol.TField("new_part", org.apache.thrift.protocol.TType.STRUCT, (short)3);
+ private static final org.apache.thrift.protocol.TField PART_VALS_FIELD_DESC = new org.apache.thrift.protocol.TField("part_vals", org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField NEW_PART_FIELD_DESC = new org.apache.thrift.protocol.TField("new_part", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private String db_name; // required
private String tbl_name; // required
+ private List<String> part_vals; // required
private Partition new_part; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
DB_NAME((short)1, "db_name"),
TBL_NAME((short)2, "tbl_name"),
- NEW_PART((short)3, "new_part");
+ PART_VALS((short)3, "part_vals"),
+ NEW_PART((short)4, "new_part");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -40042,7 +40049,9 @@ public class ThriftHiveMetastore {
return DB_NAME;
case 2: // TBL_NAME
return TBL_NAME;
- case 3: // NEW_PART
+ case 3: // PART_VALS
+ return PART_VALS;
+ case 4: // NEW_PART
return NEW_PART;
default:
return null;
@@ -40092,6 +40101,9 @@ public class ThriftHiveMetastore {
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.PART_VALS, new org.apache.thrift.meta_data.FieldMetaData("part_vals", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.NEW_PART, new org.apache.thrift.meta_data.FieldMetaData("new_part", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Partition.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
@@ -40104,11 +40116,13 @@ public class ThriftHiveMetastore {
public alter_partition_args(
String db_name,
String tbl_name,
+ List<String> part_vals,
Partition new_part)
{
this();
this.db_name = db_name;
this.tbl_name = tbl_name;
+ this.part_vals = part_vals;
this.new_part = new_part;
}
@@ -40122,6 +40136,13 @@ public class ThriftHiveMetastore {
if (other.isSetTbl_name()) {
this.tbl_name = other.tbl_name;
}
+ if (other.isSetPart_vals()) {
+ List<String> __this__part_vals = new ArrayList<String>();
+ for (String other_element : other.part_vals) {
+ __this__part_vals.add(other_element);
+ }
+ this.part_vals = __this__part_vals;
+ }
if (other.isSetNew_part()) {
this.new_part = new Partition(other.new_part);
}
@@ -40135,6 +40156,7 @@ public class ThriftHiveMetastore {
public void clear() {
this.db_name = null;
this.tbl_name = null;
+ this.part_vals = null;
this.new_part = null;
}
@@ -40184,6 +40206,44 @@ public class ThriftHiveMetastore {
}
}
+ public int getPart_valsSize() {
+ return (this.part_vals == null) ? 0 : this.part_vals.size();
+ }
+
+ public java.util.Iterator<String> getPart_valsIterator() {
+ return (this.part_vals == null) ? null : this.part_vals.iterator();
+ }
+
+ public void addToPart_vals(String elem) {
+ if (this.part_vals == null) {
+ this.part_vals = new ArrayList<String>();
+ }
+ this.part_vals.add(elem);
+ }
+
+ public List<String> getPart_vals() {
+ return this.part_vals;
+ }
+
+ public void setPart_vals(List<String> part_vals) {
+ this.part_vals = part_vals;
+ }
+
+ public void unsetPart_vals() {
+ this.part_vals = null;
+ }
+
+ /** Returns true if field part_vals is set (has been assigned a value) and false otherwise */
+ public boolean isSetPart_vals() {
+ return this.part_vals != null;
+ }
+
+ public void setPart_valsIsSet(boolean value) {
+ if (!value) {
+ this.part_vals = null;
+ }
+ }
+
public Partition getNew_part() {
return this.new_part;
}
@@ -40225,6 +40285,14 @@ public class ThriftHiveMetastore {
}
break;
+ case PART_VALS:
+ if (value == null) {
+ unsetPart_vals();
+ } else {
+ setPart_vals((List<String>)value);
+ }
+ break;
+
case NEW_PART:
if (value == null) {
unsetNew_part();
@@ -40244,6 +40312,9 @@ public class ThriftHiveMetastore {
case TBL_NAME:
return getTbl_name();
+ case PART_VALS:
+ return getPart_vals();
+
case NEW_PART:
return getNew_part();
@@ -40262,6 +40333,8 @@ public class ThriftHiveMetastore {
return isSetDb_name();
case TBL_NAME:
return isSetTbl_name();
+ case PART_VALS:
+ return isSetPart_vals();
case NEW_PART:
return isSetNew_part();
}
@@ -40299,6 +40372,15 @@ public class ThriftHiveMetastore {
return false;
}
+ boolean this_present_part_vals = true && this.isSetPart_vals();
+ boolean that_present_part_vals = true && that.isSetPart_vals();
+ if (this_present_part_vals || that_present_part_vals) {
+ if (!(this_present_part_vals && that_present_part_vals))
+ return false;
+ if (!this.part_vals.equals(that.part_vals))
+ return false;
+ }
+
boolean this_present_new_part = true && this.isSetNew_part();
boolean that_present_new_part = true && that.isSetNew_part();
if (this_present_new_part || that_present_new_part) {
@@ -40344,6 +40426,16 @@ public class ThriftHiveMetastore {
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetPart_vals()).compareTo(typedOther.isSetPart_vals());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPart_vals()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.part_vals, typedOther.part_vals);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(isSetNew_part()).compareTo(typedOther.isSetNew_part());
if (lastComparison != 0) {
return lastComparison;
@@ -40385,7 +40477,24 @@ public class ThriftHiveMetastore {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
- case 3: // NEW_PART
+ case 3: // PART_VALS
+ if (field.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list219 = iprot.readListBegin();
+ this.part_vals = new ArrayList<String>(_list219.size);
+ for (int _i220 = 0; _i220 < _list219.size; ++_i220)
+ {
+ String _elem221; // required
+ _elem221 = iprot.readString();
+ this.part_vals.add(_elem221);
+ }
+ iprot.readListEnd();
+ }
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // NEW_PART
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.new_part = new Partition();
this.new_part.read(iprot);
@@ -40416,6 +40525,18 @@ public class ThriftHiveMetastore {
oprot.writeString(this.tbl_name);
oprot.writeFieldEnd();
}
+ if (this.part_vals != null) {
+ oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.part_vals.size()));
+ for (String _iter222 : this.part_vals)
+ {
+ oprot.writeString(_iter222);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
if (this.new_part != null) {
oprot.writeFieldBegin(NEW_PART_FIELD_DESC);
this.new_part.write(oprot);
@@ -40446,6 +40567,14 @@ public class ThriftHiveMetastore {
}
first = false;
if (!first) sb.append(", ");
+ sb.append("part_vals:");
+ if (this.part_vals == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.part_vals);
+ }
+ first = false;
+ if (!first) sb.append(", ");
sb.append("new_part:");
if (this.new_part == null) {
sb.append("null");
@@ -42236,13 +42365,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list219 = iprot.readListBegin();
- this.success = new ArrayList<String>(_list219.size);
- for (int _i220 = 0; _i220 < _list219.size; ++_i220)
+ org.apache.thrift.protocol.TList _list223 = iprot.readListBegin();
+ this.success = new ArrayList<String>(_list223.size);
+ for (int _i224 = 0; _i224 < _list223.size; ++_i224)
{
- String _elem221; // required
- _elem221 = iprot.readString();
- this.success.add(_elem221);
+ String _elem225; // required
+ _elem225 = iprot.readString();
+ this.success.add(_elem225);
}
iprot.readListEnd();
}
@@ -42274,9 +42403,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
- for (String _iter222 : this.success)
+ for (String _iter226 : this.success)
{
- oprot.writeString(_iter222);
+ oprot.writeString(_iter226);
}
oprot.writeListEnd();
}
@@ -42953,15 +43082,15 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map223 = iprot.readMapBegin();
- this.success = new HashMap<String,String>(2*_map223.size);
- for (int _i224 = 0; _i224 < _map223.size; ++_i224)
+ org.apache.thrift.protocol.TMap _map227 = iprot.readMapBegin();
+ this.success = new HashMap<String,String>(2*_map227.size);
+ for (int _i228 = 0; _i228 < _map227.size; ++_i228)
{
- String _key225; // required
- String _val226; // required
- _key225 = iprot.readString();
- _val226 = iprot.readString();
- this.success.put(_key225, _val226);
+ String _key229; // required
+ String _val230; // required
+ _key229 = iprot.readString();
+ _val230 = iprot.readString();
+ this.success.put(_key229, _val230);
}
iprot.readMapEnd();
}
@@ -42993,10 +43122,10 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.success.size()));
- for (Map.Entry<String, String> _iter227 : this.success.entrySet())
+ for (Map.Entry<String, String> _iter231 : this.success.entrySet())
{
- oprot.writeString(_iter227.getKey());
- oprot.writeString(_iter227.getValue());
+ oprot.writeString(_iter231.getKey());
+ oprot.writeString(_iter231.getValue());
}
oprot.writeMapEnd();
}
@@ -43541,15 +43670,15 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map228 = iprot.readMapBegin();
- this.part_vals = new HashMap<String,String>(2*_map228.size);
- for (int _i229 = 0; _i229 < _map228.size; ++_i229)
+ org.apache.thrift.protocol.TMap _map232 = iprot.readMapBegin();
+ this.part_vals = new HashMap<String,String>(2*_map232.size);
+ for (int _i233 = 0; _i233 < _map232.size; ++_i233)
{
- String _key230; // required
- String _val231; // required
- _key230 = iprot.readString();
- _val231 = iprot.readString();
- this.part_vals.put(_key230, _val231);
+ String _key234; // required
+ String _val235; // required
+ _key234 = iprot.readString();
+ _val235 = iprot.readString();
+ this.part_vals.put(_key234, _val235);
}
iprot.readMapEnd();
}
@@ -43591,10 +43720,10 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.part_vals.size()));
- for (Map.Entry<String, String> _iter232 : this.part_vals.entrySet())
+ for (Map.Entry<String, String> _iter236 : this.part_vals.entrySet())
{
- oprot.writeString(_iter232.getKey());
- oprot.writeString(_iter232.getValue());
+ oprot.writeString(_iter236.getKey());
+ oprot.writeString(_iter236.getValue());
}
oprot.writeMapEnd();
}
@@ -44890,15 +45019,15 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map233 = iprot.readMapBegin();
- this.part_vals = new HashMap<String,String>(2*_map233.size);
- for (int _i234 = 0; _i234 < _map233.size; ++_i234)
+ org.apache.thrift.protocol.TMap _map237 = iprot.readMapBegin();
+ this.part_vals = new HashMap<String,String>(2*_map237.size);
+ for (int _i238 = 0; _i238 < _map237.size; ++_i238)
{
- String _key235; // required
- String _val236; // required
- _key235 = iprot.readString();
- _val236 = iprot.readString();
- this.part_vals.put(_key235, _val236);
+ String _key239; // required
+ String _val240; // required
+ _key239 = iprot.readString();
+ _val240 = iprot.readString();
+ this.part_vals.put(_key239, _val240);
}
iprot.readMapEnd();
}
@@ -44940,10 +45069,10 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.part_vals.size()));
- for (Map.Entry<String, String> _iter237 : this.part_vals.entrySet())
+ for (Map.Entry<String, String> _iter241 : this.part_vals.entrySet())
{
- oprot.writeString(_iter237.getKey());
- oprot.writeString(_iter237.getValue());
+ oprot.writeString(_iter241.getKey());
+ oprot.writeString(_iter241.getValue());
}
oprot.writeMapEnd();
}
@@ -50549,14 +50678,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list238 = iprot.readListBegin();
- this.success = new ArrayList<Index>(_list238.size);
- for (int _i239 = 0; _i239 < _list238.size; ++_i239)
+ org.apache.thrift.protocol.TList _list242 = iprot.readListBegin();
+ this.success = new ArrayList<Index>(_list242.size);
+ for (int _i243 = 0; _i243 < _list242.size; ++_i243)
{
- Index _elem240; // required
- _elem240 = new Index();
- _elem240.read(iprot);
- this.success.add(_elem240);
+ Index _elem244; // required
+ _elem244 = new Index();
+ _elem244.read(iprot);
+ this.success.add(_elem244);
}
iprot.readListEnd();
}
@@ -50596,9 +50725,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
- for (Index _iter241 : this.success)
+ for (Index _iter245 : this.success)
{
- _iter241.write(oprot);
+ _iter245.write(oprot);
}
oprot.writeListEnd();
}
@@ -51460,13 +51589,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list242 = iprot.readListBegin();
- this.success = new ArrayList<String>(_list242.size);
- for (int _i243 = 0; _i243 < _list242.size; ++_i243)
+ org.apache.thrift.protocol.TList _list246 = iprot.readListBegin();
+ this.success = new ArrayList<String>(_list246.size);
+ for (int _i247 = 0; _i247 < _list246.size; ++_i247)
{
- String _elem244; // required
- _elem244 = iprot.readString();
- this.success.add(_elem244);
+ String _elem248; // required
+ _elem248 = iprot.readString();
+ this.success.add(_elem248);
}
iprot.readListEnd();
}
@@ -51498,9 +51627,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
- for (String _iter245 : this.success)
+ for (String _iter249 : this.success)
{
- oprot.writeString(_iter245);
+ oprot.writeString(_iter249);
}
oprot.writeListEnd();
}
@@ -53429,13 +53558,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list246 = iprot.readListBegin();
- this.success = new ArrayList<String>(_list246.size);
- for (int _i247 = 0; _i247 < _list246.size; ++_i247)
+ org.apache.thrift.protocol.TList _list250 = iprot.readListBegin();
+ this.success = new ArrayList<String>(_list250.size);
+ for (int _i251 = 0; _i251 < _list250.size; ++_i251)
{
- String _elem248; // required
- _elem248 = iprot.readString();
- this.success.add(_elem248);
+ String _elem252; // required
+ _elem252 = iprot.readString();
+ this.success.add(_elem252);
}
iprot.readListEnd();
}
@@ -53467,9 +53596,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
- for (String _iter249 : this.success)
+ for (String _iter253 : this.success)
{
- oprot.writeString(_iter249);
+ oprot.writeString(_iter253);
}
oprot.writeListEnd();
}
@@ -56243,14 +56372,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list250 = iprot.readListBegin();
- this.success = new ArrayList<Role>(_list250.size);
- for (int _i251 = 0; _i251 < _list250.size; ++_i251)
+ org.apache.thrift.protocol.TList _list254 = iprot.readListBegin();
+ this.success = new ArrayList<Role>(_list254.size);
+ for (int _i255 = 0; _i255 < _list254.size; ++_i255)
{
- Role _elem252; // required
- _elem252 = new Role();
- _elem252.read(iprot);
- this.success.add(_elem252);
+ Role _elem256; // required
+ _elem256 = new Role();
+ _elem256.read(iprot);
+ this.success.add(_elem256);
}
iprot.readListEnd();
}
@@ -56282,9 +56411,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
- for (Role _iter253 : this.success)
+ for (Role _iter257 : this.success)
{
- _iter253.write(oprot);
+ _iter257.write(oprot);
}
oprot.writeListEnd();
}
@@ -56745,13 +56874,13 @@ public class ThriftHiveMetastore {
case 3: // GROUP_NAMES
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list254 = iprot.readListBegin();
- this.group_names = new ArrayList<String>(_list254.size);
- for (int _i255 = 0; _i255 < _list254.size; ++_i255)
+ org.apache.thrift.protocol.TList _list258 = iprot.readListBegin();
+ this.group_names = new ArrayList<String>(_list258.size);
+ for (int _i259 = 0; _i259 < _list258.size; ++_i259)
{
- String _elem256; // required
- _elem256 = iprot.readString();
- this.group_names.add(_elem256);
+ String _elem260; // required
+ _elem260 = iprot.readString();
+ this.group_names.add(_elem260);
}
iprot.readListEnd();
}
@@ -56786,9 +56915,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(GROUP_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.group_names.size()));
- for (String _iter257 : this.group_names)
+ for (String _iter261 : this.group_names)
{
- oprot.writeString(_iter257);
+ oprot.writeString(_iter261);
}
oprot.writeListEnd();
}
@@ -58035,14 +58164,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list258 = iprot.readListBegin();
- this.success = new ArrayList<HiveObjectPrivilege>(_list258.size);
- for (int _i259 = 0; _i259 < _list258.size; ++_i259)
+ org.apache.thrift.protocol.TList _list262 = iprot.readListBegin();
+ this.success = new ArrayList<HiveObjectPrivilege>(_list262.size);
+ for (int _i263 = 0; _i263 < _list262.size; ++_i263)
{
- HiveObjectPrivilege _elem260; // required
- _elem260 = new HiveObjectPrivilege();
- _elem260.read(iprot);
- this.success.add(_elem260);
+ HiveObjectPrivilege _elem264; // required
+ _elem264 = new HiveObjectPrivilege();
+ _elem264.read(iprot);
+ this.success.add(_elem264);
}
iprot.readListEnd();
}
@@ -58074,9 +58203,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
- for (HiveObjectPrivilege _iter261 : this.success)
+ for (HiveObjectPrivilege _iter265 : this.success)
{
- _iter261.write(oprot);
+ _iter265.write(oprot);
}
oprot.writeListEnd();
}