You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/07/03 10:02:50 UTC
[11/16] hive git commit: HIVE-19267: Replicate ACID/MM tables write
operations (Mahesh Kumar Behera, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
index 5c6495e..f5913fc 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
@@ -445,6 +445,8 @@ class AbortTxnsRequest;
class CommitTxnRequest;
+class WriteEventInfo;
+
class ReplTblWriteIdStateRequest;
class GetValidWriteIdsRequest;
@@ -517,6 +519,10 @@ class FireEventRequest;
class FireEventResponse;
+class WriteNotificationLogRequest;
+
+class WriteNotificationLogResponse;
+
class MetadataPpdResult;
class GetFileMetadataByExprResult;
@@ -6985,8 +6991,9 @@ inline std::ostream& operator<<(std::ostream& out, const AbortTxnsRequest& obj)
}
typedef struct _CommitTxnRequest__isset {
- _CommitTxnRequest__isset() : replPolicy(false) {}
+ _CommitTxnRequest__isset() : replPolicy(false), writeEventInfos(false) {}
bool replPolicy :1;
+ bool writeEventInfos :1;
} _CommitTxnRequest__isset;
class CommitTxnRequest {
@@ -7000,6 +7007,7 @@ class CommitTxnRequest {
virtual ~CommitTxnRequest() throw();
int64_t txnid;
std::string replPolicy;
+ std::vector<WriteEventInfo> writeEventInfos;
_CommitTxnRequest__isset __isset;
@@ -7007,6 +7015,8 @@ class CommitTxnRequest {
void __set_replPolicy(const std::string& val);
+ void __set_writeEventInfos(const std::vector<WriteEventInfo> & val);
+
bool operator == (const CommitTxnRequest & rhs) const
{
if (!(txnid == rhs.txnid))
@@ -7015,6 +7025,10 @@ class CommitTxnRequest {
return false;
else if (__isset.replPolicy && !(replPolicy == rhs.replPolicy))
return false;
+ if (__isset.writeEventInfos != rhs.__isset.writeEventInfos)
+ return false;
+ else if (__isset.writeEventInfos && !(writeEventInfos == rhs.writeEventInfos))
+ return false;
return true;
}
bool operator != (const CommitTxnRequest &rhs) const {
@@ -7037,6 +7051,90 @@ inline std::ostream& operator<<(std::ostream& out, const CommitTxnRequest& obj)
return out;
}
+typedef struct _WriteEventInfo__isset {
+ _WriteEventInfo__isset() : partition(false), tableObj(false), partitionObj(false) {}
+ bool partition :1;
+ bool tableObj :1;
+ bool partitionObj :1;
+} _WriteEventInfo__isset;
+
+class WriteEventInfo {
+ public:
+
+ WriteEventInfo(const WriteEventInfo&);
+ WriteEventInfo& operator=(const WriteEventInfo&);
+ WriteEventInfo() : writeId(0), database(), table(), files(), partition(), tableObj(), partitionObj() {
+ }
+
+ virtual ~WriteEventInfo() throw();
+ int64_t writeId;
+ std::string database;
+ std::string table;
+ std::string files;
+ std::string partition;
+ std::string tableObj;
+ std::string partitionObj;
+
+ _WriteEventInfo__isset __isset;
+
+ void __set_writeId(const int64_t val);
+
+ void __set_database(const std::string& val);
+
+ void __set_table(const std::string& val);
+
+ void __set_files(const std::string& val);
+
+ void __set_partition(const std::string& val);
+
+ void __set_tableObj(const std::string& val);
+
+ void __set_partitionObj(const std::string& val);
+
+ bool operator == (const WriteEventInfo & rhs) const
+ {
+ if (!(writeId == rhs.writeId))
+ return false;
+ if (!(database == rhs.database))
+ return false;
+ if (!(table == rhs.table))
+ return false;
+ if (!(files == rhs.files))
+ return false;
+ if (__isset.partition != rhs.__isset.partition)
+ return false;
+ else if (__isset.partition && !(partition == rhs.partition))
+ return false;
+ if (__isset.tableObj != rhs.__isset.tableObj)
+ return false;
+ else if (__isset.tableObj && !(tableObj == rhs.tableObj))
+ return false;
+ if (__isset.partitionObj != rhs.__isset.partitionObj)
+ return false;
+ else if (__isset.partitionObj && !(partitionObj == rhs.partitionObj))
+ return false;
+ return true;
+ }
+ bool operator != (const WriteEventInfo &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const WriteEventInfo & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(WriteEventInfo &a, WriteEventInfo &b);
+
+inline std::ostream& operator<<(std::ostream& out, const WriteEventInfo& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
typedef struct _ReplTblWriteIdStateRequest__isset {
_ReplTblWriteIdStateRequest__isset() : partNames(false) {}
bool partNames :1;
@@ -9035,9 +9133,10 @@ inline std::ostream& operator<<(std::ostream& out, const NotificationEventsCount
}
typedef struct _InsertEventRequestData__isset {
- _InsertEventRequestData__isset() : replace(false), filesAddedChecksum(false) {}
+ _InsertEventRequestData__isset() : replace(false), filesAddedChecksum(false), subDirectoryList(false) {}
bool replace :1;
bool filesAddedChecksum :1;
+ bool subDirectoryList :1;
} _InsertEventRequestData__isset;
class InsertEventRequestData {
@@ -9052,6 +9151,7 @@ class InsertEventRequestData {
bool replace;
std::vector<std::string> filesAdded;
std::vector<std::string> filesAddedChecksum;
+ std::vector<std::string> subDirectoryList;
_InsertEventRequestData__isset __isset;
@@ -9061,6 +9161,8 @@ class InsertEventRequestData {
void __set_filesAddedChecksum(const std::vector<std::string> & val);
+ void __set_subDirectoryList(const std::vector<std::string> & val);
+
bool operator == (const InsertEventRequestData & rhs) const
{
if (__isset.replace != rhs.__isset.replace)
@@ -9073,6 +9175,10 @@ class InsertEventRequestData {
return false;
else if (__isset.filesAddedChecksum && !(filesAddedChecksum == rhs.filesAddedChecksum))
return false;
+ if (__isset.subDirectoryList != rhs.__isset.subDirectoryList)
+ return false;
+ else if (__isset.subDirectoryList && !(subDirectoryList == rhs.subDirectoryList))
+ return false;
return true;
}
bool operator != (const InsertEventRequestData &rhs) const {
@@ -9258,6 +9364,114 @@ inline std::ostream& operator<<(std::ostream& out, const FireEventResponse& obj)
return out;
}
+typedef struct _WriteNotificationLogRequest__isset {
+ _WriteNotificationLogRequest__isset() : partitionVals(false) {}
+ bool partitionVals :1;
+} _WriteNotificationLogRequest__isset;
+
+class WriteNotificationLogRequest {
+ public:
+
+ WriteNotificationLogRequest(const WriteNotificationLogRequest&);
+ WriteNotificationLogRequest& operator=(const WriteNotificationLogRequest&);
+ WriteNotificationLogRequest() : txnId(0), writeId(0), db(), table() {
+ }
+
+ virtual ~WriteNotificationLogRequest() throw();
+ int64_t txnId;
+ int64_t writeId;
+ std::string db;
+ std::string table;
+ InsertEventRequestData fileInfo;
+ std::vector<std::string> partitionVals;
+
+ _WriteNotificationLogRequest__isset __isset;
+
+ void __set_txnId(const int64_t val);
+
+ void __set_writeId(const int64_t val);
+
+ void __set_db(const std::string& val);
+
+ void __set_table(const std::string& val);
+
+ void __set_fileInfo(const InsertEventRequestData& val);
+
+ void __set_partitionVals(const std::vector<std::string> & val);
+
+ bool operator == (const WriteNotificationLogRequest & rhs) const
+ {
+ if (!(txnId == rhs.txnId))
+ return false;
+ if (!(writeId == rhs.writeId))
+ return false;
+ if (!(db == rhs.db))
+ return false;
+ if (!(table == rhs.table))
+ return false;
+ if (!(fileInfo == rhs.fileInfo))
+ return false;
+ if (__isset.partitionVals != rhs.__isset.partitionVals)
+ return false;
+ else if (__isset.partitionVals && !(partitionVals == rhs.partitionVals))
+ return false;
+ return true;
+ }
+ bool operator != (const WriteNotificationLogRequest &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const WriteNotificationLogRequest & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(WriteNotificationLogRequest &a, WriteNotificationLogRequest &b);
+
+inline std::ostream& operator<<(std::ostream& out, const WriteNotificationLogRequest& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
+class WriteNotificationLogResponse {
+ public:
+
+ WriteNotificationLogResponse(const WriteNotificationLogResponse&);
+ WriteNotificationLogResponse& operator=(const WriteNotificationLogResponse&);
+ WriteNotificationLogResponse() {
+ }
+
+ virtual ~WriteNotificationLogResponse() throw();
+
+ bool operator == (const WriteNotificationLogResponse & /* rhs */) const
+ {
+ return true;
+ }
+ bool operator != (const WriteNotificationLogResponse &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const WriteNotificationLogResponse & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(WriteNotificationLogResponse &a, WriteNotificationLogResponse &b);
+
+inline std::ostream& operator<<(std::ostream& out, const WriteNotificationLogResponse& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
typedef struct _MetadataPpdResult__isset {
_MetadataPpdResult__isset() : metadata(false), includeBitset(false) {}
bool metadata :1;
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
index 1dcc870..3ce72e9 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
@@ -816,13 +816,13 @@ import org.slf4j.LoggerFactory;
case 5: // PARTITIONNAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list700 = iprot.readListBegin();
- struct.partitionnames = new ArrayList<String>(_list700.size);
- String _elem701;
- for (int _i702 = 0; _i702 < _list700.size; ++_i702)
+ org.apache.thrift.protocol.TList _list708 = iprot.readListBegin();
+ struct.partitionnames = new ArrayList<String>(_list708.size);
+ String _elem709;
+ for (int _i710 = 0; _i710 < _list708.size; ++_i710)
{
- _elem701 = iprot.readString();
- struct.partitionnames.add(_elem701);
+ _elem709 = iprot.readString();
+ struct.partitionnames.add(_elem709);
}
iprot.readListEnd();
}
@@ -872,9 +872,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITIONNAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionnames.size()));
- for (String _iter703 : struct.partitionnames)
+ for (String _iter711 : struct.partitionnames)
{
- oprot.writeString(_iter703);
+ oprot.writeString(_iter711);
}
oprot.writeListEnd();
}
@@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tablename);
{
oprot.writeI32(struct.partitionnames.size());
- for (String _iter704 : struct.partitionnames)
+ for (String _iter712 : struct.partitionnames)
{
- oprot.writeString(_iter704);
+ oprot.writeString(_iter712);
}
}
BitSet optionals = new BitSet();
@@ -937,13 +937,13 @@ import org.slf4j.LoggerFactory;
struct.tablename = iprot.readString();
struct.setTablenameIsSet(true);
{
- org.apache.thrift.protocol.TList _list705 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionnames = new ArrayList<String>(_list705.size);
- String _elem706;
- for (int _i707 = 0; _i707 < _list705.size; ++_i707)
+ org.apache.thrift.protocol.TList _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionnames = new ArrayList<String>(_list713.size);
+ String _elem714;
+ for (int _i715 = 0; _i715 < _list713.size; ++_i715)
{
- _elem706 = iprot.readString();
- struct.partitionnames.add(_elem706);
+ _elem714 = iprot.readString();
+ struct.partitionnames.add(_elem714);
}
}
struct.setPartitionnamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
index fa33963..a0b47a9 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
@@ -716,13 +716,13 @@ import org.slf4j.LoggerFactory;
case 3: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
- struct.txnIds = new ArrayList<Long>(_list626.size);
- long _elem627;
- for (int _i628 = 0; _i628 < _list626.size; ++_i628)
+ org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
+ struct.txnIds = new ArrayList<Long>(_list634.size);
+ long _elem635;
+ for (int _i636 = 0; _i636 < _list634.size; ++_i636)
{
- _elem627 = iprot.readI64();
- struct.txnIds.add(_elem627);
+ _elem635 = iprot.readI64();
+ struct.txnIds.add(_elem635);
}
iprot.readListEnd();
}
@@ -742,14 +742,14 @@ import org.slf4j.LoggerFactory;
case 5: // SRC_TXN_TO_WRITE_ID_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list629 = iprot.readListBegin();
- struct.srcTxnToWriteIdList = new ArrayList<TxnToWriteId>(_list629.size);
- TxnToWriteId _elem630;
- for (int _i631 = 0; _i631 < _list629.size; ++_i631)
+ org.apache.thrift.protocol.TList _list637 = iprot.readListBegin();
+ struct.srcTxnToWriteIdList = new ArrayList<TxnToWriteId>(_list637.size);
+ TxnToWriteId _elem638;
+ for (int _i639 = 0; _i639 < _list637.size; ++_i639)
{
- _elem630 = new TxnToWriteId();
- _elem630.read(iprot);
- struct.srcTxnToWriteIdList.add(_elem630);
+ _elem638 = new TxnToWriteId();
+ _elem638.read(iprot);
+ struct.srcTxnToWriteIdList.add(_elem638);
}
iprot.readListEnd();
}
@@ -786,9 +786,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXN_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txnIds.size()));
- for (long _iter632 : struct.txnIds)
+ for (long _iter640 : struct.txnIds)
{
- oprot.writeI64(_iter632);
+ oprot.writeI64(_iter640);
}
oprot.writeListEnd();
}
@@ -807,9 +807,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SRC_TXN_TO_WRITE_ID_LIST_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.srcTxnToWriteIdList.size()));
- for (TxnToWriteId _iter633 : struct.srcTxnToWriteIdList)
+ for (TxnToWriteId _iter641 : struct.srcTxnToWriteIdList)
{
- _iter633.write(oprot);
+ _iter641.write(oprot);
}
oprot.writeListEnd();
}
@@ -849,9 +849,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTxnIds()) {
{
oprot.writeI32(struct.txnIds.size());
- for (long _iter634 : struct.txnIds)
+ for (long _iter642 : struct.txnIds)
{
- oprot.writeI64(_iter634);
+ oprot.writeI64(_iter642);
}
}
}
@@ -861,9 +861,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSrcTxnToWriteIdList()) {
{
oprot.writeI32(struct.srcTxnToWriteIdList.size());
- for (TxnToWriteId _iter635 : struct.srcTxnToWriteIdList)
+ for (TxnToWriteId _iter643 : struct.srcTxnToWriteIdList)
{
- _iter635.write(oprot);
+ _iter643.write(oprot);
}
}
}
@@ -879,13 +879,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list636 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txnIds = new ArrayList<Long>(_list636.size);
- long _elem637;
- for (int _i638 = 0; _i638 < _list636.size; ++_i638)
+ org.apache.thrift.protocol.TList _list644 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txnIds = new ArrayList<Long>(_list644.size);
+ long _elem645;
+ for (int _i646 = 0; _i646 < _list644.size; ++_i646)
{
- _elem637 = iprot.readI64();
- struct.txnIds.add(_elem637);
+ _elem645 = iprot.readI64();
+ struct.txnIds.add(_elem645);
}
}
struct.setTxnIdsIsSet(true);
@@ -896,14 +896,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.srcTxnToWriteIdList = new ArrayList<TxnToWriteId>(_list639.size);
- TxnToWriteId _elem640;
- for (int _i641 = 0; _i641 < _list639.size; ++_i641)
+ org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.srcTxnToWriteIdList = new ArrayList<TxnToWriteId>(_list647.size);
+ TxnToWriteId _elem648;
+ for (int _i649 = 0; _i649 < _list647.size; ++_i649)
{
- _elem640 = new TxnToWriteId();
- _elem640.read(iprot);
- struct.srcTxnToWriteIdList.add(_elem640);
+ _elem648 = new TxnToWriteId();
+ _elem648.read(iprot);
+ struct.srcTxnToWriteIdList.add(_elem648);
}
}
struct.setSrcTxnToWriteIdListIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
index 20dc757..13df26d 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_TO_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list642.size);
- TxnToWriteId _elem643;
- for (int _i644 = 0; _i644 < _list642.size; ++_i644)
+ org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
+ struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list650.size);
+ TxnToWriteId _elem651;
+ for (int _i652 = 0; _i652 < _list650.size; ++_i652)
{
- _elem643 = new TxnToWriteId();
- _elem643.read(iprot);
- struct.txnToWriteIds.add(_elem643);
+ _elem651 = new TxnToWriteId();
+ _elem651.read(iprot);
+ struct.txnToWriteIds.add(_elem651);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXN_TO_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.txnToWriteIds.size()));
- for (TxnToWriteId _iter645 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter653 : struct.txnToWriteIds)
{
- _iter645.write(oprot);
+ _iter653.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txnToWriteIds.size());
- for (TxnToWriteId _iter646 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter654 : struct.txnToWriteIds)
{
- _iter646.write(oprot);
+ _iter654.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AllocateTableWriteIdsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list647.size);
- TxnToWriteId _elem648;
- for (int _i649 = 0; _i649 < _list647.size; ++_i649)
+ org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list655.size);
+ TxnToWriteId _elem656;
+ for (int _i657 = 0; _i657 < _list655.size; ++_i657)
{
- _elem648 = new TxnToWriteId();
- _elem648.read(iprot);
- struct.txnToWriteIds.add(_elem648);
+ _elem656 = new TxnToWriteId();
+ _elem656.read(iprot);
+ struct.txnToWriteIds.add(_elem656);
}
}
struct.setTxnToWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
index 470a070..1af1628 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list800 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list800.size);
- long _elem801;
- for (int _i802 = 0; _i802 < _list800.size; ++_i802)
+ org.apache.thrift.protocol.TList _list824 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list824.size);
+ long _elem825;
+ for (int _i826 = 0; _i826 < _list824.size; ++_i826)
{
- _elem801 = iprot.readI64();
- struct.fileIds.add(_elem801);
+ _elem825 = iprot.readI64();
+ struct.fileIds.add(_elem825);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter803 : struct.fileIds)
+ for (long _iter827 : struct.fileIds)
{
- oprot.writeI64(_iter803);
+ oprot.writeI64(_iter827);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter804 : struct.fileIds)
+ for (long _iter828 : struct.fileIds)
{
- oprot.writeI64(_iter804);
+ oprot.writeI64(_iter828);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ClearFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list805 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list805.size);
- long _elem806;
- for (int _i807 = 0; _i807 < _list805.size; ++_i807)
+ org.apache.thrift.protocol.TList _list829 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list829.size);
+ long _elem830;
+ for (int _i831 = 0; _i831 < _list829.size; ++_i831)
{
- _elem806 = iprot.readI64();
- struct.fileIds.add(_elem806);
+ _elem830 = iprot.readI64();
+ struct.fileIds.add(_elem830);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
index af48583..4cd04f1 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
@@ -354,13 +354,13 @@ import org.slf4j.LoggerFactory;
case 1: // VALUES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list816 = iprot.readListBegin();
- struct.values = new ArrayList<ClientCapability>(_list816.size);
- ClientCapability _elem817;
- for (int _i818 = 0; _i818 < _list816.size; ++_i818)
+ org.apache.thrift.protocol.TList _list840 = iprot.readListBegin();
+ struct.values = new ArrayList<ClientCapability>(_list840.size);
+ ClientCapability _elem841;
+ for (int _i842 = 0; _i842 < _list840.size; ++_i842)
{
- _elem817 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem817);
+ _elem841 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem841);
}
iprot.readListEnd();
}
@@ -386,9 +386,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(VALUES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.values.size()));
- for (ClientCapability _iter819 : struct.values)
+ for (ClientCapability _iter843 : struct.values)
{
- oprot.writeI32(_iter819.getValue());
+ oprot.writeI32(_iter843.getValue());
}
oprot.writeListEnd();
}
@@ -413,9 +413,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.values.size());
- for (ClientCapability _iter820 : struct.values)
+ for (ClientCapability _iter844 : struct.values)
{
- oprot.writeI32(_iter820.getValue());
+ oprot.writeI32(_iter844.getValue());
}
}
}
@@ -424,13 +424,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ClientCapabilities struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list821 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.values = new ArrayList<ClientCapability>(_list821.size);
- ClientCapability _elem822;
- for (int _i823 = 0; _i823 < _list821.size; ++_i823)
+ org.apache.thrift.protocol.TList _list845 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.values = new ArrayList<ClientCapability>(_list845.size);
+ ClientCapability _elem846;
+ for (int _i847 = 0; _i847 < _list845.size; ++_i847)
{
- _elem822 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem822);
+ _elem846 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem846);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
index 3c15f84..f295958 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
@@ -40,6 +40,7 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1);
private static final org.apache.thrift.protocol.TField REPL_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("replPolicy", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField WRITE_EVENT_INFOS_FIELD_DESC = new org.apache.thrift.protocol.TField("writeEventInfos", org.apache.thrift.protocol.TType.LIST, (short)3);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -49,11 +50,13 @@ import org.slf4j.LoggerFactory;
private long txnid; // required
private String replPolicy; // optional
+ private List<WriteEventInfo> writeEventInfos; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
TXNID((short)1, "txnid"),
- REPL_POLICY((short)2, "replPolicy");
+ REPL_POLICY((short)2, "replPolicy"),
+ WRITE_EVENT_INFOS((short)3, "writeEventInfos");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -72,6 +75,8 @@ import org.slf4j.LoggerFactory;
return TXNID;
case 2: // REPL_POLICY
return REPL_POLICY;
+ case 3: // WRITE_EVENT_INFOS
+ return WRITE_EVENT_INFOS;
default:
return null;
}
@@ -114,7 +119,7 @@ import org.slf4j.LoggerFactory;
// isset id assignments
private static final int __TXNID_ISSET_ID = 0;
private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.REPL_POLICY};
+ private static final _Fields optionals[] = {_Fields.REPL_POLICY,_Fields.WRITE_EVENT_INFOS};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -122,6 +127,9 @@ import org.slf4j.LoggerFactory;
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.REPL_POLICY, new org.apache.thrift.meta_data.FieldMetaData("replPolicy", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.WRITE_EVENT_INFOS, new org.apache.thrift.meta_data.FieldMetaData("writeEventInfos", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ 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.STRUCT , "WriteEventInfo"))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CommitTxnRequest.class, metaDataMap);
}
@@ -146,6 +154,13 @@ import org.slf4j.LoggerFactory;
if (other.isSetReplPolicy()) {
this.replPolicy = other.replPolicy;
}
+ if (other.isSetWriteEventInfos()) {
+ List<WriteEventInfo> __this__writeEventInfos = new ArrayList<WriteEventInfo>(other.writeEventInfos.size());
+ for (WriteEventInfo other_element : other.writeEventInfos) {
+ __this__writeEventInfos.add(other_element);
+ }
+ this.writeEventInfos = __this__writeEventInfos;
+ }
}
public CommitTxnRequest deepCopy() {
@@ -157,6 +172,7 @@ import org.slf4j.LoggerFactory;
setTxnidIsSet(false);
this.txnid = 0;
this.replPolicy = null;
+ this.writeEventInfos = null;
}
public long getTxnid() {
@@ -204,6 +220,44 @@ import org.slf4j.LoggerFactory;
}
}
+ public int getWriteEventInfosSize() {
+ return (this.writeEventInfos == null) ? 0 : this.writeEventInfos.size();
+ }
+
+ public java.util.Iterator<WriteEventInfo> getWriteEventInfosIterator() {
+ return (this.writeEventInfos == null) ? null : this.writeEventInfos.iterator();
+ }
+
+ public void addToWriteEventInfos(WriteEventInfo elem) {
+ if (this.writeEventInfos == null) {
+ this.writeEventInfos = new ArrayList<WriteEventInfo>();
+ }
+ this.writeEventInfos.add(elem);
+ }
+
+ public List<WriteEventInfo> getWriteEventInfos() {
+ return this.writeEventInfos;
+ }
+
+ public void setWriteEventInfos(List<WriteEventInfo> writeEventInfos) {
+ this.writeEventInfos = writeEventInfos;
+ }
+
+ public void unsetWriteEventInfos() {
+ this.writeEventInfos = null;
+ }
+
+ /** Returns true if field writeEventInfos is set (has been assigned a value) and false otherwise */
+ public boolean isSetWriteEventInfos() {
+ return this.writeEventInfos != null;
+ }
+
+ public void setWriteEventInfosIsSet(boolean value) {
+ if (!value) {
+ this.writeEventInfos = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case TXNID:
@@ -222,6 +276,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case WRITE_EVENT_INFOS:
+ if (value == null) {
+ unsetWriteEventInfos();
+ } else {
+ setWriteEventInfos((List<WriteEventInfo>)value);
+ }
+ break;
+
}
}
@@ -233,6 +295,9 @@ import org.slf4j.LoggerFactory;
case REPL_POLICY:
return getReplPolicy();
+ case WRITE_EVENT_INFOS:
+ return getWriteEventInfos();
+
}
throw new IllegalStateException();
}
@@ -248,6 +313,8 @@ import org.slf4j.LoggerFactory;
return isSetTxnid();
case REPL_POLICY:
return isSetReplPolicy();
+ case WRITE_EVENT_INFOS:
+ return isSetWriteEventInfos();
}
throw new IllegalStateException();
}
@@ -283,6 +350,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_writeEventInfos = true && this.isSetWriteEventInfos();
+ boolean that_present_writeEventInfos = true && that.isSetWriteEventInfos();
+ if (this_present_writeEventInfos || that_present_writeEventInfos) {
+ if (!(this_present_writeEventInfos && that_present_writeEventInfos))
+ return false;
+ if (!this.writeEventInfos.equals(that.writeEventInfos))
+ return false;
+ }
+
return true;
}
@@ -300,6 +376,11 @@ import org.slf4j.LoggerFactory;
if (present_replPolicy)
list.add(replPolicy);
+ boolean present_writeEventInfos = true && (isSetWriteEventInfos());
+ list.add(present_writeEventInfos);
+ if (present_writeEventInfos)
+ list.add(writeEventInfos);
+
return list.hashCode();
}
@@ -331,6 +412,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetWriteEventInfos()).compareTo(other.isSetWriteEventInfos());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetWriteEventInfos()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.writeEventInfos, other.writeEventInfos);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -364,6 +455,16 @@ import org.slf4j.LoggerFactory;
}
first = false;
}
+ if (isSetWriteEventInfos()) {
+ if (!first) sb.append(", ");
+ sb.append("writeEventInfos:");
+ if (this.writeEventInfos == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.writeEventInfos);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -429,6 +530,25 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 3: // WRITE_EVENT_INFOS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
+ struct.writeEventInfos = new ArrayList<WriteEventInfo>(_list594.size);
+ WriteEventInfo _elem595;
+ for (int _i596 = 0; _i596 < _list594.size; ++_i596)
+ {
+ _elem595 = new WriteEventInfo();
+ _elem595.read(iprot);
+ struct.writeEventInfos.add(_elem595);
+ }
+ iprot.readListEnd();
+ }
+ struct.setWriteEventInfosIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -452,6 +572,20 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldEnd();
}
}
+ if (struct.writeEventInfos != null) {
+ if (struct.isSetWriteEventInfos()) {
+ oprot.writeFieldBegin(WRITE_EVENT_INFOS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.writeEventInfos.size()));
+ for (WriteEventInfo _iter597 : struct.writeEventInfos)
+ {
+ _iter597.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -474,10 +608,22 @@ import org.slf4j.LoggerFactory;
if (struct.isSetReplPolicy()) {
optionals.set(0);
}
- oprot.writeBitSet(optionals, 1);
+ if (struct.isSetWriteEventInfos()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
if (struct.isSetReplPolicy()) {
oprot.writeString(struct.replPolicy);
}
+ if (struct.isSetWriteEventInfos()) {
+ {
+ oprot.writeI32(struct.writeEventInfos.size());
+ for (WriteEventInfo _iter598 : struct.writeEventInfos)
+ {
+ _iter598.write(oprot);
+ }
+ }
+ }
}
@Override
@@ -485,11 +631,25 @@ import org.slf4j.LoggerFactory;
TTupleProtocol iprot = (TTupleProtocol) prot;
struct.txnid = iprot.readI64();
struct.setTxnidIsSet(true);
- BitSet incoming = iprot.readBitSet(1);
+ BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.replPolicy = iprot.readString();
struct.setReplPolicyIsSet(true);
}
+ if (incoming.get(1)) {
+ {
+ org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.writeEventInfos = new ArrayList<WriteEventInfo>(_list599.size);
+ WriteEventInfo _elem600;
+ for (int _i601 = 0; _i601 < _list599.size; ++_i601)
+ {
+ _elem600 = new WriteEventInfo();
+ _elem600.read(iprot);
+ struct.writeEventInfos.add(_elem600);
+ }
+ }
+ struct.setWriteEventInfosIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
index 31f2e14..57eb5ef 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
@@ -814,15 +814,15 @@ import org.slf4j.LoggerFactory;
case 6: // PROPERTIES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map682 = iprot.readMapBegin();
- struct.properties = new HashMap<String,String>(2*_map682.size);
- String _key683;
- String _val684;
- for (int _i685 = 0; _i685 < _map682.size; ++_i685)
+ org.apache.thrift.protocol.TMap _map690 = iprot.readMapBegin();
+ struct.properties = new HashMap<String,String>(2*_map690.size);
+ String _key691;
+ String _val692;
+ for (int _i693 = 0; _i693 < _map690.size; ++_i693)
{
- _key683 = iprot.readString();
- _val684 = iprot.readString();
- struct.properties.put(_key683, _val684);
+ _key691 = iprot.readString();
+ _val692 = iprot.readString();
+ struct.properties.put(_key691, _val692);
}
iprot.readMapEnd();
}
@@ -878,10 +878,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size()));
- for (Map.Entry<String, String> _iter686 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter694 : struct.properties.entrySet())
{
- oprot.writeString(_iter686.getKey());
- oprot.writeString(_iter686.getValue());
+ oprot.writeString(_iter694.getKey());
+ oprot.writeString(_iter694.getValue());
}
oprot.writeMapEnd();
}
@@ -928,10 +928,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetProperties()) {
{
oprot.writeI32(struct.properties.size());
- for (Map.Entry<String, String> _iter687 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter695 : struct.properties.entrySet())
{
- oprot.writeString(_iter687.getKey());
- oprot.writeString(_iter687.getValue());
+ oprot.writeString(_iter695.getKey());
+ oprot.writeString(_iter695.getValue());
}
}
}
@@ -957,15 +957,15 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map688 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.properties = new HashMap<String,String>(2*_map688.size);
- String _key689;
- String _val690;
- for (int _i691 = 0; _i691 < _map688.size; ++_i691)
+ org.apache.thrift.protocol.TMap _map696 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.properties = new HashMap<String,String>(2*_map696.size);
+ String _key697;
+ String _val698;
+ for (int _i699 = 0; _i699 < _map696.size; ++_i699)
{
- _key689 = iprot.readString();
- _val690 = iprot.readString();
- struct.properties.put(_key689, _val690);
+ _key697 = iprot.readString();
+ _val698 = iprot.readString();
+ struct.properties.put(_key697, _val698);
}
}
struct.setPropertiesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
index ab7b059..611bf6f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
@@ -712,13 +712,13 @@ import org.slf4j.LoggerFactory;
case 4: // TABLES_USED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set708 = iprot.readSetBegin();
- struct.tablesUsed = new HashSet<String>(2*_set708.size);
- String _elem709;
- for (int _i710 = 0; _i710 < _set708.size; ++_i710)
+ org.apache.thrift.protocol.TSet _set716 = iprot.readSetBegin();
+ struct.tablesUsed = new HashSet<String>(2*_set716.size);
+ String _elem717;
+ for (int _i718 = 0; _i718 < _set716.size; ++_i718)
{
- _elem709 = iprot.readString();
- struct.tablesUsed.add(_elem709);
+ _elem717 = iprot.readString();
+ struct.tablesUsed.add(_elem717);
}
iprot.readSetEnd();
}
@@ -767,9 +767,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_USED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.tablesUsed.size()));
- for (String _iter711 : struct.tablesUsed)
+ for (String _iter719 : struct.tablesUsed)
{
- oprot.writeString(_iter711);
+ oprot.writeString(_iter719);
}
oprot.writeSetEnd();
}
@@ -804,9 +804,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.tablesUsed.size());
- for (String _iter712 : struct.tablesUsed)
+ for (String _iter720 : struct.tablesUsed)
{
- oprot.writeString(_iter712);
+ oprot.writeString(_iter720);
}
}
BitSet optionals = new BitSet();
@@ -829,13 +829,13 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TSet _set713 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tablesUsed = new HashSet<String>(2*_set713.size);
- String _elem714;
- for (int _i715 = 0; _i715 < _set713.size; ++_i715)
+ org.apache.thrift.protocol.TSet _set721 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tablesUsed = new HashSet<String>(2*_set721.size);
+ String _elem722;
+ for (int _i723 = 0; _i723 < _set721.size; ++_i723)
{
- _elem714 = iprot.readString();
- struct.tablesUsed.add(_elem714);
+ _elem722 = iprot.readString();
+ struct.tablesUsed.add(_elem722);
}
}
struct.setTablesUsedIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FindSchemasByColsResp.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FindSchemasByColsResp.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FindSchemasByColsResp.java
index e43493e..8f5b4e5 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FindSchemasByColsResp.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FindSchemasByColsResp.java
@@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory;
case 1: // SCHEMA_VERSIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list920 = iprot.readListBegin();
- struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list920.size);
- SchemaVersionDescriptor _elem921;
- for (int _i922 = 0; _i922 < _list920.size; ++_i922)
+ org.apache.thrift.protocol.TList _list944 = iprot.readListBegin();
+ struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list944.size);
+ SchemaVersionDescriptor _elem945;
+ for (int _i946 = 0; _i946 < _list944.size; ++_i946)
{
- _elem921 = new SchemaVersionDescriptor();
- _elem921.read(iprot);
- struct.schemaVersions.add(_elem921);
+ _elem945 = new SchemaVersionDescriptor();
+ _elem945.read(iprot);
+ struct.schemaVersions.add(_elem945);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SCHEMA_VERSIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.schemaVersions.size()));
- for (SchemaVersionDescriptor _iter923 : struct.schemaVersions)
+ for (SchemaVersionDescriptor _iter947 : struct.schemaVersions)
{
- _iter923.write(oprot);
+ _iter947.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSchemaVersions()) {
{
oprot.writeI32(struct.schemaVersions.size());
- for (SchemaVersionDescriptor _iter924 : struct.schemaVersions)
+ for (SchemaVersionDescriptor _iter948 : struct.schemaVersions)
{
- _iter924.write(oprot);
+ _iter948.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list925 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list925.size);
- SchemaVersionDescriptor _elem926;
- for (int _i927 = 0; _i927 < _list925.size; ++_i927)
+ org.apache.thrift.protocol.TList _list949 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list949.size);
+ SchemaVersionDescriptor _elem950;
+ for (int _i951 = 0; _i951 < _list949.size; ++_i951)
{
- _elem926 = new SchemaVersionDescriptor();
- _elem926.read(iprot);
- struct.schemaVersions.add(_elem926);
+ _elem950 = new SchemaVersionDescriptor();
+ _elem950.read(iprot);
+ struct.schemaVersions.add(_elem950);
}
}
struct.setSchemaVersionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
index 7b0ec6c..2560922 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
@@ -794,13 +794,13 @@ import org.slf4j.LoggerFactory;
case 5: // PARTITION_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list740 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list740.size);
- String _elem741;
- for (int _i742 = 0; _i742 < _list740.size; ++_i742)
+ org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
+ struct.partitionVals = new ArrayList<String>(_list756.size);
+ String _elem757;
+ for (int _i758 = 0; _i758 < _list756.size; ++_i758)
{
- _elem741 = iprot.readString();
- struct.partitionVals.add(_elem741);
+ _elem757 = iprot.readString();
+ struct.partitionVals.add(_elem757);
}
iprot.readListEnd();
}
@@ -857,9 +857,9 @@ import org.slf4j.LoggerFactory;
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 _iter743 : struct.partitionVals)
+ for (String _iter759 : struct.partitionVals)
{
- oprot.writeString(_iter743);
+ oprot.writeString(_iter759);
}
oprot.writeListEnd();
}
@@ -915,9 +915,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter744 : struct.partitionVals)
+ for (String _iter760 : struct.partitionVals)
{
- oprot.writeString(_iter744);
+ oprot.writeString(_iter760);
}
}
}
@@ -945,13 +945,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list745 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list745.size);
- String _elem746;
- for (int _i747 = 0; _i747 < _list745.size; ++_i747)
+ org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionVals = new ArrayList<String>(_list761.size);
+ String _elem762;
+ for (int _i763 = 0; _i763 < _list761.size; ++_i763)
{
- _elem746 = iprot.readString();
- struct.partitionVals.add(_elem746);
+ _elem762 = iprot.readString();
+ struct.partitionVals.add(_elem762);
}
}
struct.setPartitionValsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
index 544ba19..f68afe8 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
@@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory;
case 1: // FUNCTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list808 = iprot.readListBegin();
- struct.functions = new ArrayList<Function>(_list808.size);
- Function _elem809;
- for (int _i810 = 0; _i810 < _list808.size; ++_i810)
+ org.apache.thrift.protocol.TList _list832 = iprot.readListBegin();
+ struct.functions = new ArrayList<Function>(_list832.size);
+ Function _elem833;
+ for (int _i834 = 0; _i834 < _list832.size; ++_i834)
{
- _elem809 = new Function();
- _elem809.read(iprot);
- struct.functions.add(_elem809);
+ _elem833 = new Function();
+ _elem833.read(iprot);
+ struct.functions.add(_elem833);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FUNCTIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.functions.size()));
- for (Function _iter811 : struct.functions)
+ for (Function _iter835 : struct.functions)
{
- _iter811.write(oprot);
+ _iter835.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFunctions()) {
{
oprot.writeI32(struct.functions.size());
- for (Function _iter812 : struct.functions)
+ for (Function _iter836 : struct.functions)
{
- _iter812.write(oprot);
+ _iter836.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list813 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.functions = new ArrayList<Function>(_list813.size);
- Function _elem814;
- for (int _i815 = 0; _i815 < _list813.size; ++_i815)
+ org.apache.thrift.protocol.TList _list837 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.functions = new ArrayList<Function>(_list837.size);
+ Function _elem838;
+ for (int _i839 = 0; _i839 < _list837.size; ++_i839)
{
- _elem814 = new Function();
- _elem814.read(iprot);
- struct.functions.add(_elem814);
+ _elem838 = new Function();
+ _elem838.read(iprot);
+ struct.functions.add(_elem838);
}
}
struct.setFunctionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
index 0a94f2f..836f35f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
@@ -619,13 +619,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list758 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list758.size);
- long _elem759;
- for (int _i760 = 0; _i760 < _list758.size; ++_i760)
+ org.apache.thrift.protocol.TList _list782 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list782.size);
+ long _elem783;
+ for (int _i784 = 0; _i784 < _list782.size; ++_i784)
{
- _elem759 = iprot.readI64();
- struct.fileIds.add(_elem759);
+ _elem783 = iprot.readI64();
+ struct.fileIds.add(_elem783);
}
iprot.readListEnd();
}
@@ -675,9 +675,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter761 : struct.fileIds)
+ for (long _iter785 : struct.fileIds)
{
- oprot.writeI64(_iter761);
+ oprot.writeI64(_iter785);
}
oprot.writeListEnd();
}
@@ -719,9 +719,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter762 : struct.fileIds)
+ for (long _iter786 : struct.fileIds)
{
- oprot.writeI64(_iter762);
+ oprot.writeI64(_iter786);
}
}
oprot.writeBinary(struct.expr);
@@ -745,13 +745,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list763 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list763.size);
- long _elem764;
- for (int _i765 = 0; _i765 < _list763.size; ++_i765)
+ org.apache.thrift.protocol.TList _list787 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list787.size);
+ long _elem788;
+ for (int _i789 = 0; _i789 < _list787.size; ++_i789)
{
- _elem764 = iprot.readI64();
- struct.fileIds.add(_elem764);
+ _elem788 = iprot.readI64();
+ struct.fileIds.add(_elem788);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
index e07d2e5..17f0ee5 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
@@ -444,16 +444,16 @@ import org.slf4j.LoggerFactory;
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map748 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map748.size);
- long _key749;
- MetadataPpdResult _val750;
- for (int _i751 = 0; _i751 < _map748.size; ++_i751)
+ org.apache.thrift.protocol.TMap _map772 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map772.size);
+ long _key773;
+ MetadataPpdResult _val774;
+ for (int _i775 = 0; _i775 < _map772.size; ++_i775)
{
- _key749 = iprot.readI64();
- _val750 = new MetadataPpdResult();
- _val750.read(iprot);
- struct.metadata.put(_key749, _val750);
+ _key773 = iprot.readI64();
+ _val774 = new MetadataPpdResult();
+ _val774.read(iprot);
+ struct.metadata.put(_key773, _val774);
}
iprot.readMapEnd();
}
@@ -487,10 +487,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, struct.metadata.size()));
- for (Map.Entry<Long, MetadataPpdResult> _iter752 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter776 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter752.getKey());
- _iter752.getValue().write(oprot);
+ oprot.writeI64(_iter776.getKey());
+ _iter776.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -518,10 +518,10 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, MetadataPpdResult> _iter753 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter777 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter753.getKey());
- _iter753.getValue().write(oprot);
+ oprot.writeI64(_iter777.getKey());
+ _iter777.getValue().write(oprot);
}
}
oprot.writeBool(struct.isSupported);
@@ -531,16 +531,16 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map754 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map754.size);
- long _key755;
- MetadataPpdResult _val756;
- for (int _i757 = 0; _i757 < _map754.size; ++_i757)
+ org.apache.thrift.protocol.TMap _map778 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map778.size);
+ long _key779;
+ MetadataPpdResult _val780;
+ for (int _i781 = 0; _i781 < _map778.size; ++_i781)
{
- _key755 = iprot.readI64();
- _val756 = new MetadataPpdResult();
- _val756.read(iprot);
- struct.metadata.put(_key755, _val756);
+ _key779 = iprot.readI64();
+ _val780 = new MetadataPpdResult();
+ _val780.read(iprot);
+ struct.metadata.put(_key779, _val780);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
index ebb6639..12b4392 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list776 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list776.size);
- long _elem777;
- for (int _i778 = 0; _i778 < _list776.size; ++_i778)
+ org.apache.thrift.protocol.TList _list800 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list800.size);
+ long _elem801;
+ for (int _i802 = 0; _i802 < _list800.size; ++_i802)
{
- _elem777 = iprot.readI64();
- struct.fileIds.add(_elem777);
+ _elem801 = iprot.readI64();
+ struct.fileIds.add(_elem801);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter779 : struct.fileIds)
+ for (long _iter803 : struct.fileIds)
{
- oprot.writeI64(_iter779);
+ oprot.writeI64(_iter803);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter780 : struct.fileIds)
+ for (long _iter804 : struct.fileIds)
{
- oprot.writeI64(_iter780);
+ oprot.writeI64(_iter804);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list781 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list781.size);
- long _elem782;
- for (int _i783 = 0; _i783 < _list781.size; ++_i783)
+ org.apache.thrift.protocol.TList _list805 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list805.size);
+ long _elem806;
+ for (int _i807 = 0; _i807 < _list805.size; ++_i807)
{
- _elem782 = iprot.readI64();
- struct.fileIds.add(_elem782);
+ _elem806 = iprot.readI64();
+ struct.fileIds.add(_elem806);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
index 67981cd..65708d7 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
@@ -433,15 +433,15 @@ import org.slf4j.LoggerFactory;
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map766 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map766.size);
- long _key767;
- ByteBuffer _val768;
- for (int _i769 = 0; _i769 < _map766.size; ++_i769)
+ org.apache.thrift.protocol.TMap _map790 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map790.size);
+ long _key791;
+ ByteBuffer _val792;
+ for (int _i793 = 0; _i793 < _map790.size; ++_i793)
{
- _key767 = iprot.readI64();
- _val768 = iprot.readBinary();
- struct.metadata.put(_key767, _val768);
+ _key791 = iprot.readI64();
+ _val792 = iprot.readBinary();
+ struct.metadata.put(_key791, _val792);
}
iprot.readMapEnd();
}
@@ -475,10 +475,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (Map.Entry<Long, ByteBuffer> _iter770 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter794 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter770.getKey());
- oprot.writeBinary(_iter770.getValue());
+ oprot.writeI64(_iter794.getKey());
+ oprot.writeBinary(_iter794.getValue());
}
oprot.writeMapEnd();
}
@@ -506,10 +506,10 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, ByteBuffer> _iter771 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter795 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter771.getKey());
- oprot.writeBinary(_iter771.getValue());
+ oprot.writeI64(_iter795.getKey());
+ oprot.writeBinary(_iter795.getValue());
}
}
oprot.writeBool(struct.isSupported);
@@ -519,15 +519,15 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map772 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map772.size);
- long _key773;
- ByteBuffer _val774;
- for (int _i775 = 0; _i775 < _map772.size; ++_i775)
+ org.apache.thrift.protocol.TMap _map796 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map796.size);
+ long _key797;
+ ByteBuffer _val798;
+ for (int _i799 = 0; _i799 < _map796.size; ++_i799)
{
- _key773 = iprot.readI64();
- _val774 = iprot.readBinary();
- struct.metadata.put(_key773, _val774);
+ _key797 = iprot.readI64();
+ _val798 = iprot.readBinary();
+ struct.metadata.put(_key797, _val798);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
index 6a78b77..09ca865 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
@@ -606,13 +606,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list824 = iprot.readListBegin();
- struct.tblNames = new ArrayList<String>(_list824.size);
- String _elem825;
- for (int _i826 = 0; _i826 < _list824.size; ++_i826)
+ org.apache.thrift.protocol.TList _list848 = iprot.readListBegin();
+ struct.tblNames = new ArrayList<String>(_list848.size);
+ String _elem849;
+ for (int _i850 = 0; _i850 < _list848.size; ++_i850)
{
- _elem825 = iprot.readString();
- struct.tblNames.add(_elem825);
+ _elem849 = iprot.readString();
+ struct.tblNames.add(_elem849);
}
iprot.readListEnd();
}
@@ -661,9 +661,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tblNames.size()));
- for (String _iter827 : struct.tblNames)
+ for (String _iter851 : struct.tblNames)
{
- oprot.writeString(_iter827);
+ oprot.writeString(_iter851);
}
oprot.writeListEnd();
}
@@ -716,9 +716,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTblNames()) {
{
oprot.writeI32(struct.tblNames.size());
- for (String _iter828 : struct.tblNames)
+ for (String _iter852 : struct.tblNames)
{
- oprot.writeString(_iter828);
+ oprot.writeString(_iter852);
}
}
}
@@ -738,13 +738,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list829 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tblNames = new ArrayList<String>(_list829.size);
- String _elem830;
- for (int _i831 = 0; _i831 < _list829.size; ++_i831)
+ org.apache.thrift.protocol.TList _list853 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tblNames = new ArrayList<String>(_list853.size);
+ String _elem854;
+ for (int _i855 = 0; _i855 < _list853.size; ++_i855)
{
- _elem830 = iprot.readString();
- struct.tblNames.add(_elem830);
+ _elem854 = iprot.readString();
+ struct.tblNames.add(_elem854);
}
}
struct.setTblNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
index 13be2ed..72256e6 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TABLES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list832 = iprot.readListBegin();
- struct.tables = new ArrayList<Table>(_list832.size);
- Table _elem833;
- for (int _i834 = 0; _i834 < _list832.size; ++_i834)
+ org.apache.thrift.protocol.TList _list856 = iprot.readListBegin();
+ struct.tables = new ArrayList<Table>(_list856.size);
+ Table _elem857;
+ for (int _i858 = 0; _i858 < _list856.size; ++_i858)
{
- _elem833 = new Table();
- _elem833.read(iprot);
- struct.tables.add(_elem833);
+ _elem857 = new Table();
+ _elem857.read(iprot);
+ struct.tables.add(_elem857);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tables.size()));
- for (Table _iter835 : struct.tables)
+ for (Table _iter859 : struct.tables)
{
- _iter835.write(oprot);
+ _iter859.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tables.size());
- for (Table _iter836 : struct.tables)
+ for (Table _iter860 : struct.tables)
{
- _iter836.write(oprot);
+ _iter860.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list837 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tables = new ArrayList<Table>(_list837.size);
- Table _elem838;
- for (int _i839 = 0; _i839 < _list837.size; ++_i839)
+ org.apache.thrift.protocol.TList _list861 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tables = new ArrayList<Table>(_list861.size);
+ Table _elem862;
+ for (int _i863 = 0; _i863 < _list861.size; ++_i863)
{
- _elem838 = new Table();
- _elem838.read(iprot);
- struct.tables.add(_elem838);
+ _elem862 = new Table();
+ _elem862.read(iprot);
+ struct.tables.add(_elem862);
}
}
struct.setTablesIsSet(true);