You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2015/03/31 22:14:07 UTC
svn commit: r1670462 [5/26] - in /hive/branches/cbo: ./
ant/src/org/apache/hadoop/hive/ant/ beeline/src/java/org/apache/hive/beeline/
common/src/java/org/apache/hadoop/hive/conf/
common/src/java/org/apache/hive/common/util/ common/src/test/org/apache/h...
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h Tue Mar 31 20:14:02 2015
@@ -135,6 +135,7 @@ class ThriftHiveMetastoreIf : virtual pu
virtual void heartbeat_txn_range(HeartbeatTxnRangeResponse& _return, const HeartbeatTxnRangeRequest& txns) = 0;
virtual void compact(const CompactionRequest& rqst) = 0;
virtual void show_compact(ShowCompactResponse& _return, const ShowCompactRequest& rqst) = 0;
+ virtual void add_dynamic_partitions(const AddDynamicPartitions& rqst) = 0;
virtual void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) = 0;
virtual void get_current_notificationEventId(CurrentNotificationEventId& _return) = 0;
virtual void fire_listener_event(FireEventResponse& _return, const FireEventRequest& rqst) = 0;
@@ -547,6 +548,9 @@ class ThriftHiveMetastoreNull : virtual
void show_compact(ShowCompactResponse& /* _return */, const ShowCompactRequest& /* rqst */) {
return;
}
+ void add_dynamic_partitions(const AddDynamicPartitions& /* rqst */) {
+ return;
+ }
void get_next_notification(NotificationEventResponse& /* _return */, const NotificationEventRequest& /* rqst */) {
return;
}
@@ -16899,6 +16903,124 @@ class ThriftHiveMetastore_show_compact_p
};
+typedef struct _ThriftHiveMetastore_add_dynamic_partitions_args__isset {
+ _ThriftHiveMetastore_add_dynamic_partitions_args__isset() : rqst(false) {}
+ bool rqst;
+} _ThriftHiveMetastore_add_dynamic_partitions_args__isset;
+
+class ThriftHiveMetastore_add_dynamic_partitions_args {
+ public:
+
+ ThriftHiveMetastore_add_dynamic_partitions_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_add_dynamic_partitions_args() throw() {}
+
+ AddDynamicPartitions rqst;
+
+ _ThriftHiveMetastore_add_dynamic_partitions_args__isset __isset;
+
+ void __set_rqst(const AddDynamicPartitions& val) {
+ rqst = val;
+ }
+
+ bool operator == (const ThriftHiveMetastore_add_dynamic_partitions_args & rhs) const
+ {
+ if (!(rqst == rhs.rqst))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_add_dynamic_partitions_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_add_dynamic_partitions_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_add_dynamic_partitions_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_add_dynamic_partitions_pargs() throw() {}
+
+ const AddDynamicPartitions* rqst;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_add_dynamic_partitions_result__isset {
+ _ThriftHiveMetastore_add_dynamic_partitions_result__isset() : o1(false), o2(false) {}
+ bool o1;
+ bool o2;
+} _ThriftHiveMetastore_add_dynamic_partitions_result__isset;
+
+class ThriftHiveMetastore_add_dynamic_partitions_result {
+ public:
+
+ ThriftHiveMetastore_add_dynamic_partitions_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_add_dynamic_partitions_result() throw() {}
+
+ NoSuchTxnException o1;
+ TxnAbortedException o2;
+
+ _ThriftHiveMetastore_add_dynamic_partitions_result__isset __isset;
+
+ void __set_o1(const NoSuchTxnException& val) {
+ o1 = val;
+ }
+
+ void __set_o2(const TxnAbortedException& val) {
+ o2 = val;
+ }
+
+ bool operator == (const ThriftHiveMetastore_add_dynamic_partitions_result & rhs) const
+ {
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_add_dynamic_partitions_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_add_dynamic_partitions_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_add_dynamic_partitions_presult__isset {
+ _ThriftHiveMetastore_add_dynamic_partitions_presult__isset() : o1(false), o2(false) {}
+ bool o1;
+ bool o2;
+} _ThriftHiveMetastore_add_dynamic_partitions_presult__isset;
+
+class ThriftHiveMetastore_add_dynamic_partitions_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_add_dynamic_partitions_presult() throw() {}
+
+ NoSuchTxnException o1;
+ TxnAbortedException o2;
+
+ _ThriftHiveMetastore_add_dynamic_partitions_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
typedef struct _ThriftHiveMetastore_get_next_notification_args__isset {
_ThriftHiveMetastore_get_next_notification_args__isset() : rqst(false) {}
bool rqst;
@@ -17578,6 +17700,9 @@ class ThriftHiveMetastoreClient : virtua
void show_compact(ShowCompactResponse& _return, const ShowCompactRequest& rqst);
void send_show_compact(const ShowCompactRequest& rqst);
void recv_show_compact(ShowCompactResponse& _return);
+ void add_dynamic_partitions(const AddDynamicPartitions& rqst);
+ void send_add_dynamic_partitions(const AddDynamicPartitions& rqst);
+ void recv_add_dynamic_partitions();
void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst);
void send_get_next_notification(const NotificationEventRequest& rqst);
void recv_get_next_notification(NotificationEventResponse& _return);
@@ -17716,6 +17841,7 @@ class ThriftHiveMetastoreProcessor : pub
void process_heartbeat_txn_range(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_compact(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_show_compact(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_add_dynamic_partitions(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_next_notification(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_current_notificationEventId(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_fire_listener_event(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -17842,6 +17968,7 @@ class ThriftHiveMetastoreProcessor : pub
processMap_["heartbeat_txn_range"] = &ThriftHiveMetastoreProcessor::process_heartbeat_txn_range;
processMap_["compact"] = &ThriftHiveMetastoreProcessor::process_compact;
processMap_["show_compact"] = &ThriftHiveMetastoreProcessor::process_show_compact;
+ processMap_["add_dynamic_partitions"] = &ThriftHiveMetastoreProcessor::process_add_dynamic_partitions;
processMap_["get_next_notification"] = &ThriftHiveMetastoreProcessor::process_get_next_notification;
processMap_["get_current_notificationEventId"] = &ThriftHiveMetastoreProcessor::process_get_current_notificationEventId;
processMap_["fire_listener_event"] = &ThriftHiveMetastoreProcessor::process_fire_listener_event;
@@ -19019,6 +19146,15 @@ class ThriftHiveMetastoreMultiface : vir
return;
}
+ void add_dynamic_partitions(const AddDynamicPartitions& rqst) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->add_dynamic_partitions(rqst);
+ }
+ ifaces_[i]->add_dynamic_partitions(rqst);
+ }
+
void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) {
size_t sz = ifaces_.size();
size_t i = 0;
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp Tue Mar 31 20:14:02 2015
@@ -617,6 +617,11 @@ class ThriftHiveMetastoreHandler : virtu
printf("show_compact\n");
}
+ void add_dynamic_partitions(const AddDynamicPartitions& rqst) {
+ // Your implementation goes here
+ printf("add_dynamic_partitions\n");
+ }
+
void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) {
// Your implementation goes here
printf("get_next_notification\n");
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp Tue Mar 31 20:14:02 2015
@@ -9294,6 +9294,138 @@ void swap(ShowCompactResponse &a, ShowCo
swap(a.compacts, b.compacts);
}
+const char* AddDynamicPartitions::ascii_fingerprint = "A53A2B050DCCFE6A2158480A24E33898";
+const uint8_t AddDynamicPartitions::binary_fingerprint[16] = {0xA5,0x3A,0x2B,0x05,0x0D,0xCC,0xFE,0x6A,0x21,0x58,0x48,0x0A,0x24,0xE3,0x38,0x98};
+
+uint32_t AddDynamicPartitions::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+ bool isset_txnid = false;
+ bool isset_dbname = false;
+ bool isset_tablename = false;
+ bool isset_partitionnames = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->txnid);
+ isset_txnid = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->dbname);
+ isset_dbname = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->tablename);
+ isset_tablename = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->partitionnames.clear();
+ uint32_t _size401;
+ ::apache::thrift::protocol::TType _etype404;
+ xfer += iprot->readListBegin(_etype404, _size401);
+ this->partitionnames.resize(_size401);
+ uint32_t _i405;
+ for (_i405 = 0; _i405 < _size401; ++_i405)
+ {
+ xfer += iprot->readString(this->partitionnames[_i405]);
+ }
+ xfer += iprot->readListEnd();
+ }
+ isset_partitionnames = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_txnid)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_dbname)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_tablename)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_partitionnames)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t AddDynamicPartitions::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("AddDynamicPartitions");
+
+ xfer += oprot->writeFieldBegin("txnid", ::apache::thrift::protocol::T_I64, 1);
+ xfer += oprot->writeI64(this->txnid);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("dbname", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->dbname);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("tablename", ::apache::thrift::protocol::T_STRING, 3);
+ xfer += oprot->writeString(this->tablename);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("partitionnames", ::apache::thrift::protocol::T_LIST, 4);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->partitionnames.size()));
+ std::vector<std::string> ::const_iterator _iter406;
+ for (_iter406 = this->partitionnames.begin(); _iter406 != this->partitionnames.end(); ++_iter406)
+ {
+ xfer += oprot->writeString((*_iter406));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(AddDynamicPartitions &a, AddDynamicPartitions &b) {
+ using ::std::swap;
+ swap(a.txnid, b.txnid);
+ swap(a.dbname, b.dbname);
+ swap(a.tablename, b.tablename);
+ swap(a.partitionnames, b.partitionnames);
+}
+
const char* NotificationEventRequest::ascii_fingerprint = "6E578DA8AB10EED824A75534350EBAEF";
const uint8_t NotificationEventRequest::binary_fingerprint[16] = {0x6E,0x57,0x8D,0xA8,0xAB,0x10,0xEE,0xD8,0x24,0xA7,0x55,0x34,0x35,0x0E,0xBA,0xEF};
@@ -9542,14 +9674,14 @@ uint32_t NotificationEventResponse::read
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->events.clear();
- uint32_t _size401;
- ::apache::thrift::protocol::TType _etype404;
- xfer += iprot->readListBegin(_etype404, _size401);
- this->events.resize(_size401);
- uint32_t _i405;
- for (_i405 = 0; _i405 < _size401; ++_i405)
+ uint32_t _size407;
+ ::apache::thrift::protocol::TType _etype410;
+ xfer += iprot->readListBegin(_etype410, _size407);
+ this->events.resize(_size407);
+ uint32_t _i411;
+ for (_i411 = 0; _i411 < _size407; ++_i411)
{
- xfer += this->events[_i405].read(iprot);
+ xfer += this->events[_i411].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -9579,10 +9711,10 @@ uint32_t NotificationEventResponse::writ
xfer += oprot->writeFieldBegin("events", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->events.size()));
- std::vector<NotificationEvent> ::const_iterator _iter406;
- for (_iter406 = this->events.begin(); _iter406 != this->events.end(); ++_iter406)
+ std::vector<NotificationEvent> ::const_iterator _iter412;
+ for (_iter412 = this->events.begin(); _iter412 != this->events.end(); ++_iter412)
{
- xfer += (*_iter406).write(oprot);
+ xfer += (*_iter412).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -9690,14 +9822,14 @@ uint32_t InsertEventRequestData::read(::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->filesAdded.clear();
- uint32_t _size407;
- ::apache::thrift::protocol::TType _etype410;
- xfer += iprot->readListBegin(_etype410, _size407);
- this->filesAdded.resize(_size407);
- uint32_t _i411;
- for (_i411 = 0; _i411 < _size407; ++_i411)
+ uint32_t _size413;
+ ::apache::thrift::protocol::TType _etype416;
+ xfer += iprot->readListBegin(_etype416, _size413);
+ this->filesAdded.resize(_size413);
+ uint32_t _i417;
+ for (_i417 = 0; _i417 < _size413; ++_i417)
{
- xfer += iprot->readString(this->filesAdded[_i411]);
+ xfer += iprot->readString(this->filesAdded[_i417]);
}
xfer += iprot->readListEnd();
}
@@ -9727,10 +9859,10 @@ uint32_t InsertEventRequestData::write(:
xfer += oprot->writeFieldBegin("filesAdded", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->filesAdded.size()));
- std::vector<std::string> ::const_iterator _iter412;
- for (_iter412 = this->filesAdded.begin(); _iter412 != this->filesAdded.end(); ++_iter412)
+ std::vector<std::string> ::const_iterator _iter418;
+ for (_iter418 = this->filesAdded.begin(); _iter418 != this->filesAdded.end(); ++_iter418)
{
- xfer += oprot->writeString((*_iter412));
+ xfer += oprot->writeString((*_iter418));
}
xfer += oprot->writeListEnd();
}
@@ -9869,14 +10001,14 @@ uint32_t FireEventRequest::read(::apache
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->partitionVals.clear();
- uint32_t _size413;
- ::apache::thrift::protocol::TType _etype416;
- xfer += iprot->readListBegin(_etype416, _size413);
- this->partitionVals.resize(_size413);
- uint32_t _i417;
- for (_i417 = 0; _i417 < _size413; ++_i417)
+ uint32_t _size419;
+ ::apache::thrift::protocol::TType _etype422;
+ xfer += iprot->readListBegin(_etype422, _size419);
+ this->partitionVals.resize(_size419);
+ uint32_t _i423;
+ for (_i423 = 0; _i423 < _size419; ++_i423)
{
- xfer += iprot->readString(this->partitionVals[_i417]);
+ xfer += iprot->readString(this->partitionVals[_i423]);
}
xfer += iprot->readListEnd();
}
@@ -9927,10 +10059,10 @@ uint32_t FireEventRequest::write(::apach
xfer += oprot->writeFieldBegin("partitionVals", ::apache::thrift::protocol::T_LIST, 5);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->partitionVals.size()));
- std::vector<std::string> ::const_iterator _iter418;
- for (_iter418 = this->partitionVals.begin(); _iter418 != this->partitionVals.end(); ++_iter418)
+ std::vector<std::string> ::const_iterator _iter424;
+ for (_iter424 = this->partitionVals.begin(); _iter424 != this->partitionVals.end(); ++_iter424)
{
- xfer += oprot->writeString((*_iter418));
+ xfer += oprot->writeString((*_iter424));
}
xfer += oprot->writeListEnd();
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h Tue Mar 31 20:14:02 2015
@@ -5088,6 +5088,64 @@ class ShowCompactResponse {
void swap(ShowCompactResponse &a, ShowCompactResponse &b);
+
+class AddDynamicPartitions {
+ public:
+
+ static const char* ascii_fingerprint; // = "A53A2B050DCCFE6A2158480A24E33898";
+ static const uint8_t binary_fingerprint[16]; // = {0xA5,0x3A,0x2B,0x05,0x0D,0xCC,0xFE,0x6A,0x21,0x58,0x48,0x0A,0x24,0xE3,0x38,0x98};
+
+ AddDynamicPartitions() : txnid(0), dbname(), tablename() {
+ }
+
+ virtual ~AddDynamicPartitions() throw() {}
+
+ int64_t txnid;
+ std::string dbname;
+ std::string tablename;
+ std::vector<std::string> partitionnames;
+
+ void __set_txnid(const int64_t val) {
+ txnid = val;
+ }
+
+ void __set_dbname(const std::string& val) {
+ dbname = val;
+ }
+
+ void __set_tablename(const std::string& val) {
+ tablename = val;
+ }
+
+ void __set_partitionnames(const std::vector<std::string> & val) {
+ partitionnames = val;
+ }
+
+ bool operator == (const AddDynamicPartitions & rhs) const
+ {
+ if (!(txnid == rhs.txnid))
+ return false;
+ if (!(dbname == rhs.dbname))
+ return false;
+ if (!(tablename == rhs.tablename))
+ return false;
+ if (!(partitionnames == rhs.partitionnames))
+ return false;
+ return true;
+ }
+ bool operator != (const AddDynamicPartitions &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const AddDynamicPartitions & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(AddDynamicPartitions &a, AddDynamicPartitions &b);
+
typedef struct _NotificationEventRequest__isset {
_NotificationEventRequest__isset() : maxEvents(false) {}
bool maxEvents;
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java Tue Mar 31 20:14:02 2015
@@ -712,13 +712,13 @@ public class FireEventRequest implements
case 5: // PARTITION_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list508 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list508.size);
- for (int _i509 = 0; _i509 < _list508.size; ++_i509)
+ org.apache.thrift.protocol.TList _list516 = iprot.readListBegin();
+ struct.partitionVals = new ArrayList<String>(_list516.size);
+ for (int _i517 = 0; _i517 < _list516.size; ++_i517)
{
- String _elem510; // required
- _elem510 = iprot.readString();
- struct.partitionVals.add(_elem510);
+ String _elem518; // required
+ _elem518 = iprot.readString();
+ struct.partitionVals.add(_elem518);
}
iprot.readListEnd();
}
@@ -767,9 +767,9 @@ public class FireEventRequest implements
oprot.writeFieldBegin(PARTITION_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionVals.size()));
- for (String _iter511 : struct.partitionVals)
+ for (String _iter519 : struct.partitionVals)
{
- oprot.writeString(_iter511);
+ oprot.writeString(_iter519);
}
oprot.writeListEnd();
}
@@ -815,9 +815,9 @@ public class FireEventRequest implements
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter512 : struct.partitionVals)
+ for (String _iter520 : struct.partitionVals)
{
- oprot.writeString(_iter512);
+ oprot.writeString(_iter520);
}
}
}
@@ -842,13 +842,13 @@ public class FireEventRequest implements
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list513 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list513.size);
- for (int _i514 = 0; _i514 < _list513.size; ++_i514)
+ org.apache.thrift.protocol.TList _list521 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionVals = new ArrayList<String>(_list521.size);
+ for (int _i522 = 0; _i522 < _list521.size; ++_i522)
{
- String _elem515; // required
- _elem515 = iprot.readString();
- struct.partitionVals.add(_elem515);
+ String _elem523; // required
+ _elem523 = iprot.readString();
+ struct.partitionVals.add(_elem523);
}
}
struct.setPartitionValsIsSet(true);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java Tue Mar 31 20:14:02 2015
@@ -350,13 +350,13 @@ public class InsertEventRequestData impl
case 1: // FILES_ADDED
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list500 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list500.size);
- for (int _i501 = 0; _i501 < _list500.size; ++_i501)
+ org.apache.thrift.protocol.TList _list508 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list508.size);
+ for (int _i509 = 0; _i509 < _list508.size; ++_i509)
{
- String _elem502; // required
- _elem502 = iprot.readString();
- struct.filesAdded.add(_elem502);
+ String _elem510; // required
+ _elem510 = iprot.readString();
+ struct.filesAdded.add(_elem510);
}
iprot.readListEnd();
}
@@ -382,9 +382,9 @@ public class InsertEventRequestData impl
oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size()));
- for (String _iter503 : struct.filesAdded)
+ for (String _iter511 : struct.filesAdded)
{
- oprot.writeString(_iter503);
+ oprot.writeString(_iter511);
}
oprot.writeListEnd();
}
@@ -409,9 +409,9 @@ public class InsertEventRequestData impl
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter504 : struct.filesAdded)
+ for (String _iter512 : struct.filesAdded)
{
- oprot.writeString(_iter504);
+ oprot.writeString(_iter512);
}
}
}
@@ -420,13 +420,13 @@ public class InsertEventRequestData impl
public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list505 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list505.size);
- for (int _i506 = 0; _i506 < _list505.size; ++_i506)
+ org.apache.thrift.protocol.TList _list513 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list513.size);
+ for (int _i514 = 0; _i514 < _list513.size; ++_i514)
{
- String _elem507; // required
- _elem507 = iprot.readString();
- struct.filesAdded.add(_elem507);
+ String _elem515; // required
+ _elem515 = iprot.readString();
+ struct.filesAdded.add(_elem515);
}
}
struct.setFilesAddedIsSet(true);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java?rev=1670462&r1=1670461&r2=1670462&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java Tue Mar 31 20:14:02 2015
@@ -350,14 +350,14 @@ public class NotificationEventResponse i
case 1: // EVENTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list492 = iprot.readListBegin();
- struct.events = new ArrayList<NotificationEvent>(_list492.size);
- for (int _i493 = 0; _i493 < _list492.size; ++_i493)
+ org.apache.thrift.protocol.TList _list500 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list500.size);
+ for (int _i501 = 0; _i501 < _list500.size; ++_i501)
{
- NotificationEvent _elem494; // required
- _elem494 = new NotificationEvent();
- _elem494.read(iprot);
- struct.events.add(_elem494);
+ NotificationEvent _elem502; // required
+ _elem502 = new NotificationEvent();
+ _elem502.read(iprot);
+ struct.events.add(_elem502);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class NotificationEventResponse i
oprot.writeFieldBegin(EVENTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size()));
- for (NotificationEvent _iter495 : struct.events)
+ for (NotificationEvent _iter503 : struct.events)
{
- _iter495.write(oprot);
+ _iter503.write(oprot);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class NotificationEventResponse i
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.events.size());
- for (NotificationEvent _iter496 : struct.events)
+ for (NotificationEvent _iter504 : struct.events)
{
- _iter496.write(oprot);
+ _iter504.write(oprot);
}
}
}
@@ -421,14 +421,14 @@ public class NotificationEventResponse i
public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list497 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.events = new ArrayList<NotificationEvent>(_list497.size);
- for (int _i498 = 0; _i498 < _list497.size; ++_i498)
+ org.apache.thrift.protocol.TList _list505 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.events = new ArrayList<NotificationEvent>(_list505.size);
+ for (int _i506 = 0; _i506 < _list505.size; ++_i506)
{
- NotificationEvent _elem499; // required
- _elem499 = new NotificationEvent();
- _elem499.read(iprot);
- struct.events.add(_elem499);
+ NotificationEvent _elem507; // required
+ _elem507 = new NotificationEvent();
+ _elem507.read(iprot);
+ struct.events.add(_elem507);
}
}
struct.setEventsIsSet(true);