You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by mi...@apache.org on 2017/09/19 21:31:51 UTC
[08/12] hive git commit: HIVE-17466: Metastore API to list unique
partition-key-value combinations. (Thiruvel Thirumoolan,
reviewed by Mithun Radhakrishnan)
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
index e73333a..c5bd146 100644
--- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
+++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
@@ -302,6 +302,12 @@ class RequestPartsSpec;
class DropPartitionsRequest;
+class PartitionValuesRequest;
+
+class PartitionValuesRow;
+
+class PartitionValuesResponse;
+
class ResourceUri;
class Function;
@@ -4640,6 +4646,181 @@ inline std::ostream& operator<<(std::ostream& out, const DropPartitionsRequest&
return out;
}
+typedef struct _PartitionValuesRequest__isset {
+ _PartitionValuesRequest__isset() : applyDistinct(true), filter(false), partitionOrder(false), ascending(true), maxParts(true) {}
+ bool applyDistinct :1;
+ bool filter :1;
+ bool partitionOrder :1;
+ bool ascending :1;
+ bool maxParts :1;
+} _PartitionValuesRequest__isset;
+
+class PartitionValuesRequest {
+ public:
+
+ PartitionValuesRequest(const PartitionValuesRequest&);
+ PartitionValuesRequest& operator=(const PartitionValuesRequest&);
+ PartitionValuesRequest() : dbName(), tblName(), applyDistinct(true), filter(), ascending(true), maxParts(-1LL) {
+ }
+
+ virtual ~PartitionValuesRequest() throw();
+ std::string dbName;
+ std::string tblName;
+ std::vector<FieldSchema> partitionKeys;
+ bool applyDistinct;
+ std::string filter;
+ std::vector<FieldSchema> partitionOrder;
+ bool ascending;
+ int64_t maxParts;
+
+ _PartitionValuesRequest__isset __isset;
+
+ void __set_dbName(const std::string& val);
+
+ void __set_tblName(const std::string& val);
+
+ void __set_partitionKeys(const std::vector<FieldSchema> & val);
+
+ void __set_applyDistinct(const bool val);
+
+ void __set_filter(const std::string& val);
+
+ void __set_partitionOrder(const std::vector<FieldSchema> & val);
+
+ void __set_ascending(const bool val);
+
+ void __set_maxParts(const int64_t val);
+
+ bool operator == (const PartitionValuesRequest & rhs) const
+ {
+ if (!(dbName == rhs.dbName))
+ return false;
+ if (!(tblName == rhs.tblName))
+ return false;
+ if (!(partitionKeys == rhs.partitionKeys))
+ return false;
+ if (__isset.applyDistinct != rhs.__isset.applyDistinct)
+ return false;
+ else if (__isset.applyDistinct && !(applyDistinct == rhs.applyDistinct))
+ return false;
+ if (__isset.filter != rhs.__isset.filter)
+ return false;
+ else if (__isset.filter && !(filter == rhs.filter))
+ return false;
+ if (__isset.partitionOrder != rhs.__isset.partitionOrder)
+ return false;
+ else if (__isset.partitionOrder && !(partitionOrder == rhs.partitionOrder))
+ return false;
+ if (__isset.ascending != rhs.__isset.ascending)
+ return false;
+ else if (__isset.ascending && !(ascending == rhs.ascending))
+ return false;
+ if (__isset.maxParts != rhs.__isset.maxParts)
+ return false;
+ else if (__isset.maxParts && !(maxParts == rhs.maxParts))
+ return false;
+ return true;
+ }
+ bool operator != (const PartitionValuesRequest &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const PartitionValuesRequest & ) 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(PartitionValuesRequest &a, PartitionValuesRequest &b);
+
+inline std::ostream& operator<<(std::ostream& out, const PartitionValuesRequest& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
+class PartitionValuesRow {
+ public:
+
+ PartitionValuesRow(const PartitionValuesRow&);
+ PartitionValuesRow& operator=(const PartitionValuesRow&);
+ PartitionValuesRow() {
+ }
+
+ virtual ~PartitionValuesRow() throw();
+ std::vector<std::string> row;
+
+ void __set_row(const std::vector<std::string> & val);
+
+ bool operator == (const PartitionValuesRow & rhs) const
+ {
+ if (!(row == rhs.row))
+ return false;
+ return true;
+ }
+ bool operator != (const PartitionValuesRow &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const PartitionValuesRow & ) 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(PartitionValuesRow &a, PartitionValuesRow &b);
+
+inline std::ostream& operator<<(std::ostream& out, const PartitionValuesRow& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
+class PartitionValuesResponse {
+ public:
+
+ PartitionValuesResponse(const PartitionValuesResponse&);
+ PartitionValuesResponse& operator=(const PartitionValuesResponse&);
+ PartitionValuesResponse() {
+ }
+
+ virtual ~PartitionValuesResponse() throw();
+ std::vector<PartitionValuesRow> partitionValues;
+
+ void __set_partitionValues(const std::vector<PartitionValuesRow> & val);
+
+ bool operator == (const PartitionValuesResponse & rhs) const
+ {
+ if (!(partitionValues == rhs.partitionValues))
+ return false;
+ return true;
+ }
+ bool operator != (const PartitionValuesResponse &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const PartitionValuesResponse & ) 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(PartitionValuesResponse &a, PartitionValuesResponse &b);
+
+inline std::ostream& operator<<(std::ostream& out, const PartitionValuesResponse& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
typedef struct _ResourceUri__isset {
_ResourceUri__isset() : resourceType(false), uri(false) {}
bool resourceType :1;
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
index d89eb97..eee1e64 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
@@ -351,13 +351,13 @@ public class AbortTxnsRequest implements org.apache.thrift.TBase<AbortTxnsReques
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list484 = iprot.readListBegin();
- struct.txn_ids = new ArrayList<Long>(_list484.size);
- long _elem485;
- for (int _i486 = 0; _i486 < _list484.size; ++_i486)
+ org.apache.thrift.protocol.TList _list516 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list516.size);
+ long _elem517;
+ for (int _i518 = 0; _i518 < _list516.size; ++_i518)
{
- _elem485 = iprot.readI64();
- struct.txn_ids.add(_elem485);
+ _elem517 = iprot.readI64();
+ struct.txn_ids.add(_elem517);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class AbortTxnsRequest implements org.apache.thrift.TBase<AbortTxnsReques
oprot.writeFieldBegin(TXN_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txn_ids.size()));
- for (long _iter487 : struct.txn_ids)
+ for (long _iter519 : struct.txn_ids)
{
- oprot.writeI64(_iter487);
+ oprot.writeI64(_iter519);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class AbortTxnsRequest implements org.apache.thrift.TBase<AbortTxnsReques
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txn_ids.size());
- for (long _iter488 : struct.txn_ids)
+ for (long _iter520 : struct.txn_ids)
{
- oprot.writeI64(_iter488);
+ oprot.writeI64(_iter520);
}
}
}
@@ -421,13 +421,13 @@ public class AbortTxnsRequest implements org.apache.thrift.TBase<AbortTxnsReques
public void read(org.apache.thrift.protocol.TProtocol prot, AbortTxnsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list489 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txn_ids = new ArrayList<Long>(_list489.size);
- long _elem490;
- for (int _i491 = 0; _i491 < _list489.size; ++_i491)
+ org.apache.thrift.protocol.TList _list521 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list521.size);
+ long _elem522;
+ for (int _i523 = 0; _i523 < _list521.size; ++_i523)
{
- _elem490 = iprot.readI64();
- struct.txn_ids.add(_elem490);
+ _elem522 = iprot.readI64();
+ struct.txn_ids.add(_elem522);
}
}
struct.setTxn_idsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
index ba06a56..054cf1b 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
@@ -727,13 +727,13 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP
case 4: // PARTITIONNAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list542 = iprot.readListBegin();
- struct.partitionnames = new ArrayList<String>(_list542.size);
- String _elem543;
- for (int _i544 = 0; _i544 < _list542.size; ++_i544)
+ org.apache.thrift.protocol.TList _list574 = iprot.readListBegin();
+ struct.partitionnames = new ArrayList<String>(_list574.size);
+ String _elem575;
+ for (int _i576 = 0; _i576 < _list574.size; ++_i576)
{
- _elem543 = iprot.readString();
- struct.partitionnames.add(_elem543);
+ _elem575 = iprot.readString();
+ struct.partitionnames.add(_elem575);
}
iprot.readListEnd();
}
@@ -780,9 +780,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP
oprot.writeFieldBegin(PARTITIONNAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionnames.size()));
- for (String _iter545 : struct.partitionnames)
+ for (String _iter577 : struct.partitionnames)
{
- oprot.writeString(_iter545);
+ oprot.writeString(_iter577);
}
oprot.writeListEnd();
}
@@ -817,9 +817,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP
oprot.writeString(struct.tablename);
{
oprot.writeI32(struct.partitionnames.size());
- for (String _iter546 : struct.partitionnames)
+ for (String _iter578 : struct.partitionnames)
{
- oprot.writeString(_iter546);
+ oprot.writeString(_iter578);
}
}
BitSet optionals = new BitSet();
@@ -842,13 +842,13 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP
struct.tablename = iprot.readString();
struct.setTablenameIsSet(true);
{
- org.apache.thrift.protocol.TList _list547 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionnames = new ArrayList<String>(_list547.size);
- String _elem548;
- for (int _i549 = 0; _i549 < _list547.size; ++_i549)
+ org.apache.thrift.protocol.TList _list579 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionnames = new ArrayList<String>(_list579.size);
+ String _elem580;
+ for (int _i581 = 0; _i581 < _list579.size; ++_i581)
{
- _elem548 = iprot.readString();
- struct.partitionnames.add(_elem548);
+ _elem580 = iprot.readString();
+ struct.partitionnames.add(_elem580);
}
}
struct.setPartitionnamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
index 0da09bf..0b6574d 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
@@ -351,13 +351,13 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list634.size);
- long _elem635;
- for (int _i636 = 0; _i636 < _list634.size; ++_i636)
+ org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list666.size);
+ long _elem667;
+ for (int _i668 = 0; _i668 < _list666.size; ++_i668)
{
- _elem635 = iprot.readI64();
- struct.fileIds.add(_elem635);
+ _elem667 = iprot.readI64();
+ struct.fileIds.add(_elem667);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi
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 _iter637 : struct.fileIds)
+ for (long _iter669 : struct.fileIds)
{
- oprot.writeI64(_iter637);
+ oprot.writeI64(_iter669);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter638 : struct.fileIds)
+ for (long _iter670 : struct.fileIds)
{
- oprot.writeI64(_iter638);
+ oprot.writeI64(_iter670);
}
}
}
@@ -421,13 +421,13 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi
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 _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list639.size);
- long _elem640;
- for (int _i641 = 0; _i641 < _list639.size; ++_i641)
+ org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list671.size);
+ long _elem672;
+ for (int _i673 = 0; _i673 < _list671.size; ++_i673)
{
- _elem640 = iprot.readI64();
- struct.fileIds.add(_elem640);
+ _elem672 = iprot.readI64();
+ struct.fileIds.add(_elem672);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
index 81534fe..19e671b 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
@@ -354,13 +354,13 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil
case 1: // VALUES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
- struct.values = new ArrayList<ClientCapability>(_list650.size);
- ClientCapability _elem651;
- for (int _i652 = 0; _i652 < _list650.size; ++_i652)
+ org.apache.thrift.protocol.TList _list682 = iprot.readListBegin();
+ struct.values = new ArrayList<ClientCapability>(_list682.size);
+ ClientCapability _elem683;
+ for (int _i684 = 0; _i684 < _list682.size; ++_i684)
{
- _elem651 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem651);
+ _elem683 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem683);
}
iprot.readListEnd();
}
@@ -386,9 +386,9 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil
oprot.writeFieldBegin(VALUES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.values.size()));
- for (ClientCapability _iter653 : struct.values)
+ for (ClientCapability _iter685 : struct.values)
{
- oprot.writeI32(_iter653.getValue());
+ oprot.writeI32(_iter685.getValue());
}
oprot.writeListEnd();
}
@@ -413,9 +413,9 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.values.size());
- for (ClientCapability _iter654 : struct.values)
+ for (ClientCapability _iter686 : struct.values)
{
- oprot.writeI32(_iter654.getValue());
+ oprot.writeI32(_iter686.getValue());
}
}
}
@@ -424,13 +424,13 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil
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 _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.values = new ArrayList<ClientCapability>(_list655.size);
- ClientCapability _elem656;
- for (int _i657 = 0; _i657 < _list655.size; ++_i657)
+ org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.values = new ArrayList<ClientCapability>(_list687.size);
+ ClientCapability _elem688;
+ for (int _i689 = 0; _i689 < _list687.size; ++_i689)
{
- _elem656 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem656);
+ _elem688 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem688);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
index d3fc92a..3acb203 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
@@ -814,15 +814,15 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
case 6: // PROPERTIES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map524 = iprot.readMapBegin();
- struct.properties = new HashMap<String,String>(2*_map524.size);
- String _key525;
- String _val526;
- for (int _i527 = 0; _i527 < _map524.size; ++_i527)
+ org.apache.thrift.protocol.TMap _map556 = iprot.readMapBegin();
+ struct.properties = new HashMap<String,String>(2*_map556.size);
+ String _key557;
+ String _val558;
+ for (int _i559 = 0; _i559 < _map556.size; ++_i559)
{
- _key525 = iprot.readString();
- _val526 = iprot.readString();
- struct.properties.put(_key525, _val526);
+ _key557 = iprot.readString();
+ _val558 = iprot.readString();
+ struct.properties.put(_key557, _val558);
}
iprot.readMapEnd();
}
@@ -878,10 +878,10 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
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> _iter528 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter560 : struct.properties.entrySet())
{
- oprot.writeString(_iter528.getKey());
- oprot.writeString(_iter528.getValue());
+ oprot.writeString(_iter560.getKey());
+ oprot.writeString(_iter560.getValue());
}
oprot.writeMapEnd();
}
@@ -928,10 +928,10 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
if (struct.isSetProperties()) {
{
oprot.writeI32(struct.properties.size());
- for (Map.Entry<String, String> _iter529 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter561 : struct.properties.entrySet())
{
- oprot.writeString(_iter529.getKey());
- oprot.writeString(_iter529.getValue());
+ oprot.writeString(_iter561.getKey());
+ oprot.writeString(_iter561.getValue());
}
}
}
@@ -957,15 +957,15 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map530 = 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*_map530.size);
- String _key531;
- String _val532;
- for (int _i533 = 0; _i533 < _map530.size; ++_i533)
+ org.apache.thrift.protocol.TMap _map562 = 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*_map562.size);
+ String _key563;
+ String _val564;
+ for (int _i565 = 0; _i565 < _map562.size; ++_i565)
{
- _key531 = iprot.readString();
- _val532 = iprot.readString();
- struct.properties.put(_key531, _val532);
+ _key563 = iprot.readString();
+ _val564 = iprot.readString();
+ struct.properties.put(_key563, _val564);
}
}
struct.setPropertiesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
index 7bb10b3..cc336c5 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
@@ -713,13 +713,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
case 5: // PARTITION_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list574 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list574.size);
- String _elem575;
- for (int _i576 = 0; _i576 < _list574.size; ++_i576)
+ org.apache.thrift.protocol.TList _list606 = iprot.readListBegin();
+ struct.partitionVals = new ArrayList<String>(_list606.size);
+ String _elem607;
+ for (int _i608 = 0; _i608 < _list606.size; ++_i608)
{
- _elem575 = iprot.readString();
- struct.partitionVals.add(_elem575);
+ _elem607 = iprot.readString();
+ struct.partitionVals.add(_elem607);
}
iprot.readListEnd();
}
@@ -768,9 +768,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
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 _iter577 : struct.partitionVals)
+ for (String _iter609 : struct.partitionVals)
{
- oprot.writeString(_iter577);
+ oprot.writeString(_iter609);
}
oprot.writeListEnd();
}
@@ -816,9 +816,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter578 : struct.partitionVals)
+ for (String _iter610 : struct.partitionVals)
{
- oprot.writeString(_iter578);
+ oprot.writeString(_iter610);
}
}
}
@@ -843,13 +843,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list579 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list579.size);
- String _elem580;
- for (int _i581 = 0; _i581 < _list579.size; ++_i581)
+ org.apache.thrift.protocol.TList _list611 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionVals = new ArrayList<String>(_list611.size);
+ String _elem612;
+ for (int _i613 = 0; _i613 < _list611.size; ++_i613)
{
- _elem580 = iprot.readString();
- struct.partitionVals.add(_elem580);
+ _elem612 = iprot.readString();
+ struct.partitionVals.add(_elem612);
}
}
struct.setPartitionValsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
index 56a4d30..ad12ab1 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
@@ -997,14 +997,14 @@ public class Function implements org.apache.thrift.TBase<Function, Function._Fie
case 8: // RESOURCE_URIS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list452 = iprot.readListBegin();
- struct.resourceUris = new ArrayList<ResourceUri>(_list452.size);
- ResourceUri _elem453;
- for (int _i454 = 0; _i454 < _list452.size; ++_i454)
+ org.apache.thrift.protocol.TList _list484 = iprot.readListBegin();
+ struct.resourceUris = new ArrayList<ResourceUri>(_list484.size);
+ ResourceUri _elem485;
+ for (int _i486 = 0; _i486 < _list484.size; ++_i486)
{
- _elem453 = new ResourceUri();
- _elem453.read(iprot);
- struct.resourceUris.add(_elem453);
+ _elem485 = new ResourceUri();
+ _elem485.read(iprot);
+ struct.resourceUris.add(_elem485);
}
iprot.readListEnd();
}
@@ -1063,9 +1063,9 @@ public class Function implements org.apache.thrift.TBase<Function, Function._Fie
oprot.writeFieldBegin(RESOURCE_URIS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.resourceUris.size()));
- for (ResourceUri _iter455 : struct.resourceUris)
+ for (ResourceUri _iter487 : struct.resourceUris)
{
- _iter455.write(oprot);
+ _iter487.write(oprot);
}
oprot.writeListEnd();
}
@@ -1138,9 +1138,9 @@ public class Function implements org.apache.thrift.TBase<Function, Function._Fie
if (struct.isSetResourceUris()) {
{
oprot.writeI32(struct.resourceUris.size());
- for (ResourceUri _iter456 : struct.resourceUris)
+ for (ResourceUri _iter488 : struct.resourceUris)
{
- _iter456.write(oprot);
+ _iter488.write(oprot);
}
}
}
@@ -1180,14 +1180,14 @@ public class Function implements org.apache.thrift.TBase<Function, Function._Fie
}
if (incoming.get(7)) {
{
- org.apache.thrift.protocol.TList _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.resourceUris = new ArrayList<ResourceUri>(_list457.size);
- ResourceUri _elem458;
- for (int _i459 = 0; _i459 < _list457.size; ++_i459)
+ org.apache.thrift.protocol.TList _list489 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.resourceUris = new ArrayList<ResourceUri>(_list489.size);
+ ResourceUri _elem490;
+ for (int _i491 = 0; _i491 < _list489.size; ++_i491)
{
- _elem458 = new ResourceUri();
- _elem458.read(iprot);
- struct.resourceUris.add(_elem458);
+ _elem490 = new ResourceUri();
+ _elem490.read(iprot);
+ struct.resourceUris.add(_elem490);
}
}
struct.setResourceUrisIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
index 49a1be2..bb11fe3 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java
@@ -346,14 +346,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
case 1: // FUNCTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
- struct.functions = new ArrayList<Function>(_list642.size);
- Function _elem643;
- for (int _i644 = 0; _i644 < _list642.size; ++_i644)
+ org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
+ struct.functions = new ArrayList<Function>(_list674.size);
+ Function _elem675;
+ for (int _i676 = 0; _i676 < _list674.size; ++_i676)
{
- _elem643 = new Function();
- _elem643.read(iprot);
- struct.functions.add(_elem643);
+ _elem675 = new Function();
+ _elem675.read(iprot);
+ struct.functions.add(_elem675);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
oprot.writeFieldBegin(FUNCTIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.functions.size()));
- for (Function _iter645 : struct.functions)
+ for (Function _iter677 : struct.functions)
{
- _iter645.write(oprot);
+ _iter677.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
if (struct.isSetFunctions()) {
{
oprot.writeI32(struct.functions.size());
- for (Function _iter646 : struct.functions)
+ for (Function _iter678 : struct.functions)
{
- _iter646.write(oprot);
+ _iter678.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.functions = new ArrayList<Function>(_list647.size);
- Function _elem648;
- for (int _i649 = 0; _i649 < _list647.size; ++_i649)
+ org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.functions = new ArrayList<Function>(_list679.size);
+ Function _elem680;
+ for (int _i681 = 0; _i681 < _list679.size; ++_i681)
{
- _elem648 = new Function();
- _elem648.read(iprot);
- struct.functions.add(_elem648);
+ _elem680 = new Function();
+ _elem680.read(iprot);
+ struct.functions.add(_elem680);
}
}
struct.setFunctionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
index 20b82cf..ef758cd 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java
@@ -619,13 +619,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list592 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list592.size);
- long _elem593;
- for (int _i594 = 0; _i594 < _list592.size; ++_i594)
+ org.apache.thrift.protocol.TList _list624 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list624.size);
+ long _elem625;
+ for (int _i626 = 0; _i626 < _list624.size; ++_i626)
{
- _elem593 = iprot.readI64();
- struct.fileIds.add(_elem593);
+ _elem625 = iprot.readI64();
+ struct.fileIds.add(_elem625);
}
iprot.readListEnd();
}
@@ -675,9 +675,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
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 _iter595 : struct.fileIds)
+ for (long _iter627 : struct.fileIds)
{
- oprot.writeI64(_iter595);
+ oprot.writeI64(_iter627);
}
oprot.writeListEnd();
}
@@ -719,9 +719,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter596 : struct.fileIds)
+ for (long _iter628 : struct.fileIds)
{
- oprot.writeI64(_iter596);
+ oprot.writeI64(_iter628);
}
}
oprot.writeBinary(struct.expr);
@@ -745,13 +745,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get
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 _list597 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list597.size);
- long _elem598;
- for (int _i599 = 0; _i599 < _list597.size; ++_i599)
+ org.apache.thrift.protocol.TList _list629 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list629.size);
+ long _elem630;
+ for (int _i631 = 0; _i631 < _list629.size; ++_i631)
{
- _elem598 = iprot.readI64();
- struct.fileIds.add(_elem598);
+ _elem630 = iprot.readI64();
+ struct.fileIds.add(_elem630);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
index 9975dfc..ee94380 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java
@@ -444,16 +444,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map582 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map582.size);
- long _key583;
- MetadataPpdResult _val584;
- for (int _i585 = 0; _i585 < _map582.size; ++_i585)
+ org.apache.thrift.protocol.TMap _map614 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map614.size);
+ long _key615;
+ MetadataPpdResult _val616;
+ for (int _i617 = 0; _i617 < _map614.size; ++_i617)
{
- _key583 = iprot.readI64();
- _val584 = new MetadataPpdResult();
- _val584.read(iprot);
- struct.metadata.put(_key583, _val584);
+ _key615 = iprot.readI64();
+ _val616 = new MetadataPpdResult();
+ _val616.read(iprot);
+ struct.metadata.put(_key615, _val616);
}
iprot.readMapEnd();
}
@@ -487,10 +487,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
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> _iter586 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter618 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter586.getKey());
- _iter586.getValue().write(oprot);
+ oprot.writeI64(_iter618.getKey());
+ _iter618.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -518,10 +518,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, MetadataPpdResult> _iter587 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter619 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter587.getKey());
- _iter587.getValue().write(oprot);
+ oprot.writeI64(_iter619.getKey());
+ _iter619.getValue().write(oprot);
}
}
oprot.writeBool(struct.isSupported);
@@ -531,16 +531,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF
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 _map588 = 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*_map588.size);
- long _key589;
- MetadataPpdResult _val590;
- for (int _i591 = 0; _i591 < _map588.size; ++_i591)
+ org.apache.thrift.protocol.TMap _map620 = 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*_map620.size);
+ long _key621;
+ MetadataPpdResult _val622;
+ for (int _i623 = 0; _i623 < _map620.size; ++_i623)
{
- _key589 = iprot.readI64();
- _val590 = new MetadataPpdResult();
- _val590.read(iprot);
- struct.metadata.put(_key589, _val590);
+ _key621 = iprot.readI64();
+ _val622 = new MetadataPpdResult();
+ _val622.read(iprot);
+ struct.metadata.put(_key621, _val622);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
index 7aebede..f8c8258 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java
@@ -351,13 +351,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list610.size);
- long _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list642.size);
+ long _elem643;
+ for (int _i644 = 0; _i644 < _list642.size; ++_i644)
{
- _elem611 = iprot.readI64();
- struct.fileIds.add(_elem611);
+ _elem643 = iprot.readI64();
+ struct.fileIds.add(_elem643);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
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 _iter613 : struct.fileIds)
+ for (long _iter645 : struct.fileIds)
{
- oprot.writeI64(_iter613);
+ oprot.writeI64(_iter645);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter614 : struct.fileIds)
+ for (long _iter646 : struct.fileIds)
{
- oprot.writeI64(_iter614);
+ oprot.writeI64(_iter646);
}
}
}
@@ -421,13 +421,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe
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 _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list615.size);
- long _elem616;
- for (int _i617 = 0; _i617 < _list615.size; ++_i617)
+ org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list647.size);
+ long _elem648;
+ for (int _i649 = 0; _i649 < _list647.size; ++_i649)
{
- _elem616 = iprot.readI64();
- struct.fileIds.add(_elem616);
+ _elem648 = iprot.readI64();
+ struct.fileIds.add(_elem648);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
index fe83a6e..73888e9 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java
@@ -433,15 +433,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
case 1: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map600 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map600.size);
- long _key601;
- ByteBuffer _val602;
- for (int _i603 = 0; _i603 < _map600.size; ++_i603)
+ org.apache.thrift.protocol.TMap _map632 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map632.size);
+ long _key633;
+ ByteBuffer _val634;
+ for (int _i635 = 0; _i635 < _map632.size; ++_i635)
{
- _key601 = iprot.readI64();
- _val602 = iprot.readBinary();
- struct.metadata.put(_key601, _val602);
+ _key633 = iprot.readI64();
+ _val634 = iprot.readBinary();
+ struct.metadata.put(_key633, _val634);
}
iprot.readMapEnd();
}
@@ -475,10 +475,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
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> _iter604 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter636 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter604.getKey());
- oprot.writeBinary(_iter604.getValue());
+ oprot.writeI64(_iter636.getKey());
+ oprot.writeBinary(_iter636.getValue());
}
oprot.writeMapEnd();
}
@@ -506,10 +506,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.metadata.size());
- for (Map.Entry<Long, ByteBuffer> _iter605 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter637 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter605.getKey());
- oprot.writeBinary(_iter605.getValue());
+ oprot.writeI64(_iter637.getKey());
+ oprot.writeBinary(_iter637.getValue());
}
}
oprot.writeBool(struct.isSupported);
@@ -519,15 +519,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet
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 _map606 = 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*_map606.size);
- long _key607;
- ByteBuffer _val608;
- for (int _i609 = 0; _i609 < _map606.size; ++_i609)
+ org.apache.thrift.protocol.TMap _map638 = 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*_map638.size);
+ long _key639;
+ ByteBuffer _val640;
+ for (int _i641 = 0; _i641 < _map638.size; ++_i641)
{
- _key607 = iprot.readI64();
- _val608 = iprot.readBinary();
- struct.metadata.put(_key607, _val608);
+ _key639 = iprot.readI64();
+ _val640 = iprot.readBinary();
+ struct.metadata.put(_key639, _val640);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
index e68793b..18a8e62 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
@@ -447,14 +447,14 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT
case 2: // OPEN_TXNS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list460 = iprot.readListBegin();
- struct.open_txns = new ArrayList<TxnInfo>(_list460.size);
- TxnInfo _elem461;
- for (int _i462 = 0; _i462 < _list460.size; ++_i462)
+ org.apache.thrift.protocol.TList _list492 = iprot.readListBegin();
+ struct.open_txns = new ArrayList<TxnInfo>(_list492.size);
+ TxnInfo _elem493;
+ for (int _i494 = 0; _i494 < _list492.size; ++_i494)
{
- _elem461 = new TxnInfo();
- _elem461.read(iprot);
- struct.open_txns.add(_elem461);
+ _elem493 = new TxnInfo();
+ _elem493.read(iprot);
+ struct.open_txns.add(_elem493);
}
iprot.readListEnd();
}
@@ -483,9 +483,9 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT
oprot.writeFieldBegin(OPEN_TXNS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.open_txns.size()));
- for (TxnInfo _iter463 : struct.open_txns)
+ for (TxnInfo _iter495 : struct.open_txns)
{
- _iter463.write(oprot);
+ _iter495.write(oprot);
}
oprot.writeListEnd();
}
@@ -511,9 +511,9 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT
oprot.writeI64(struct.txn_high_water_mark);
{
oprot.writeI32(struct.open_txns.size());
- for (TxnInfo _iter464 : struct.open_txns)
+ for (TxnInfo _iter496 : struct.open_txns)
{
- _iter464.write(oprot);
+ _iter496.write(oprot);
}
}
}
@@ -524,14 +524,14 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT
struct.txn_high_water_mark = iprot.readI64();
struct.setTxn_high_water_markIsSet(true);
{
- org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.open_txns = new ArrayList<TxnInfo>(_list465.size);
- TxnInfo _elem466;
- for (int _i467 = 0; _i467 < _list465.size; ++_i467)
+ org.apache.thrift.protocol.TList _list497 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.open_txns = new ArrayList<TxnInfo>(_list497.size);
+ TxnInfo _elem498;
+ for (int _i499 = 0; _i499 < _list497.size; ++_i499)
{
- _elem466 = new TxnInfo();
- _elem466.read(iprot);
- struct.open_txns.add(_elem466);
+ _elem498 = new TxnInfo();
+ _elem498.read(iprot);
+ struct.open_txns.add(_elem498);
}
}
struct.setOpen_txnsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
index 8230d38..572e2cd 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
@@ -521,13 +521,13 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR
case 2: // OPEN_TXNS
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set468 = iprot.readSetBegin();
- struct.open_txns = new HashSet<Long>(2*_set468.size);
- long _elem469;
- for (int _i470 = 0; _i470 < _set468.size; ++_i470)
+ org.apache.thrift.protocol.TSet _set500 = iprot.readSetBegin();
+ struct.open_txns = new HashSet<Long>(2*_set500.size);
+ long _elem501;
+ for (int _i502 = 0; _i502 < _set500.size; ++_i502)
{
- _elem469 = iprot.readI64();
- struct.open_txns.add(_elem469);
+ _elem501 = iprot.readI64();
+ struct.open_txns.add(_elem501);
}
iprot.readSetEnd();
}
@@ -564,9 +564,9 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR
oprot.writeFieldBegin(OPEN_TXNS_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.open_txns.size()));
- for (long _iter471 : struct.open_txns)
+ for (long _iter503 : struct.open_txns)
{
- oprot.writeI64(_iter471);
+ oprot.writeI64(_iter503);
}
oprot.writeSetEnd();
}
@@ -597,9 +597,9 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR
oprot.writeI64(struct.txn_high_water_mark);
{
oprot.writeI32(struct.open_txns.size());
- for (long _iter472 : struct.open_txns)
+ for (long _iter504 : struct.open_txns)
{
- oprot.writeI64(_iter472);
+ oprot.writeI64(_iter504);
}
}
BitSet optionals = new BitSet();
@@ -618,13 +618,13 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR
struct.txn_high_water_mark = iprot.readI64();
struct.setTxn_high_water_markIsSet(true);
{
- org.apache.thrift.protocol.TSet _set473 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.open_txns = new HashSet<Long>(2*_set473.size);
- long _elem474;
- for (int _i475 = 0; _i475 < _set473.size; ++_i475)
+ org.apache.thrift.protocol.TSet _set505 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.open_txns = new HashSet<Long>(2*_set505.size);
+ long _elem506;
+ for (int _i507 = 0; _i507 < _set505.size; ++_i507)
{
- _elem474 = iprot.readI64();
- struct.open_txns.add(_elem474);
+ _elem506 = iprot.readI64();
+ struct.open_txns.add(_elem506);
}
}
struct.setOpen_txnsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
index 225fda9..5195427 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
@@ -525,13 +525,13 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
- struct.tblNames = new ArrayList<String>(_list658.size);
- String _elem659;
- for (int _i660 = 0; _i660 < _list658.size; ++_i660)
+ org.apache.thrift.protocol.TList _list690 = iprot.readListBegin();
+ struct.tblNames = new ArrayList<String>(_list690.size);
+ String _elem691;
+ for (int _i692 = 0; _i692 < _list690.size; ++_i692)
{
- _elem659 = iprot.readString();
- struct.tblNames.add(_elem659);
+ _elem691 = iprot.readString();
+ struct.tblNames.add(_elem691);
}
iprot.readListEnd();
}
@@ -572,9 +572,9 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
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 _iter661 : struct.tblNames)
+ for (String _iter693 : struct.tblNames)
{
- oprot.writeString(_iter661);
+ oprot.writeString(_iter693);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
if (struct.isSetTblNames()) {
{
oprot.writeI32(struct.tblNames.size());
- for (String _iter662 : struct.tblNames)
+ for (String _iter694 : struct.tblNames)
{
- oprot.writeString(_iter662);
+ oprot.writeString(_iter694);
}
}
}
@@ -636,13 +636,13 @@ public class GetTablesRequest implements org.apache.thrift.TBase<GetTablesReques
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tblNames = new ArrayList<String>(_list663.size);
- String _elem664;
- for (int _i665 = 0; _i665 < _list663.size; ++_i665)
+ org.apache.thrift.protocol.TList _list695 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tblNames = new ArrayList<String>(_list695.size);
+ String _elem696;
+ for (int _i697 = 0; _i697 < _list695.size; ++_i697)
{
- _elem664 = iprot.readString();
- struct.tblNames.add(_elem664);
+ _elem696 = iprot.readString();
+ struct.tblNames.add(_elem696);
}
}
struct.setTblNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
index 91cb198..1ade2f5 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
@@ -354,14 +354,14 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
case 1: // TABLES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
- struct.tables = new ArrayList<Table>(_list666.size);
- Table _elem667;
- for (int _i668 = 0; _i668 < _list666.size; ++_i668)
+ org.apache.thrift.protocol.TList _list698 = iprot.readListBegin();
+ struct.tables = new ArrayList<Table>(_list698.size);
+ Table _elem699;
+ for (int _i700 = 0; _i700 < _list698.size; ++_i700)
{
- _elem667 = new Table();
- _elem667.read(iprot);
- struct.tables.add(_elem667);
+ _elem699 = new Table();
+ _elem699.read(iprot);
+ struct.tables.add(_elem699);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
oprot.writeFieldBegin(TABLES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tables.size()));
- for (Table _iter669 : struct.tables)
+ for (Table _iter701 : struct.tables)
{
- _iter669.write(oprot);
+ _iter701.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tables.size());
- for (Table _iter670 : struct.tables)
+ for (Table _iter702 : struct.tables)
{
- _iter670.write(oprot);
+ _iter702.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult,
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 _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tables = new ArrayList<Table>(_list671.size);
- Table _elem672;
- for (int _i673 = 0; _i673 < _list671.size; ++_i673)
+ org.apache.thrift.protocol.TList _list703 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tables = new ArrayList<Table>(_list703.size);
+ Table _elem704;
+ for (int _i705 = 0; _i705 < _list703.size; ++_i705)
{
- _elem672 = new Table();
- _elem672.read(iprot);
- struct.tables.add(_elem672);
+ _elem704 = new Table();
+ _elem704.read(iprot);
+ struct.tables.add(_elem704);
}
}
struct.setTablesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
index 164ff51..a33210d 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
@@ -453,13 +453,13 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb
case 1: // ABORTED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set508 = iprot.readSetBegin();
- struct.aborted = new HashSet<Long>(2*_set508.size);
- long _elem509;
- for (int _i510 = 0; _i510 < _set508.size; ++_i510)
+ org.apache.thrift.protocol.TSet _set540 = iprot.readSetBegin();
+ struct.aborted = new HashSet<Long>(2*_set540.size);
+ long _elem541;
+ for (int _i542 = 0; _i542 < _set540.size; ++_i542)
{
- _elem509 = iprot.readI64();
- struct.aborted.add(_elem509);
+ _elem541 = iprot.readI64();
+ struct.aborted.add(_elem541);
}
iprot.readSetEnd();
}
@@ -471,13 +471,13 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb
case 2: // NOSUCH
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set511 = iprot.readSetBegin();
- struct.nosuch = new HashSet<Long>(2*_set511.size);
- long _elem512;
- for (int _i513 = 0; _i513 < _set511.size; ++_i513)
+ org.apache.thrift.protocol.TSet _set543 = iprot.readSetBegin();
+ struct.nosuch = new HashSet<Long>(2*_set543.size);
+ long _elem544;
+ for (int _i545 = 0; _i545 < _set543.size; ++_i545)
{
- _elem512 = iprot.readI64();
- struct.nosuch.add(_elem512);
+ _elem544 = iprot.readI64();
+ struct.nosuch.add(_elem544);
}
iprot.readSetEnd();
}
@@ -503,9 +503,9 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb
oprot.writeFieldBegin(ABORTED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size()));
- for (long _iter514 : struct.aborted)
+ for (long _iter546 : struct.aborted)
{
- oprot.writeI64(_iter514);
+ oprot.writeI64(_iter546);
}
oprot.writeSetEnd();
}
@@ -515,9 +515,9 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb
oprot.writeFieldBegin(NOSUCH_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size()));
- for (long _iter515 : struct.nosuch)
+ for (long _iter547 : struct.nosuch)
{
- oprot.writeI64(_iter515);
+ oprot.writeI64(_iter547);
}
oprot.writeSetEnd();
}
@@ -542,16 +542,16 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.aborted.size());
- for (long _iter516 : struct.aborted)
+ for (long _iter548 : struct.aborted)
{
- oprot.writeI64(_iter516);
+ oprot.writeI64(_iter548);
}
}
{
oprot.writeI32(struct.nosuch.size());
- for (long _iter517 : struct.nosuch)
+ for (long _iter549 : struct.nosuch)
{
- oprot.writeI64(_iter517);
+ oprot.writeI64(_iter549);
}
}
}
@@ -560,24 +560,24 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb
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 _set518 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.aborted = new HashSet<Long>(2*_set518.size);
- long _elem519;
- for (int _i520 = 0; _i520 < _set518.size; ++_i520)
+ org.apache.thrift.protocol.TSet _set550 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.aborted = new HashSet<Long>(2*_set550.size);
+ long _elem551;
+ for (int _i552 = 0; _i552 < _set550.size; ++_i552)
{
- _elem519 = iprot.readI64();
- struct.aborted.add(_elem519);
+ _elem551 = iprot.readI64();
+ struct.aborted.add(_elem551);
}
}
struct.setAbortedIsSet(true);
{
- org.apache.thrift.protocol.TSet _set521 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.nosuch = new HashSet<Long>(2*_set521.size);
- long _elem522;
- for (int _i523 = 0; _i523 < _set521.size; ++_i523)
+ org.apache.thrift.protocol.TSet _set553 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.nosuch = new HashSet<Long>(2*_set553.size);
+ long _elem554;
+ for (int _i555 = 0; _i555 < _set553.size; ++_i555)
{
- _elem522 = iprot.readI64();
- struct.nosuch.add(_elem522);
+ _elem554 = iprot.readI64();
+ struct.nosuch.add(_elem554);
}
}
struct.setNosuchIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index fd1dc06..766d7d3 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -450,13 +450,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
case 1: // FILES_ADDED
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list558 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list558.size);
- String _elem559;
- for (int _i560 = 0; _i560 < _list558.size; ++_i560)
+ org.apache.thrift.protocol.TList _list590 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list590.size);
+ String _elem591;
+ for (int _i592 = 0; _i592 < _list590.size; ++_i592)
{
- _elem559 = iprot.readString();
- struct.filesAdded.add(_elem559);
+ _elem591 = iprot.readString();
+ struct.filesAdded.add(_elem591);
}
iprot.readListEnd();
}
@@ -468,13 +468,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
case 2: // FILES_ADDED_CHECKSUM
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list561 = iprot.readListBegin();
- struct.filesAddedChecksum = new ArrayList<String>(_list561.size);
- String _elem562;
- for (int _i563 = 0; _i563 < _list561.size; ++_i563)
+ org.apache.thrift.protocol.TList _list593 = iprot.readListBegin();
+ struct.filesAddedChecksum = new ArrayList<String>(_list593.size);
+ String _elem594;
+ for (int _i595 = 0; _i595 < _list593.size; ++_i595)
{
- _elem562 = iprot.readString();
- struct.filesAddedChecksum.add(_elem562);
+ _elem594 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem594);
}
iprot.readListEnd();
}
@@ -500,9 +500,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size()));
- for (String _iter564 : struct.filesAdded)
+ for (String _iter596 : struct.filesAdded)
{
- oprot.writeString(_iter564);
+ oprot.writeString(_iter596);
}
oprot.writeListEnd();
}
@@ -513,9 +513,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
oprot.writeFieldBegin(FILES_ADDED_CHECKSUM_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAddedChecksum.size()));
- for (String _iter565 : struct.filesAddedChecksum)
+ for (String _iter597 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter565);
+ oprot.writeString(_iter597);
}
oprot.writeListEnd();
}
@@ -541,9 +541,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter566 : struct.filesAdded)
+ for (String _iter598 : struct.filesAdded)
{
- oprot.writeString(_iter566);
+ oprot.writeString(_iter598);
}
}
BitSet optionals = new BitSet();
@@ -554,9 +554,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
if (struct.isSetFilesAddedChecksum()) {
{
oprot.writeI32(struct.filesAddedChecksum.size());
- for (String _iter567 : struct.filesAddedChecksum)
+ for (String _iter599 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter567);
+ oprot.writeString(_iter599);
}
}
}
@@ -566,26 +566,26 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve
public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list568 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list568.size);
- String _elem569;
- for (int _i570 = 0; _i570 < _list568.size; ++_i570)
+ org.apache.thrift.protocol.TList _list600 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list600.size);
+ String _elem601;
+ for (int _i602 = 0; _i602 < _list600.size; ++_i602)
{
- _elem569 = iprot.readString();
- struct.filesAdded.add(_elem569);
+ _elem601 = iprot.readString();
+ struct.filesAdded.add(_elem601);
}
}
struct.setFilesAddedIsSet(true);
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list571 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAddedChecksum = new ArrayList<String>(_list571.size);
- String _elem572;
- for (int _i573 = 0; _i573 < _list571.size; ++_i573)
+ org.apache.thrift.protocol.TList _list603 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAddedChecksum = new ArrayList<String>(_list603.size);
+ String _elem604;
+ for (int _i605 = 0; _i605 < _list603.size; ++_i605)
{
- _elem572 = iprot.readString();
- struct.filesAddedChecksum.add(_elem572);
+ _elem604 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem604);
}
}
struct.setFilesAddedChecksumIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
index a1a1cac..833adbb 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
@@ -689,14 +689,14 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq
case 1: // COMPONENT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list492 = iprot.readListBegin();
- struct.component = new ArrayList<LockComponent>(_list492.size);
- LockComponent _elem493;
- for (int _i494 = 0; _i494 < _list492.size; ++_i494)
+ org.apache.thrift.protocol.TList _list524 = iprot.readListBegin();
+ struct.component = new ArrayList<LockComponent>(_list524.size);
+ LockComponent _elem525;
+ for (int _i526 = 0; _i526 < _list524.size; ++_i526)
{
- _elem493 = new LockComponent();
- _elem493.read(iprot);
- struct.component.add(_elem493);
+ _elem525 = new LockComponent();
+ _elem525.read(iprot);
+ struct.component.add(_elem525);
}
iprot.readListEnd();
}
@@ -754,9 +754,9 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq
oprot.writeFieldBegin(COMPONENT_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size()));
- for (LockComponent _iter495 : struct.component)
+ for (LockComponent _iter527 : struct.component)
{
- _iter495.write(oprot);
+ _iter527.write(oprot);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.component.size());
- for (LockComponent _iter496 : struct.component)
+ for (LockComponent _iter528 : struct.component)
{
- _iter496.write(oprot);
+ _iter528.write(oprot);
}
}
oprot.writeString(struct.user);
@@ -830,14 +830,14 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq
public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list497 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component = new ArrayList<LockComponent>(_list497.size);
- LockComponent _elem498;
- for (int _i499 = 0; _i499 < _list497.size; ++_i499)
+ org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component = new ArrayList<LockComponent>(_list529.size);
+ LockComponent _elem530;
+ for (int _i531 = 0; _i531 < _list529.size; ++_i531)
{
- _elem498 = new LockComponent();
- _elem498.read(iprot);
- struct.component.add(_elem498);
+ _elem530 = new LockComponent();
+ _elem530.read(iprot);
+ struct.component.add(_elem530);
}
}
struct.setComponentIsSet(true);