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/05/02 06:45:33 UTC
[09/14] hive git commit: HIVE-18988: Support bootstrap replication of
ACID tables (Sankar Hariappan, reviewed by Mahesh Kumar Behera, Thejas M Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 6298893..4dad6dd 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
@@ -443,6 +443,8 @@ class AbortTxnsRequest;
class CommitTxnRequest;
+class ReplTblWriteIdStateRequest;
+
class GetValidWriteIdsRequest;
class TableValidWriteIds;
@@ -6965,6 +6967,79 @@ inline std::ostream& operator<<(std::ostream& out, const CommitTxnRequest& obj)
return out;
}
+typedef struct _ReplTblWriteIdStateRequest__isset {
+ _ReplTblWriteIdStateRequest__isset() : partNames(false) {}
+ bool partNames :1;
+} _ReplTblWriteIdStateRequest__isset;
+
+class ReplTblWriteIdStateRequest {
+ public:
+
+ ReplTblWriteIdStateRequest(const ReplTblWriteIdStateRequest&);
+ ReplTblWriteIdStateRequest& operator=(const ReplTblWriteIdStateRequest&);
+ ReplTblWriteIdStateRequest() : validWriteIdlist(), user(), hostName(), dbName(), tableName() {
+ }
+
+ virtual ~ReplTblWriteIdStateRequest() throw();
+ std::string validWriteIdlist;
+ std::string user;
+ std::string hostName;
+ std::string dbName;
+ std::string tableName;
+ std::vector<std::string> partNames;
+
+ _ReplTblWriteIdStateRequest__isset __isset;
+
+ void __set_validWriteIdlist(const std::string& val);
+
+ void __set_user(const std::string& val);
+
+ void __set_hostName(const std::string& val);
+
+ void __set_dbName(const std::string& val);
+
+ void __set_tableName(const std::string& val);
+
+ void __set_partNames(const std::vector<std::string> & val);
+
+ bool operator == (const ReplTblWriteIdStateRequest & rhs) const
+ {
+ if (!(validWriteIdlist == rhs.validWriteIdlist))
+ return false;
+ if (!(user == rhs.user))
+ return false;
+ if (!(hostName == rhs.hostName))
+ return false;
+ if (!(dbName == rhs.dbName))
+ return false;
+ if (!(tableName == rhs.tableName))
+ return false;
+ if (__isset.partNames != rhs.__isset.partNames)
+ return false;
+ else if (__isset.partNames && !(partNames == rhs.partNames))
+ return false;
+ return true;
+ }
+ bool operator != (const ReplTblWriteIdStateRequest &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ReplTblWriteIdStateRequest & ) 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(ReplTblWriteIdStateRequest &a, ReplTblWriteIdStateRequest &b);
+
+inline std::ostream& operator<<(std::ostream& out, const ReplTblWriteIdStateRequest& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
class GetValidWriteIdsRequest {
public:
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 6411129..1dcc870 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 _list692 = iprot.readListBegin();
- struct.partitionnames = new ArrayList<String>(_list692.size);
- String _elem693;
- for (int _i694 = 0; _i694 < _list692.size; ++_i694)
+ 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)
{
- _elem693 = iprot.readString();
- struct.partitionnames.add(_elem693);
+ _elem701 = iprot.readString();
+ struct.partitionnames.add(_elem701);
}
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 _iter695 : struct.partitionnames)
+ for (String _iter703 : struct.partitionnames)
{
- oprot.writeString(_iter695);
+ oprot.writeString(_iter703);
}
oprot.writeListEnd();
}
@@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tablename);
{
oprot.writeI32(struct.partitionnames.size());
- for (String _iter696 : struct.partitionnames)
+ for (String _iter704 : struct.partitionnames)
{
- oprot.writeString(_iter696);
+ oprot.writeString(_iter704);
}
}
BitSet optionals = new BitSet();
@@ -937,13 +937,13 @@ import org.slf4j.LoggerFactory;
struct.tablename = iprot.readString();
struct.setTablenameIsSet(true);
{
- org.apache.thrift.protocol.TList _list697 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionnames = new ArrayList<String>(_list697.size);
- String _elem698;
- for (int _i699 = 0; _i699 < _list697.size; ++_i699)
+ 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)
{
- _elem698 = iprot.readString();
- struct.partitionnames.add(_elem698);
+ _elem706 = iprot.readString();
+ struct.partitionnames.add(_elem706);
}
}
struct.setPartitionnamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 5a60e95..fa33963 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 _list618 = iprot.readListBegin();
- struct.txnIds = new ArrayList<Long>(_list618.size);
- long _elem619;
- for (int _i620 = 0; _i620 < _list618.size; ++_i620)
+ 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)
{
- _elem619 = iprot.readI64();
- struct.txnIds.add(_elem619);
+ _elem627 = iprot.readI64();
+ struct.txnIds.add(_elem627);
}
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 _list621 = iprot.readListBegin();
- struct.srcTxnToWriteIdList = new ArrayList<TxnToWriteId>(_list621.size);
- TxnToWriteId _elem622;
- for (int _i623 = 0; _i623 < _list621.size; ++_i623)
+ 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)
{
- _elem622 = new TxnToWriteId();
- _elem622.read(iprot);
- struct.srcTxnToWriteIdList.add(_elem622);
+ _elem630 = new TxnToWriteId();
+ _elem630.read(iprot);
+ struct.srcTxnToWriteIdList.add(_elem630);
}
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 _iter624 : struct.txnIds)
+ for (long _iter632 : struct.txnIds)
{
- oprot.writeI64(_iter624);
+ oprot.writeI64(_iter632);
}
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 _iter625 : struct.srcTxnToWriteIdList)
+ for (TxnToWriteId _iter633 : struct.srcTxnToWriteIdList)
{
- _iter625.write(oprot);
+ _iter633.write(oprot);
}
oprot.writeListEnd();
}
@@ -849,9 +849,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTxnIds()) {
{
oprot.writeI32(struct.txnIds.size());
- for (long _iter626 : struct.txnIds)
+ for (long _iter634 : struct.txnIds)
{
- oprot.writeI64(_iter626);
+ oprot.writeI64(_iter634);
}
}
}
@@ -861,9 +861,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSrcTxnToWriteIdList()) {
{
oprot.writeI32(struct.srcTxnToWriteIdList.size());
- for (TxnToWriteId _iter627 : struct.srcTxnToWriteIdList)
+ for (TxnToWriteId _iter635 : struct.srcTxnToWriteIdList)
{
- _iter627.write(oprot);
+ _iter635.write(oprot);
}
}
}
@@ -879,13 +879,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list628 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txnIds = new ArrayList<Long>(_list628.size);
- long _elem629;
- for (int _i630 = 0; _i630 < _list628.size; ++_i630)
+ 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)
{
- _elem629 = iprot.readI64();
- struct.txnIds.add(_elem629);
+ _elem637 = iprot.readI64();
+ struct.txnIds.add(_elem637);
}
}
struct.setTxnIdsIsSet(true);
@@ -896,14 +896,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.srcTxnToWriteIdList = new ArrayList<TxnToWriteId>(_list631.size);
- TxnToWriteId _elem632;
- for (int _i633 = 0; _i633 < _list631.size; ++_i633)
+ 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)
{
- _elem632 = new TxnToWriteId();
- _elem632.read(iprot);
- struct.srcTxnToWriteIdList.add(_elem632);
+ _elem640 = new TxnToWriteId();
+ _elem640.read(iprot);
+ struct.srcTxnToWriteIdList.add(_elem640);
}
}
struct.setSrcTxnToWriteIdListIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 7bba38c..20dc757 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 _list634 = iprot.readListBegin();
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list634.size);
- TxnToWriteId _elem635;
- for (int _i636 = 0; _i636 < _list634.size; ++_i636)
+ 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)
{
- _elem635 = new TxnToWriteId();
- _elem635.read(iprot);
- struct.txnToWriteIds.add(_elem635);
+ _elem643 = new TxnToWriteId();
+ _elem643.read(iprot);
+ struct.txnToWriteIds.add(_elem643);
}
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 _iter637 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter645 : struct.txnToWriteIds)
{
- _iter637.write(oprot);
+ _iter645.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txnToWriteIds.size());
- for (TxnToWriteId _iter638 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter646 : struct.txnToWriteIds)
{
- _iter638.write(oprot);
+ _iter646.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 _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.txnToWriteIds = 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.txnToWriteIds = new ArrayList<TxnToWriteId>(_list647.size);
+ TxnToWriteId _elem648;
+ for (int _i649 = 0; _i649 < _list647.size; ++_i649)
{
- _elem640 = new TxnToWriteId();
- _elem640.read(iprot);
- struct.txnToWriteIds.add(_elem640);
+ _elem648 = new TxnToWriteId();
+ _elem648.read(iprot);
+ struct.txnToWriteIds.add(_elem648);
}
}
struct.setTxnToWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 7db0801..470a070 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 _list792 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list792.size);
- long _elem793;
- for (int _i794 = 0; _i794 < _list792.size; ++_i794)
+ 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)
{
- _elem793 = iprot.readI64();
- struct.fileIds.add(_elem793);
+ _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 _iter795 : struct.fileIds)
+ for (long _iter803 : struct.fileIds)
{
- oprot.writeI64(_iter795);
+ oprot.writeI64(_iter803);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter796 : struct.fileIds)
+ for (long _iter804 : struct.fileIds)
{
- oprot.writeI64(_iter796);
+ oprot.writeI64(_iter804);
}
}
}
@@ -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 _list797 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list797.size);
- long _elem798;
- for (int _i799 = 0; _i799 < _list797.size; ++_i799)
+ 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)
{
- _elem798 = iprot.readI64();
- struct.fileIds.add(_elem798);
+ _elem806 = iprot.readI64();
+ struct.fileIds.add(_elem806);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 a83c0bb..af48583 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 _list808 = iprot.readListBegin();
- struct.values = new ArrayList<ClientCapability>(_list808.size);
- ClientCapability _elem809;
- for (int _i810 = 0; _i810 < _list808.size; ++_i810)
+ 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)
{
- _elem809 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem809);
+ _elem817 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem817);
}
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 _iter811 : struct.values)
+ for (ClientCapability _iter819 : struct.values)
{
- oprot.writeI32(_iter811.getValue());
+ oprot.writeI32(_iter819.getValue());
}
oprot.writeListEnd();
}
@@ -413,9 +413,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.values.size());
- for (ClientCapability _iter812 : struct.values)
+ for (ClientCapability _iter820 : struct.values)
{
- oprot.writeI32(_iter812.getValue());
+ oprot.writeI32(_iter820.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 _list813 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.values = new ArrayList<ClientCapability>(_list813.size);
- ClientCapability _elem814;
- for (int _i815 = 0; _i815 < _list813.size; ++_i815)
+ 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)
{
- _elem814 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem814);
+ _elem822 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem822);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 524a48e..31f2e14 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 _map674 = iprot.readMapBegin();
- struct.properties = new HashMap<String,String>(2*_map674.size);
- String _key675;
- String _val676;
- for (int _i677 = 0; _i677 < _map674.size; ++_i677)
+ 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)
{
- _key675 = iprot.readString();
- _val676 = iprot.readString();
- struct.properties.put(_key675, _val676);
+ _key683 = iprot.readString();
+ _val684 = iprot.readString();
+ struct.properties.put(_key683, _val684);
}
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> _iter678 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter686 : struct.properties.entrySet())
{
- oprot.writeString(_iter678.getKey());
- oprot.writeString(_iter678.getValue());
+ oprot.writeString(_iter686.getKey());
+ oprot.writeString(_iter686.getValue());
}
oprot.writeMapEnd();
}
@@ -928,10 +928,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetProperties()) {
{
oprot.writeI32(struct.properties.size());
- for (Map.Entry<String, String> _iter679 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter687 : struct.properties.entrySet())
{
- oprot.writeString(_iter679.getKey());
- oprot.writeString(_iter679.getValue());
+ oprot.writeString(_iter687.getKey());
+ oprot.writeString(_iter687.getValue());
}
}
}
@@ -957,15 +957,15 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map680 = 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*_map680.size);
- String _key681;
- String _val682;
- for (int _i683 = 0; _i683 < _map680.size; ++_i683)
+ 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)
{
- _key681 = iprot.readString();
- _val682 = iprot.readString();
- struct.properties.put(_key681, _val682);
+ _key689 = iprot.readString();
+ _val690 = iprot.readString();
+ struct.properties.put(_key689, _val690);
}
}
struct.setPropertiesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 8e4144e..ab7b059 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 _set700 = iprot.readSetBegin();
- struct.tablesUsed = new HashSet<String>(2*_set700.size);
- String _elem701;
- for (int _i702 = 0; _i702 < _set700.size; ++_i702)
+ 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)
{
- _elem701 = iprot.readString();
- struct.tablesUsed.add(_elem701);
+ _elem709 = iprot.readString();
+ struct.tablesUsed.add(_elem709);
}
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 _iter703 : struct.tablesUsed)
+ for (String _iter711 : struct.tablesUsed)
{
- oprot.writeString(_iter703);
+ oprot.writeString(_iter711);
}
oprot.writeSetEnd();
}
@@ -804,9 +804,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.tablesUsed.size());
- for (String _iter704 : struct.tablesUsed)
+ for (String _iter712 : struct.tablesUsed)
{
- oprot.writeString(_iter704);
+ oprot.writeString(_iter712);
}
}
BitSet optionals = new BitSet();
@@ -829,13 +829,13 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TSet _set705 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tablesUsed = new HashSet<String>(2*_set705.size);
- String _elem706;
- for (int _i707 = 0; _i707 < _set705.size; ++_i707)
+ 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)
{
- _elem706 = iprot.readString();
- struct.tablesUsed.add(_elem706);
+ _elem714 = iprot.readString();
+ struct.tablesUsed.add(_elem714);
}
}
struct.setTablesUsedIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 bb64086..e43493e 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 _list912 = iprot.readListBegin();
- struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list912.size);
- SchemaVersionDescriptor _elem913;
- for (int _i914 = 0; _i914 < _list912.size; ++_i914)
+ 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)
{
- _elem913 = new SchemaVersionDescriptor();
- _elem913.read(iprot);
- struct.schemaVersions.add(_elem913);
+ _elem921 = new SchemaVersionDescriptor();
+ _elem921.read(iprot);
+ struct.schemaVersions.add(_elem921);
}
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 _iter915 : struct.schemaVersions)
+ for (SchemaVersionDescriptor _iter923 : struct.schemaVersions)
{
- _iter915.write(oprot);
+ _iter923.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSchemaVersions()) {
{
oprot.writeI32(struct.schemaVersions.size());
- for (SchemaVersionDescriptor _iter916 : struct.schemaVersions)
+ for (SchemaVersionDescriptor _iter924 : struct.schemaVersions)
{
- _iter916.write(oprot);
+ _iter924.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list917 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list917.size);
- SchemaVersionDescriptor _elem918;
- for (int _i919 = 0; _i919 < _list917.size; ++_i919)
+ 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)
{
- _elem918 = new SchemaVersionDescriptor();
- _elem918.read(iprot);
- struct.schemaVersions.add(_elem918);
+ _elem926 = new SchemaVersionDescriptor();
+ _elem926.read(iprot);
+ struct.schemaVersions.add(_elem926);
}
}
struct.setSchemaVersionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 42c9b53..7b0ec6c 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 _list732 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list732.size);
- String _elem733;
- for (int _i734 = 0; _i734 < _list732.size; ++_i734)
+ 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)
{
- _elem733 = iprot.readString();
- struct.partitionVals.add(_elem733);
+ _elem741 = iprot.readString();
+ struct.partitionVals.add(_elem741);
}
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 _iter735 : struct.partitionVals)
+ for (String _iter743 : struct.partitionVals)
{
- oprot.writeString(_iter735);
+ oprot.writeString(_iter743);
}
oprot.writeListEnd();
}
@@ -915,9 +915,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter736 : struct.partitionVals)
+ for (String _iter744 : struct.partitionVals)
{
- oprot.writeString(_iter736);
+ oprot.writeString(_iter744);
}
}
}
@@ -945,13 +945,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list737.size);
- String _elem738;
- for (int _i739 = 0; _i739 < _list737.size; ++_i739)
+ 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)
{
- _elem738 = iprot.readString();
- struct.partitionVals.add(_elem738);
+ _elem746 = iprot.readString();
+ struct.partitionVals.add(_elem746);
}
}
struct.setPartitionValsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 32e6543..544ba19 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 _list800 = iprot.readListBegin();
- struct.functions = new ArrayList<Function>(_list800.size);
- Function _elem801;
- for (int _i802 = 0; _i802 < _list800.size; ++_i802)
+ 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)
{
- _elem801 = new Function();
- _elem801.read(iprot);
- struct.functions.add(_elem801);
+ _elem809 = new Function();
+ _elem809.read(iprot);
+ struct.functions.add(_elem809);
}
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 _iter803 : struct.functions)
+ for (Function _iter811 : struct.functions)
{
- _iter803.write(oprot);
+ _iter811.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFunctions()) {
{
oprot.writeI32(struct.functions.size());
- for (Function _iter804 : struct.functions)
+ for (Function _iter812 : struct.functions)
{
- _iter804.write(oprot);
+ _iter812.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list805 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.functions = new ArrayList<Function>(_list805.size);
- Function _elem806;
- for (int _i807 = 0; _i807 < _list805.size; ++_i807)
+ 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)
{
- _elem806 = new Function();
- _elem806.read(iprot);
- struct.functions.add(_elem806);
+ _elem814 = new Function();
+ _elem814.read(iprot);
+ struct.functions.add(_elem814);
}
}
struct.setFunctionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 8dab985..0a94f2f 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 _list750 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list750.size);
- long _elem751;
- for (int _i752 = 0; _i752 < _list750.size; ++_i752)
+ 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)
{
- _elem751 = iprot.readI64();
- struct.fileIds.add(_elem751);
+ _elem759 = iprot.readI64();
+ struct.fileIds.add(_elem759);
}
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 _iter753 : struct.fileIds)
+ for (long _iter761 : struct.fileIds)
{
- oprot.writeI64(_iter753);
+ oprot.writeI64(_iter761);
}
oprot.writeListEnd();
}
@@ -719,9 +719,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter754 : struct.fileIds)
+ for (long _iter762 : struct.fileIds)
{
- oprot.writeI64(_iter754);
+ oprot.writeI64(_iter762);
}
}
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 _list755 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list755.size);
- long _elem756;
- for (int _i757 = 0; _i757 < _list755.size; ++_i757)
+ 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)
{
- _elem756 = iprot.readI64();
- struct.fileIds.add(_elem756);
+ _elem764 = iprot.readI64();
+ struct.fileIds.add(_elem764);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 d94ea73..e07d2e5 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 _map740 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map740.size);
- long _key741;
- MetadataPpdResult _val742;
- for (int _i743 = 0; _i743 < _map740.size; ++_i743)
+ 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)
{
- _key741 = iprot.readI64();
- _val742 = new MetadataPpdResult();
- _val742.read(iprot);
- struct.metadata.put(_key741, _val742);
+ _key749 = iprot.readI64();
+ _val750 = new MetadataPpdResult();
+ _val750.read(iprot);
+ struct.metadata.put(_key749, _val750);
}
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> _iter744 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter752 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter744.getKey());
- _iter744.getValue().write(oprot);
+ oprot.writeI64(_iter752.getKey());
+ _iter752.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> _iter745 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter753 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter745.getKey());
- _iter745.getValue().write(oprot);
+ oprot.writeI64(_iter753.getKey());
+ _iter753.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 _map746 = 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*_map746.size);
- long _key747;
- MetadataPpdResult _val748;
- for (int _i749 = 0; _i749 < _map746.size; ++_i749)
+ 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)
{
- _key747 = iprot.readI64();
- _val748 = new MetadataPpdResult();
- _val748.read(iprot);
- struct.metadata.put(_key747, _val748);
+ _key755 = iprot.readI64();
+ _val756 = new MetadataPpdResult();
+ _val756.read(iprot);
+ struct.metadata.put(_key755, _val756);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 9dfc484..ebb6639 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 _list768 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list768.size);
- long _elem769;
- for (int _i770 = 0; _i770 < _list768.size; ++_i770)
+ 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)
{
- _elem769 = iprot.readI64();
- struct.fileIds.add(_elem769);
+ _elem777 = iprot.readI64();
+ struct.fileIds.add(_elem777);
}
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 _iter771 : struct.fileIds)
+ for (long _iter779 : struct.fileIds)
{
- oprot.writeI64(_iter771);
+ oprot.writeI64(_iter779);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter772 : struct.fileIds)
+ for (long _iter780 : struct.fileIds)
{
- oprot.writeI64(_iter772);
+ oprot.writeI64(_iter780);
}
}
}
@@ -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 _list773 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list773.size);
- long _elem774;
- for (int _i775 = 0; _i775 < _list773.size; ++_i775)
+ 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)
{
- _elem774 = iprot.readI64();
- struct.fileIds.add(_elem774);
+ _elem782 = iprot.readI64();
+ struct.fileIds.add(_elem782);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 d454340..67981cd 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 _map758 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map758.size);
- long _key759;
- ByteBuffer _val760;
- for (int _i761 = 0; _i761 < _map758.size; ++_i761)
+ 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)
{
- _key759 = iprot.readI64();
- _val760 = iprot.readBinary();
- struct.metadata.put(_key759, _val760);
+ _key767 = iprot.readI64();
+ _val768 = iprot.readBinary();
+ struct.metadata.put(_key767, _val768);
}
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> _iter762 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter770 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter762.getKey());
- oprot.writeBinary(_iter762.getValue());
+ oprot.writeI64(_iter770.getKey());
+ oprot.writeBinary(_iter770.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> _iter763 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter771 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter763.getKey());
- oprot.writeBinary(_iter763.getValue());
+ oprot.writeI64(_iter771.getKey());
+ oprot.writeBinary(_iter771.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 _map764 = 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*_map764.size);
- long _key765;
- ByteBuffer _val766;
- for (int _i767 = 0; _i767 < _map764.size; ++_i767)
+ 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)
{
- _key765 = iprot.readI64();
- _val766 = iprot.readBinary();
- struct.metadata.put(_key765, _val766);
+ _key773 = iprot.readI64();
+ _val774 = iprot.readBinary();
+ struct.metadata.put(_key773, _val774);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 f2be7ec..6a78b77 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 _list816 = iprot.readListBegin();
- struct.tblNames = new ArrayList<String>(_list816.size);
- String _elem817;
- for (int _i818 = 0; _i818 < _list816.size; ++_i818)
+ 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)
{
- _elem817 = iprot.readString();
- struct.tblNames.add(_elem817);
+ _elem825 = iprot.readString();
+ struct.tblNames.add(_elem825);
}
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 _iter819 : struct.tblNames)
+ for (String _iter827 : struct.tblNames)
{
- oprot.writeString(_iter819);
+ oprot.writeString(_iter827);
}
oprot.writeListEnd();
}
@@ -716,9 +716,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTblNames()) {
{
oprot.writeI32(struct.tblNames.size());
- for (String _iter820 : struct.tblNames)
+ for (String _iter828 : struct.tblNames)
{
- oprot.writeString(_iter820);
+ oprot.writeString(_iter828);
}
}
}
@@ -738,13 +738,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list821 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tblNames = new ArrayList<String>(_list821.size);
- String _elem822;
- for (int _i823 = 0; _i823 < _list821.size; ++_i823)
+ 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)
{
- _elem822 = iprot.readString();
- struct.tblNames.add(_elem822);
+ _elem830 = iprot.readString();
+ struct.tblNames.add(_elem830);
}
}
struct.setTblNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/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 371757a..13be2ed 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 _list824 = iprot.readListBegin();
- struct.tables = new ArrayList<Table>(_list824.size);
- Table _elem825;
- for (int _i826 = 0; _i826 < _list824.size; ++_i826)
+ 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)
{
- _elem825 = new Table();
- _elem825.read(iprot);
- struct.tables.add(_elem825);
+ _elem833 = new Table();
+ _elem833.read(iprot);
+ struct.tables.add(_elem833);
}
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 _iter827 : struct.tables)
+ for (Table _iter835 : struct.tables)
{
- _iter827.write(oprot);
+ _iter835.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tables.size());
- for (Table _iter828 : struct.tables)
+ for (Table _iter836 : struct.tables)
{
- _iter828.write(oprot);
+ _iter836.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 _list829 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tables = new ArrayList<Table>(_list829.size);
- Table _elem830;
- for (int _i831 = 0; _i831 < _list829.size; ++_i831)
+ 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)
{
- _elem830 = new Table();
- _elem830.read(iprot);
- struct.tables.add(_elem830);
+ _elem838 = new Table();
+ _elem838.read(iprot);
+ struct.tables.add(_elem838);
}
}
struct.setTablesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
index 58c608a..27b6cf8 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
@@ -436,13 +436,13 @@ import org.slf4j.LoggerFactory;
case 1: // FULL_TABLE_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
- struct.fullTableNames = new ArrayList<String>(_list594.size);
- String _elem595;
- for (int _i596 = 0; _i596 < _list594.size; ++_i596)
+ org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
+ struct.fullTableNames = new ArrayList<String>(_list602.size);
+ String _elem603;
+ for (int _i604 = 0; _i604 < _list602.size; ++_i604)
{
- _elem595 = iprot.readString();
- struct.fullTableNames.add(_elem595);
+ _elem603 = iprot.readString();
+ struct.fullTableNames.add(_elem603);
}
iprot.readListEnd();
}
@@ -476,9 +476,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FULL_TABLE_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fullTableNames.size()));
- for (String _iter597 : struct.fullTableNames)
+ for (String _iter605 : struct.fullTableNames)
{
- oprot.writeString(_iter597);
+ oprot.writeString(_iter605);
}
oprot.writeListEnd();
}
@@ -508,9 +508,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fullTableNames.size());
- for (String _iter598 : struct.fullTableNames)
+ for (String _iter606 : struct.fullTableNames)
{
- oprot.writeString(_iter598);
+ oprot.writeString(_iter606);
}
}
oprot.writeString(struct.validTxnList);
@@ -520,13 +520,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.fullTableNames = new ArrayList<String>(_list599.size);
- String _elem600;
- for (int _i601 = 0; _i601 < _list599.size; ++_i601)
+ org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.fullTableNames = new ArrayList<String>(_list607.size);
+ String _elem608;
+ for (int _i609 = 0; _i609 < _list607.size; ++_i609)
{
- _elem600 = iprot.readString();
- struct.fullTableNames.add(_elem600);
+ _elem608 = iprot.readString();
+ struct.fullTableNames.add(_elem608);
}
}
struct.setFullTableNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
index 86bc346..7a1bbc7 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TBL_VALID_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list610.size);
- TableValidWriteIds _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ org.apache.thrift.protocol.TList _list618 = iprot.readListBegin();
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list618.size);
+ TableValidWriteIds _elem619;
+ for (int _i620 = 0; _i620 < _list618.size; ++_i620)
{
- _elem611 = new TableValidWriteIds();
- _elem611.read(iprot);
- struct.tblValidWriteIds.add(_elem611);
+ _elem619 = new TableValidWriteIds();
+ _elem619.read(iprot);
+ struct.tblValidWriteIds.add(_elem619);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_VALID_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tblValidWriteIds.size()));
- for (TableValidWriteIds _iter613 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter621 : struct.tblValidWriteIds)
{
- _iter613.write(oprot);
+ _iter621.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tblValidWriteIds.size());
- for (TableValidWriteIds _iter614 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter622 : struct.tblValidWriteIds)
{
- _iter614.write(oprot);
+ _iter622.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list615.size);
- TableValidWriteIds _elem616;
- for (int _i617 = 0; _i617 < _list615.size; ++_i617)
+ org.apache.thrift.protocol.TList _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list623.size);
+ TableValidWriteIds _elem624;
+ for (int _i625 = 0; _i625 < _list623.size; ++_i625)
{
- _elem616 = new TableValidWriteIds();
- _elem616.read(iprot);
- struct.tblValidWriteIds.add(_elem616);
+ _elem624 = new TableValidWriteIds();
+ _elem624.read(iprot);
+ struct.tblValidWriteIds.add(_elem624);
}
}
struct.setTblValidWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
index 75ddaf6..4999215 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
@@ -453,13 +453,13 @@ import org.slf4j.LoggerFactory;
case 1: // ABORTED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set658 = iprot.readSetBegin();
- struct.aborted = new HashSet<Long>(2*_set658.size);
- long _elem659;
- for (int _i660 = 0; _i660 < _set658.size; ++_i660)
+ org.apache.thrift.protocol.TSet _set666 = iprot.readSetBegin();
+ struct.aborted = new HashSet<Long>(2*_set666.size);
+ long _elem667;
+ for (int _i668 = 0; _i668 < _set666.size; ++_i668)
{
- _elem659 = iprot.readI64();
- struct.aborted.add(_elem659);
+ _elem667 = iprot.readI64();
+ struct.aborted.add(_elem667);
}
iprot.readSetEnd();
}
@@ -471,13 +471,13 @@ import org.slf4j.LoggerFactory;
case 2: // NOSUCH
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set661 = iprot.readSetBegin();
- struct.nosuch = new HashSet<Long>(2*_set661.size);
- long _elem662;
- for (int _i663 = 0; _i663 < _set661.size; ++_i663)
+ org.apache.thrift.protocol.TSet _set669 = iprot.readSetBegin();
+ struct.nosuch = new HashSet<Long>(2*_set669.size);
+ long _elem670;
+ for (int _i671 = 0; _i671 < _set669.size; ++_i671)
{
- _elem662 = iprot.readI64();
- struct.nosuch.add(_elem662);
+ _elem670 = iprot.readI64();
+ struct.nosuch.add(_elem670);
}
iprot.readSetEnd();
}
@@ -503,9 +503,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(ABORTED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size()));
- for (long _iter664 : struct.aborted)
+ for (long _iter672 : struct.aborted)
{
- oprot.writeI64(_iter664);
+ oprot.writeI64(_iter672);
}
oprot.writeSetEnd();
}
@@ -515,9 +515,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOSUCH_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size()));
- for (long _iter665 : struct.nosuch)
+ for (long _iter673 : struct.nosuch)
{
- oprot.writeI64(_iter665);
+ oprot.writeI64(_iter673);
}
oprot.writeSetEnd();
}
@@ -542,16 +542,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.aborted.size());
- for (long _iter666 : struct.aborted)
+ for (long _iter674 : struct.aborted)
{
- oprot.writeI64(_iter666);
+ oprot.writeI64(_iter674);
}
}
{
oprot.writeI32(struct.nosuch.size());
- for (long _iter667 : struct.nosuch)
+ for (long _iter675 : struct.nosuch)
{
- oprot.writeI64(_iter667);
+ oprot.writeI64(_iter675);
}
}
}
@@ -560,24 +560,24 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TSet _set668 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.aborted = new HashSet<Long>(2*_set668.size);
- long _elem669;
- for (int _i670 = 0; _i670 < _set668.size; ++_i670)
+ org.apache.thrift.protocol.TSet _set676 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.aborted = new HashSet<Long>(2*_set676.size);
+ long _elem677;
+ for (int _i678 = 0; _i678 < _set676.size; ++_i678)
{
- _elem669 = iprot.readI64();
- struct.aborted.add(_elem669);
+ _elem677 = iprot.readI64();
+ struct.aborted.add(_elem677);
}
}
struct.setAbortedIsSet(true);
{
- org.apache.thrift.protocol.TSet _set671 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.nosuch = new HashSet<Long>(2*_set671.size);
- long _elem672;
- for (int _i673 = 0; _i673 < _set671.size; ++_i673)
+ org.apache.thrift.protocol.TSet _set679 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.nosuch = new HashSet<Long>(2*_set679.size);
+ long _elem680;
+ for (int _i681 = 0; _i681 < _set679.size; ++_i681)
{
- _elem672 = iprot.readI64();
- struct.nosuch.add(_elem672);
+ _elem680 = iprot.readI64();
+ struct.nosuch.add(_elem680);
}
}
struct.setNosuchIsSet(true);