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);