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/04/02 04:32:58 UTC
[09/12] hive git commit: HIVE-18781: Create/Replicate Open,
Commit (without writes) and Abort Txn events (Mahesh Kumar Behera,
reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 d4ee95b..086cfe9 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
@@ -6697,8 +6697,10 @@ inline std::ostream& operator<<(std::ostream& out, const GetOpenTxnsResponse& ob
}
typedef struct _OpenTxnRequest__isset {
- _OpenTxnRequest__isset() : agentInfo(true) {}
+ _OpenTxnRequest__isset() : agentInfo(true), replPolicy(false), replSrcTxnIds(false) {}
bool agentInfo :1;
+ bool replPolicy :1;
+ bool replSrcTxnIds :1;
} _OpenTxnRequest__isset;
class OpenTxnRequest {
@@ -6706,7 +6708,7 @@ class OpenTxnRequest {
OpenTxnRequest(const OpenTxnRequest&);
OpenTxnRequest& operator=(const OpenTxnRequest&);
- OpenTxnRequest() : num_txns(0), user(), hostname(), agentInfo("Unknown") {
+ OpenTxnRequest() : num_txns(0), user(), hostname(), agentInfo("Unknown"), replPolicy() {
}
virtual ~OpenTxnRequest() throw();
@@ -6714,6 +6716,8 @@ class OpenTxnRequest {
std::string user;
std::string hostname;
std::string agentInfo;
+ std::string replPolicy;
+ std::vector<int64_t> replSrcTxnIds;
_OpenTxnRequest__isset __isset;
@@ -6725,6 +6729,10 @@ class OpenTxnRequest {
void __set_agentInfo(const std::string& val);
+ void __set_replPolicy(const std::string& val);
+
+ void __set_replSrcTxnIds(const std::vector<int64_t> & val);
+
bool operator == (const OpenTxnRequest & rhs) const
{
if (!(num_txns == rhs.num_txns))
@@ -6737,6 +6745,14 @@ class OpenTxnRequest {
return false;
else if (__isset.agentInfo && !(agentInfo == rhs.agentInfo))
return false;
+ if (__isset.replPolicy != rhs.__isset.replPolicy)
+ return false;
+ else if (__isset.replPolicy && !(replPolicy == rhs.replPolicy))
+ return false;
+ if (__isset.replSrcTxnIds != rhs.__isset.replSrcTxnIds)
+ return false;
+ else if (__isset.replSrcTxnIds && !(replSrcTxnIds == rhs.replSrcTxnIds))
+ return false;
return true;
}
bool operator != (const OpenTxnRequest &rhs) const {
@@ -6799,24 +6815,37 @@ inline std::ostream& operator<<(std::ostream& out, const OpenTxnsResponse& obj)
return out;
}
+typedef struct _AbortTxnRequest__isset {
+ _AbortTxnRequest__isset() : replPolicy(false) {}
+ bool replPolicy :1;
+} _AbortTxnRequest__isset;
class AbortTxnRequest {
public:
AbortTxnRequest(const AbortTxnRequest&);
AbortTxnRequest& operator=(const AbortTxnRequest&);
- AbortTxnRequest() : txnid(0) {
+ AbortTxnRequest() : txnid(0), replPolicy() {
}
virtual ~AbortTxnRequest() throw();
int64_t txnid;
+ std::string replPolicy;
+
+ _AbortTxnRequest__isset __isset;
void __set_txnid(const int64_t val);
+ void __set_replPolicy(const std::string& val);
+
bool operator == (const AbortTxnRequest & rhs) const
{
if (!(txnid == rhs.txnid))
return false;
+ if (__isset.replPolicy != rhs.__isset.replPolicy)
+ return false;
+ else if (__isset.replPolicy && !(replPolicy == rhs.replPolicy))
+ return false;
return true;
}
bool operator != (const AbortTxnRequest &rhs) const {
@@ -6879,24 +6908,37 @@ inline std::ostream& operator<<(std::ostream& out, const AbortTxnsRequest& obj)
return out;
}
+typedef struct _CommitTxnRequest__isset {
+ _CommitTxnRequest__isset() : replPolicy(false) {}
+ bool replPolicy :1;
+} _CommitTxnRequest__isset;
class CommitTxnRequest {
public:
CommitTxnRequest(const CommitTxnRequest&);
CommitTxnRequest& operator=(const CommitTxnRequest&);
- CommitTxnRequest() : txnid(0) {
+ CommitTxnRequest() : txnid(0), replPolicy() {
}
virtual ~CommitTxnRequest() throw();
int64_t txnid;
+ std::string replPolicy;
+
+ _CommitTxnRequest__isset __isset;
void __set_txnid(const int64_t val);
+ void __set_replPolicy(const std::string& val);
+
bool operator == (const CommitTxnRequest & rhs) const
{
if (!(txnid == rhs.txnid))
return false;
+ if (__isset.replPolicy != rhs.__isset.replPolicy)
+ return false;
+ else if (__isset.replPolicy && !(replPolicy == rhs.replPolicy))
+ return false;
return true;
}
bool operator != (const CommitTxnRequest &rhs) const {
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java
index d6c68fe..3530f2b 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java
@@ -39,6 +39,7 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AbortTxnRequest");
private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1);
+ private static final org.apache.thrift.protocol.TField REPL_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("replPolicy", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -47,10 +48,12 @@ import org.slf4j.LoggerFactory;
}
private long txnid; // required
+ private String replPolicy; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- TXNID((short)1, "txnid");
+ TXNID((short)1, "txnid"),
+ REPL_POLICY((short)2, "replPolicy");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -67,6 +70,8 @@ import org.slf4j.LoggerFactory;
switch(fieldId) {
case 1: // TXNID
return TXNID;
+ case 2: // REPL_POLICY
+ return REPL_POLICY;
default:
return null;
}
@@ -109,11 +114,14 @@ import org.slf4j.LoggerFactory;
// isset id assignments
private static final int __TXNID_ISSET_ID = 0;
private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.REPL_POLICY};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.TXNID, new org.apache.thrift.meta_data.FieldMetaData("txnid", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.REPL_POLICY, new org.apache.thrift.meta_data.FieldMetaData("replPolicy", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AbortTxnRequest.class, metaDataMap);
}
@@ -135,6 +143,9 @@ import org.slf4j.LoggerFactory;
public AbortTxnRequest(AbortTxnRequest other) {
__isset_bitfield = other.__isset_bitfield;
this.txnid = other.txnid;
+ if (other.isSetReplPolicy()) {
+ this.replPolicy = other.replPolicy;
+ }
}
public AbortTxnRequest deepCopy() {
@@ -145,6 +156,7 @@ import org.slf4j.LoggerFactory;
public void clear() {
setTxnidIsSet(false);
this.txnid = 0;
+ this.replPolicy = null;
}
public long getTxnid() {
@@ -169,6 +181,29 @@ import org.slf4j.LoggerFactory;
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXNID_ISSET_ID, value);
}
+ public String getReplPolicy() {
+ return this.replPolicy;
+ }
+
+ public void setReplPolicy(String replPolicy) {
+ this.replPolicy = replPolicy;
+ }
+
+ public void unsetReplPolicy() {
+ this.replPolicy = null;
+ }
+
+ /** Returns true if field replPolicy is set (has been assigned a value) and false otherwise */
+ public boolean isSetReplPolicy() {
+ return this.replPolicy != null;
+ }
+
+ public void setReplPolicyIsSet(boolean value) {
+ if (!value) {
+ this.replPolicy = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case TXNID:
@@ -179,6 +214,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case REPL_POLICY:
+ if (value == null) {
+ unsetReplPolicy();
+ } else {
+ setReplPolicy((String)value);
+ }
+ break;
+
}
}
@@ -187,6 +230,9 @@ import org.slf4j.LoggerFactory;
case TXNID:
return getTxnid();
+ case REPL_POLICY:
+ return getReplPolicy();
+
}
throw new IllegalStateException();
}
@@ -200,6 +246,8 @@ import org.slf4j.LoggerFactory;
switch (field) {
case TXNID:
return isSetTxnid();
+ case REPL_POLICY:
+ return isSetReplPolicy();
}
throw new IllegalStateException();
}
@@ -226,6 +274,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_replPolicy = true && this.isSetReplPolicy();
+ boolean that_present_replPolicy = true && that.isSetReplPolicy();
+ if (this_present_replPolicy || that_present_replPolicy) {
+ if (!(this_present_replPolicy && that_present_replPolicy))
+ return false;
+ if (!this.replPolicy.equals(that.replPolicy))
+ return false;
+ }
+
return true;
}
@@ -238,6 +295,11 @@ import org.slf4j.LoggerFactory;
if (present_txnid)
list.add(txnid);
+ boolean present_replPolicy = true && (isSetReplPolicy());
+ list.add(present_replPolicy);
+ if (present_replPolicy)
+ list.add(replPolicy);
+
return list.hashCode();
}
@@ -259,6 +321,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetReplPolicy()).compareTo(other.isSetReplPolicy());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReplPolicy()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replPolicy, other.replPolicy);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -282,6 +354,16 @@ import org.slf4j.LoggerFactory;
sb.append("txnid:");
sb.append(this.txnid);
first = false;
+ if (isSetReplPolicy()) {
+ if (!first) sb.append(", ");
+ sb.append("replPolicy:");
+ if (this.replPolicy == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.replPolicy);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -339,6 +421,14 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 2: // REPL_POLICY
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -355,6 +445,13 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXNID_FIELD_DESC);
oprot.writeI64(struct.txnid);
oprot.writeFieldEnd();
+ if (struct.replPolicy != null) {
+ if (struct.isSetReplPolicy()) {
+ oprot.writeFieldBegin(REPL_POLICY_FIELD_DESC);
+ oprot.writeString(struct.replPolicy);
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -373,6 +470,14 @@ import org.slf4j.LoggerFactory;
public void write(org.apache.thrift.protocol.TProtocol prot, AbortTxnRequest struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
oprot.writeI64(struct.txnid);
+ BitSet optionals = new BitSet();
+ if (struct.isSetReplPolicy()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetReplPolicy()) {
+ oprot.writeString(struct.replPolicy);
+ }
}
@Override
@@ -380,6 +485,11 @@ import org.slf4j.LoggerFactory;
TTupleProtocol iprot = (TTupleProtocol) prot;
struct.txnid = iprot.readI64();
struct.setTxnidIsSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
index 24c68d8..3ee3370 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list578 = iprot.readListBegin();
- struct.txn_ids = new ArrayList<Long>(_list578.size);
- long _elem579;
- for (int _i580 = 0; _i580 < _list578.size; ++_i580)
+ org.apache.thrift.protocol.TList _list586 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list586.size);
+ long _elem587;
+ for (int _i588 = 0; _i588 < _list586.size; ++_i588)
{
- _elem579 = iprot.readI64();
- struct.txn_ids.add(_elem579);
+ _elem587 = iprot.readI64();
+ struct.txn_ids.add(_elem587);
}
iprot.readListEnd();
}
@@ -383,9 +383,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.txn_ids.size()));
- for (long _iter581 : struct.txn_ids)
+ for (long _iter589 : struct.txn_ids)
{
- oprot.writeI64(_iter581);
+ oprot.writeI64(_iter589);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txn_ids.size());
- for (long _iter582 : struct.txn_ids)
+ for (long _iter590 : struct.txn_ids)
{
- oprot.writeI64(_iter582);
+ oprot.writeI64(_iter590);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
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 _list583 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txn_ids = new ArrayList<Long>(_list583.size);
- long _elem584;
- for (int _i585 = 0; _i585 < _list583.size; ++_i585)
+ org.apache.thrift.protocol.TList _list591 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list591.size);
+ long _elem592;
+ for (int _i593 = 0; _i593 < _list591.size; ++_i593)
{
- _elem584 = iprot.readI64();
- struct.txn_ids.add(_elem584);
+ _elem592 = iprot.readI64();
+ struct.txn_ids.add(_elem592);
}
}
struct.setTxn_idsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 d6a071a..3acdec5 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 _list676 = iprot.readListBegin();
- struct.partitionnames = new ArrayList<String>(_list676.size);
- String _elem677;
- for (int _i678 = 0; _i678 < _list676.size; ++_i678)
+ org.apache.thrift.protocol.TList _list684 = iprot.readListBegin();
+ struct.partitionnames = new ArrayList<String>(_list684.size);
+ String _elem685;
+ for (int _i686 = 0; _i686 < _list684.size; ++_i686)
{
- _elem677 = iprot.readString();
- struct.partitionnames.add(_elem677);
+ _elem685 = iprot.readString();
+ struct.partitionnames.add(_elem685);
}
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 _iter679 : struct.partitionnames)
+ for (String _iter687 : struct.partitionnames)
{
- oprot.writeString(_iter679);
+ oprot.writeString(_iter687);
}
oprot.writeListEnd();
}
@@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tablename);
{
oprot.writeI32(struct.partitionnames.size());
- for (String _iter680 : struct.partitionnames)
+ for (String _iter688 : struct.partitionnames)
{
- oprot.writeString(_iter680);
+ oprot.writeString(_iter688);
}
}
BitSet optionals = new BitSet();
@@ -937,13 +937,13 @@ import org.slf4j.LoggerFactory;
struct.tablename = iprot.readString();
struct.setTablenameIsSet(true);
{
- org.apache.thrift.protocol.TList _list681 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionnames = new ArrayList<String>(_list681.size);
- String _elem682;
- for (int _i683 = 0; _i683 < _list681.size; ++_i683)
+ org.apache.thrift.protocol.TList _list689 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionnames = new ArrayList<String>(_list689.size);
+ String _elem690;
+ for (int _i691 = 0; _i691 < _list689.size; ++_i691)
{
- _elem682 = iprot.readString();
- struct.partitionnames.add(_elem682);
+ _elem690 = iprot.readString();
+ struct.partitionnames.add(_elem690);
}
}
struct.setPartitionnamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 fd0d3c9..35ccef7 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
@@ -521,13 +521,13 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
- struct.txnIds = new ArrayList<Long>(_list610.size);
- long _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ 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)
{
- _elem611 = iprot.readI64();
- struct.txnIds.add(_elem611);
+ _elem619 = iprot.readI64();
+ struct.txnIds.add(_elem619);
}
iprot.readListEnd();
}
@@ -569,9 +569,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 _iter613 : struct.txnIds)
+ for (long _iter621 : struct.txnIds)
{
- oprot.writeI64(_iter613);
+ oprot.writeI64(_iter621);
}
oprot.writeListEnd();
}
@@ -606,9 +606,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txnIds.size());
- for (long _iter614 : struct.txnIds)
+ for (long _iter622 : struct.txnIds)
{
- oprot.writeI64(_iter614);
+ oprot.writeI64(_iter622);
}
}
oprot.writeString(struct.dbName);
@@ -619,13 +619,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AllocateTableWriteIdsRequest 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.txnIds = new ArrayList<Long>(_list615.size);
- long _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.I64, iprot.readI32());
+ struct.txnIds = new ArrayList<Long>(_list623.size);
+ long _elem624;
+ for (int _i625 = 0; _i625 < _list623.size; ++_i625)
{
- _elem616 = iprot.readI64();
- struct.txnIds.add(_elem616);
+ _elem624 = iprot.readI64();
+ struct.txnIds.add(_elem624);
}
}
struct.setTxnIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 fb47073..35cbca3 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 _list618 = iprot.readListBegin();
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list618.size);
- TxnToWriteId _elem619;
- for (int _i620 = 0; _i620 < _list618.size; ++_i620)
+ org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
+ struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list626.size);
+ TxnToWriteId _elem627;
+ for (int _i628 = 0; _i628 < _list626.size; ++_i628)
{
- _elem619 = new TxnToWriteId();
- _elem619.read(iprot);
- struct.txnToWriteIds.add(_elem619);
+ _elem627 = new TxnToWriteId();
+ _elem627.read(iprot);
+ struct.txnToWriteIds.add(_elem627);
}
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 _iter621 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter629 : struct.txnToWriteIds)
{
- _iter621.write(oprot);
+ _iter629.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txnToWriteIds.size());
- for (TxnToWriteId _iter622 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter630 : struct.txnToWriteIds)
{
- _iter622.write(oprot);
+ _iter630.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 _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list623.size);
- TxnToWriteId _elem624;
- for (int _i625 = 0; _i625 < _list623.size; ++_i625)
+ org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list631.size);
+ TxnToWriteId _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
{
- _elem624 = new TxnToWriteId();
- _elem624.read(iprot);
- struct.txnToWriteIds.add(_elem624);
+ _elem632 = new TxnToWriteId();
+ _elem632.read(iprot);
+ struct.txnToWriteIds.add(_elem632);
}
}
struct.setTxnToWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 b4bf2ce..2162163 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 _list776 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list776.size);
- long _elem777;
- for (int _i778 = 0; _i778 < _list776.size; ++_i778)
+ org.apache.thrift.protocol.TList _list784 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list784.size);
+ long _elem785;
+ for (int _i786 = 0; _i786 < _list784.size; ++_i786)
{
- _elem777 = iprot.readI64();
- struct.fileIds.add(_elem777);
+ _elem785 = iprot.readI64();
+ struct.fileIds.add(_elem785);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter779 : struct.fileIds)
+ for (long _iter787 : struct.fileIds)
{
- oprot.writeI64(_iter779);
+ oprot.writeI64(_iter787);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter780 : struct.fileIds)
+ for (long _iter788 : struct.fileIds)
{
- oprot.writeI64(_iter780);
+ oprot.writeI64(_iter788);
}
}
}
@@ -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 _list781 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list781.size);
- long _elem782;
- for (int _i783 = 0; _i783 < _list781.size; ++_i783)
+ org.apache.thrift.protocol.TList _list789 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list789.size);
+ long _elem790;
+ for (int _i791 = 0; _i791 < _list789.size; ++_i791)
{
- _elem782 = iprot.readI64();
- struct.fileIds.add(_elem782);
+ _elem790 = iprot.readI64();
+ struct.fileIds.add(_elem790);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 a214a87..65e9e4c 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 _list792 = iprot.readListBegin();
- struct.values = new ArrayList<ClientCapability>(_list792.size);
- ClientCapability _elem793;
- for (int _i794 = 0; _i794 < _list792.size; ++_i794)
+ org.apache.thrift.protocol.TList _list800 = iprot.readListBegin();
+ struct.values = new ArrayList<ClientCapability>(_list800.size);
+ ClientCapability _elem801;
+ for (int _i802 = 0; _i802 < _list800.size; ++_i802)
{
- _elem793 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem793);
+ _elem801 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem801);
}
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 _iter795 : struct.values)
+ for (ClientCapability _iter803 : struct.values)
{
- oprot.writeI32(_iter795.getValue());
+ oprot.writeI32(_iter803.getValue());
}
oprot.writeListEnd();
}
@@ -413,9 +413,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.values.size());
- for (ClientCapability _iter796 : struct.values)
+ for (ClientCapability _iter804 : struct.values)
{
- oprot.writeI32(_iter796.getValue());
+ oprot.writeI32(_iter804.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 _list797 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.values = new ArrayList<ClientCapability>(_list797.size);
- ClientCapability _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.I32, iprot.readI32());
+ struct.values = new ArrayList<ClientCapability>(_list805.size);
+ ClientCapability _elem806;
+ for (int _i807 = 0; _i807 < _list805.size; ++_i807)
{
- _elem798 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem798);
+ _elem806 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem806);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
index 17e6e9c..3c15f84 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java
@@ -39,6 +39,7 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommitTxnRequest");
private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1);
+ private static final org.apache.thrift.protocol.TField REPL_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("replPolicy", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -47,10 +48,12 @@ import org.slf4j.LoggerFactory;
}
private long txnid; // required
+ private String replPolicy; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- TXNID((short)1, "txnid");
+ TXNID((short)1, "txnid"),
+ REPL_POLICY((short)2, "replPolicy");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -67,6 +70,8 @@ import org.slf4j.LoggerFactory;
switch(fieldId) {
case 1: // TXNID
return TXNID;
+ case 2: // REPL_POLICY
+ return REPL_POLICY;
default:
return null;
}
@@ -109,11 +114,14 @@ import org.slf4j.LoggerFactory;
// isset id assignments
private static final int __TXNID_ISSET_ID = 0;
private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.REPL_POLICY};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.TXNID, new org.apache.thrift.meta_data.FieldMetaData("txnid", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.REPL_POLICY, new org.apache.thrift.meta_data.FieldMetaData("replPolicy", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CommitTxnRequest.class, metaDataMap);
}
@@ -135,6 +143,9 @@ import org.slf4j.LoggerFactory;
public CommitTxnRequest(CommitTxnRequest other) {
__isset_bitfield = other.__isset_bitfield;
this.txnid = other.txnid;
+ if (other.isSetReplPolicy()) {
+ this.replPolicy = other.replPolicy;
+ }
}
public CommitTxnRequest deepCopy() {
@@ -145,6 +156,7 @@ import org.slf4j.LoggerFactory;
public void clear() {
setTxnidIsSet(false);
this.txnid = 0;
+ this.replPolicy = null;
}
public long getTxnid() {
@@ -169,6 +181,29 @@ import org.slf4j.LoggerFactory;
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXNID_ISSET_ID, value);
}
+ public String getReplPolicy() {
+ return this.replPolicy;
+ }
+
+ public void setReplPolicy(String replPolicy) {
+ this.replPolicy = replPolicy;
+ }
+
+ public void unsetReplPolicy() {
+ this.replPolicy = null;
+ }
+
+ /** Returns true if field replPolicy is set (has been assigned a value) and false otherwise */
+ public boolean isSetReplPolicy() {
+ return this.replPolicy != null;
+ }
+
+ public void setReplPolicyIsSet(boolean value) {
+ if (!value) {
+ this.replPolicy = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case TXNID:
@@ -179,6 +214,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case REPL_POLICY:
+ if (value == null) {
+ unsetReplPolicy();
+ } else {
+ setReplPolicy((String)value);
+ }
+ break;
+
}
}
@@ -187,6 +230,9 @@ import org.slf4j.LoggerFactory;
case TXNID:
return getTxnid();
+ case REPL_POLICY:
+ return getReplPolicy();
+
}
throw new IllegalStateException();
}
@@ -200,6 +246,8 @@ import org.slf4j.LoggerFactory;
switch (field) {
case TXNID:
return isSetTxnid();
+ case REPL_POLICY:
+ return isSetReplPolicy();
}
throw new IllegalStateException();
}
@@ -226,6 +274,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_replPolicy = true && this.isSetReplPolicy();
+ boolean that_present_replPolicy = true && that.isSetReplPolicy();
+ if (this_present_replPolicy || that_present_replPolicy) {
+ if (!(this_present_replPolicy && that_present_replPolicy))
+ return false;
+ if (!this.replPolicy.equals(that.replPolicy))
+ return false;
+ }
+
return true;
}
@@ -238,6 +295,11 @@ import org.slf4j.LoggerFactory;
if (present_txnid)
list.add(txnid);
+ boolean present_replPolicy = true && (isSetReplPolicy());
+ list.add(present_replPolicy);
+ if (present_replPolicy)
+ list.add(replPolicy);
+
return list.hashCode();
}
@@ -259,6 +321,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetReplPolicy()).compareTo(other.isSetReplPolicy());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReplPolicy()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replPolicy, other.replPolicy);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -282,6 +354,16 @@ import org.slf4j.LoggerFactory;
sb.append("txnid:");
sb.append(this.txnid);
first = false;
+ if (isSetReplPolicy()) {
+ if (!first) sb.append(", ");
+ sb.append("replPolicy:");
+ if (this.replPolicy == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.replPolicy);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -339,6 +421,14 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 2: // REPL_POLICY
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -355,6 +445,13 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXNID_FIELD_DESC);
oprot.writeI64(struct.txnid);
oprot.writeFieldEnd();
+ if (struct.replPolicy != null) {
+ if (struct.isSetReplPolicy()) {
+ oprot.writeFieldBegin(REPL_POLICY_FIELD_DESC);
+ oprot.writeString(struct.replPolicy);
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -373,6 +470,14 @@ import org.slf4j.LoggerFactory;
public void write(org.apache.thrift.protocol.TProtocol prot, CommitTxnRequest struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
oprot.writeI64(struct.txnid);
+ BitSet optionals = new BitSet();
+ if (struct.isSetReplPolicy()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetReplPolicy()) {
+ oprot.writeString(struct.replPolicy);
+ }
}
@Override
@@ -380,6 +485,11 @@ import org.slf4j.LoggerFactory;
TTupleProtocol iprot = (TTupleProtocol) prot;
struct.txnid = iprot.readI64();
struct.setTxnidIsSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 a106cd4..e499e80 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 _map658 = iprot.readMapBegin();
- struct.properties = new HashMap<String,String>(2*_map658.size);
- String _key659;
- String _val660;
- for (int _i661 = 0; _i661 < _map658.size; ++_i661)
+ org.apache.thrift.protocol.TMap _map666 = iprot.readMapBegin();
+ struct.properties = new HashMap<String,String>(2*_map666.size);
+ String _key667;
+ String _val668;
+ for (int _i669 = 0; _i669 < _map666.size; ++_i669)
{
- _key659 = iprot.readString();
- _val660 = iprot.readString();
- struct.properties.put(_key659, _val660);
+ _key667 = iprot.readString();
+ _val668 = iprot.readString();
+ struct.properties.put(_key667, _val668);
}
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> _iter662 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter670 : struct.properties.entrySet())
{
- oprot.writeString(_iter662.getKey());
- oprot.writeString(_iter662.getValue());
+ oprot.writeString(_iter670.getKey());
+ oprot.writeString(_iter670.getValue());
}
oprot.writeMapEnd();
}
@@ -928,10 +928,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetProperties()) {
{
oprot.writeI32(struct.properties.size());
- for (Map.Entry<String, String> _iter663 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter671 : struct.properties.entrySet())
{
- oprot.writeString(_iter663.getKey());
- oprot.writeString(_iter663.getValue());
+ oprot.writeString(_iter671.getKey());
+ oprot.writeString(_iter671.getValue());
}
}
}
@@ -957,15 +957,15 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map664 = 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*_map664.size);
- String _key665;
- String _val666;
- for (int _i667 = 0; _i667 < _map664.size; ++_i667)
+ org.apache.thrift.protocol.TMap _map672 = 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*_map672.size);
+ String _key673;
+ String _val674;
+ for (int _i675 = 0; _i675 < _map672.size; ++_i675)
{
- _key665 = iprot.readString();
- _val666 = iprot.readString();
- struct.properties.put(_key665, _val666);
+ _key673 = iprot.readString();
+ _val674 = iprot.readString();
+ struct.properties.put(_key673, _val674);
}
}
struct.setPropertiesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 d28972c..1a16fac 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 _set684 = iprot.readSetBegin();
- struct.tablesUsed = new HashSet<String>(2*_set684.size);
- String _elem685;
- for (int _i686 = 0; _i686 < _set684.size; ++_i686)
+ org.apache.thrift.protocol.TSet _set692 = iprot.readSetBegin();
+ struct.tablesUsed = new HashSet<String>(2*_set692.size);
+ String _elem693;
+ for (int _i694 = 0; _i694 < _set692.size; ++_i694)
{
- _elem685 = iprot.readString();
- struct.tablesUsed.add(_elem685);
+ _elem693 = iprot.readString();
+ struct.tablesUsed.add(_elem693);
}
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 _iter687 : struct.tablesUsed)
+ for (String _iter695 : struct.tablesUsed)
{
- oprot.writeString(_iter687);
+ oprot.writeString(_iter695);
}
oprot.writeSetEnd();
}
@@ -804,9 +804,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.tablesUsed.size());
- for (String _iter688 : struct.tablesUsed)
+ for (String _iter696 : struct.tablesUsed)
{
- oprot.writeString(_iter688);
+ oprot.writeString(_iter696);
}
}
BitSet optionals = new BitSet();
@@ -829,13 +829,13 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TSet _set689 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tablesUsed = new HashSet<String>(2*_set689.size);
- String _elem690;
- for (int _i691 = 0; _i691 < _set689.size; ++_i691)
+ org.apache.thrift.protocol.TSet _set697 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tablesUsed = new HashSet<String>(2*_set697.size);
+ String _elem698;
+ for (int _i699 = 0; _i699 < _set697.size; ++_i699)
{
- _elem690 = iprot.readString();
- struct.tablesUsed.add(_elem690);
+ _elem698 = iprot.readString();
+ struct.tablesUsed.add(_elem698);
}
}
struct.setTablesUsedIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 b95efc7..c06b95c 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 _list896 = iprot.readListBegin();
- struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list896.size);
- SchemaVersionDescriptor _elem897;
- for (int _i898 = 0; _i898 < _list896.size; ++_i898)
+ org.apache.thrift.protocol.TList _list904 = iprot.readListBegin();
+ struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list904.size);
+ SchemaVersionDescriptor _elem905;
+ for (int _i906 = 0; _i906 < _list904.size; ++_i906)
{
- _elem897 = new SchemaVersionDescriptor();
- _elem897.read(iprot);
- struct.schemaVersions.add(_elem897);
+ _elem905 = new SchemaVersionDescriptor();
+ _elem905.read(iprot);
+ struct.schemaVersions.add(_elem905);
}
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 _iter899 : struct.schemaVersions)
+ for (SchemaVersionDescriptor _iter907 : struct.schemaVersions)
{
- _iter899.write(oprot);
+ _iter907.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSchemaVersions()) {
{
oprot.writeI32(struct.schemaVersions.size());
- for (SchemaVersionDescriptor _iter900 : struct.schemaVersions)
+ for (SchemaVersionDescriptor _iter908 : struct.schemaVersions)
{
- _iter900.write(oprot);
+ _iter908.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list901.size);
- SchemaVersionDescriptor _elem902;
- for (int _i903 = 0; _i903 < _list901.size; ++_i903)
+ org.apache.thrift.protocol.TList _list909 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.schemaVersions = new ArrayList<SchemaVersionDescriptor>(_list909.size);
+ SchemaVersionDescriptor _elem910;
+ for (int _i911 = 0; _i911 < _list909.size; ++_i911)
{
- _elem902 = new SchemaVersionDescriptor();
- _elem902.read(iprot);
- struct.schemaVersions.add(_elem902);
+ _elem910 = new SchemaVersionDescriptor();
+ _elem910.read(iprot);
+ struct.schemaVersions.add(_elem910);
}
}
struct.setSchemaVersionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 ddc0a6a..14e6abe 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 _list716 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list716.size);
- String _elem717;
- for (int _i718 = 0; _i718 < _list716.size; ++_i718)
+ org.apache.thrift.protocol.TList _list724 = iprot.readListBegin();
+ struct.partitionVals = new ArrayList<String>(_list724.size);
+ String _elem725;
+ for (int _i726 = 0; _i726 < _list724.size; ++_i726)
{
- _elem717 = iprot.readString();
- struct.partitionVals.add(_elem717);
+ _elem725 = iprot.readString();
+ struct.partitionVals.add(_elem725);
}
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 _iter719 : struct.partitionVals)
+ for (String _iter727 : struct.partitionVals)
{
- oprot.writeString(_iter719);
+ oprot.writeString(_iter727);
}
oprot.writeListEnd();
}
@@ -915,9 +915,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter720 : struct.partitionVals)
+ for (String _iter728 : struct.partitionVals)
{
- oprot.writeString(_iter720);
+ oprot.writeString(_iter728);
}
}
}
@@ -945,13 +945,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list721.size);
- String _elem722;
- for (int _i723 = 0; _i723 < _list721.size; ++_i723)
+ org.apache.thrift.protocol.TList _list729 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionVals = new ArrayList<String>(_list729.size);
+ String _elem730;
+ for (int _i731 = 0; _i731 < _list729.size; ++_i731)
{
- _elem722 = iprot.readString();
- struct.partitionVals.add(_elem722);
+ _elem730 = iprot.readString();
+ struct.partitionVals.add(_elem730);
}
}
struct.setPartitionValsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 0c5f62b..dfdc357 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 _list784 = iprot.readListBegin();
- struct.functions = new ArrayList<Function>(_list784.size);
- Function _elem785;
- for (int _i786 = 0; _i786 < _list784.size; ++_i786)
+ org.apache.thrift.protocol.TList _list792 = iprot.readListBegin();
+ struct.functions = new ArrayList<Function>(_list792.size);
+ Function _elem793;
+ for (int _i794 = 0; _i794 < _list792.size; ++_i794)
{
- _elem785 = new Function();
- _elem785.read(iprot);
- struct.functions.add(_elem785);
+ _elem793 = new Function();
+ _elem793.read(iprot);
+ struct.functions.add(_elem793);
}
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 _iter787 : struct.functions)
+ for (Function _iter795 : struct.functions)
{
- _iter787.write(oprot);
+ _iter795.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFunctions()) {
{
oprot.writeI32(struct.functions.size());
- for (Function _iter788 : struct.functions)
+ for (Function _iter796 : struct.functions)
{
- _iter788.write(oprot);
+ _iter796.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list789 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.functions = new ArrayList<Function>(_list789.size);
- Function _elem790;
- for (int _i791 = 0; _i791 < _list789.size; ++_i791)
+ org.apache.thrift.protocol.TList _list797 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.functions = new ArrayList<Function>(_list797.size);
+ Function _elem798;
+ for (int _i799 = 0; _i799 < _list797.size; ++_i799)
{
- _elem790 = new Function();
- _elem790.read(iprot);
- struct.functions.add(_elem790);
+ _elem798 = new Function();
+ _elem798.read(iprot);
+ struct.functions.add(_elem798);
}
}
struct.setFunctionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 b64dea4..0adb11d 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 _list734 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list734.size);
- long _elem735;
- for (int _i736 = 0; _i736 < _list734.size; ++_i736)
+ org.apache.thrift.protocol.TList _list742 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list742.size);
+ long _elem743;
+ for (int _i744 = 0; _i744 < _list742.size; ++_i744)
{
- _elem735 = iprot.readI64();
- struct.fileIds.add(_elem735);
+ _elem743 = iprot.readI64();
+ struct.fileIds.add(_elem743);
}
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 _iter737 : struct.fileIds)
+ for (long _iter745 : struct.fileIds)
{
- oprot.writeI64(_iter737);
+ oprot.writeI64(_iter745);
}
oprot.writeListEnd();
}
@@ -719,9 +719,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter738 : struct.fileIds)
+ for (long _iter746 : struct.fileIds)
{
- oprot.writeI64(_iter738);
+ oprot.writeI64(_iter746);
}
}
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 _list739 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list739.size);
- long _elem740;
- for (int _i741 = 0; _i741 < _list739.size; ++_i741)
+ org.apache.thrift.protocol.TList _list747 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list747.size);
+ long _elem748;
+ for (int _i749 = 0; _i749 < _list747.size; ++_i749)
{
- _elem740 = iprot.readI64();
- struct.fileIds.add(_elem740);
+ _elem748 = iprot.readI64();
+ struct.fileIds.add(_elem748);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 a01a366..f86d9ea 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 _map724 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map724.size);
- long _key725;
- MetadataPpdResult _val726;
- for (int _i727 = 0; _i727 < _map724.size; ++_i727)
+ org.apache.thrift.protocol.TMap _map732 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map732.size);
+ long _key733;
+ MetadataPpdResult _val734;
+ for (int _i735 = 0; _i735 < _map732.size; ++_i735)
{
- _key725 = iprot.readI64();
- _val726 = new MetadataPpdResult();
- _val726.read(iprot);
- struct.metadata.put(_key725, _val726);
+ _key733 = iprot.readI64();
+ _val734 = new MetadataPpdResult();
+ _val734.read(iprot);
+ struct.metadata.put(_key733, _val734);
}
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> _iter728 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter736 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter728.getKey());
- _iter728.getValue().write(oprot);
+ oprot.writeI64(_iter736.getKey());
+ _iter736.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> _iter729 : struct.metadata.entrySet())
+ for (Map.Entry<Long, MetadataPpdResult> _iter737 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter729.getKey());
- _iter729.getValue().write(oprot);
+ oprot.writeI64(_iter737.getKey());
+ _iter737.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 _map730 = 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*_map730.size);
- long _key731;
- MetadataPpdResult _val732;
- for (int _i733 = 0; _i733 < _map730.size; ++_i733)
+ org.apache.thrift.protocol.TMap _map738 = 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*_map738.size);
+ long _key739;
+ MetadataPpdResult _val740;
+ for (int _i741 = 0; _i741 < _map738.size; ++_i741)
{
- _key731 = iprot.readI64();
- _val732 = new MetadataPpdResult();
- _val732.read(iprot);
- struct.metadata.put(_key731, _val732);
+ _key739 = iprot.readI64();
+ _val740 = new MetadataPpdResult();
+ _val740.read(iprot);
+ struct.metadata.put(_key739, _val740);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 4541cf4..b98375c 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 _list752 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list752.size);
- long _elem753;
- for (int _i754 = 0; _i754 < _list752.size; ++_i754)
+ org.apache.thrift.protocol.TList _list760 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list760.size);
+ long _elem761;
+ for (int _i762 = 0; _i762 < _list760.size; ++_i762)
{
- _elem753 = iprot.readI64();
- struct.fileIds.add(_elem753);
+ _elem761 = iprot.readI64();
+ struct.fileIds.add(_elem761);
}
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 _iter755 : struct.fileIds)
+ for (long _iter763 : struct.fileIds)
{
- oprot.writeI64(_iter755);
+ oprot.writeI64(_iter763);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter756 : struct.fileIds)
+ for (long _iter764 : struct.fileIds)
{
- oprot.writeI64(_iter756);
+ oprot.writeI64(_iter764);
}
}
}
@@ -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 _list757 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list757.size);
- long _elem758;
- for (int _i759 = 0; _i759 < _list757.size; ++_i759)
+ org.apache.thrift.protocol.TList _list765 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list765.size);
+ long _elem766;
+ for (int _i767 = 0; _i767 < _list765.size; ++_i767)
{
- _elem758 = iprot.readI64();
- struct.fileIds.add(_elem758);
+ _elem766 = iprot.readI64();
+ struct.fileIds.add(_elem766);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 3efb371..d8d903e 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 _map742 = iprot.readMapBegin();
- struct.metadata = new HashMap<Long,ByteBuffer>(2*_map742.size);
- long _key743;
- ByteBuffer _val744;
- for (int _i745 = 0; _i745 < _map742.size; ++_i745)
+ org.apache.thrift.protocol.TMap _map750 = iprot.readMapBegin();
+ struct.metadata = new HashMap<Long,ByteBuffer>(2*_map750.size);
+ long _key751;
+ ByteBuffer _val752;
+ for (int _i753 = 0; _i753 < _map750.size; ++_i753)
{
- _key743 = iprot.readI64();
- _val744 = iprot.readBinary();
- struct.metadata.put(_key743, _val744);
+ _key751 = iprot.readI64();
+ _val752 = iprot.readBinary();
+ struct.metadata.put(_key751, _val752);
}
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> _iter746 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter754 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter746.getKey());
- oprot.writeBinary(_iter746.getValue());
+ oprot.writeI64(_iter754.getKey());
+ oprot.writeBinary(_iter754.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> _iter747 : struct.metadata.entrySet())
+ for (Map.Entry<Long, ByteBuffer> _iter755 : struct.metadata.entrySet())
{
- oprot.writeI64(_iter747.getKey());
- oprot.writeBinary(_iter747.getValue());
+ oprot.writeI64(_iter755.getKey());
+ oprot.writeBinary(_iter755.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 _map748 = 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*_map748.size);
- long _key749;
- ByteBuffer _val750;
- for (int _i751 = 0; _i751 < _map748.size; ++_i751)
+ org.apache.thrift.protocol.TMap _map756 = 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*_map756.size);
+ long _key757;
+ ByteBuffer _val758;
+ for (int _i759 = 0; _i759 < _map756.size; ++_i759)
{
- _key749 = iprot.readI64();
- _val750 = iprot.readBinary();
- struct.metadata.put(_key749, _val750);
+ _key757 = iprot.readI64();
+ _val758 = iprot.readBinary();
+ struct.metadata.put(_key757, _val758);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 1c9fba8..a264cdd 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 _list800 = iprot.readListBegin();
- struct.tblNames = new ArrayList<String>(_list800.size);
- String _elem801;
- for (int _i802 = 0; _i802 < _list800.size; ++_i802)
+ org.apache.thrift.protocol.TList _list808 = iprot.readListBegin();
+ struct.tblNames = new ArrayList<String>(_list808.size);
+ String _elem809;
+ for (int _i810 = 0; _i810 < _list808.size; ++_i810)
{
- _elem801 = iprot.readString();
- struct.tblNames.add(_elem801);
+ _elem809 = iprot.readString();
+ struct.tblNames.add(_elem809);
}
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 _iter803 : struct.tblNames)
+ for (String _iter811 : struct.tblNames)
{
- oprot.writeString(_iter803);
+ oprot.writeString(_iter811);
}
oprot.writeListEnd();
}
@@ -716,9 +716,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTblNames()) {
{
oprot.writeI32(struct.tblNames.size());
- for (String _iter804 : struct.tblNames)
+ for (String _iter812 : struct.tblNames)
{
- oprot.writeString(_iter804);
+ oprot.writeString(_iter812);
}
}
}
@@ -738,13 +738,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list805 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tblNames = new ArrayList<String>(_list805.size);
- String _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.STRING, iprot.readI32());
+ struct.tblNames = new ArrayList<String>(_list813.size);
+ String _elem814;
+ for (int _i815 = 0; _i815 < _list813.size; ++_i815)
{
- _elem806 = iprot.readString();
- struct.tblNames.add(_elem806);
+ _elem814 = iprot.readString();
+ struct.tblNames.add(_elem814);
}
}
struct.setTblNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/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 c020773..f4ccc8b 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 _list808 = iprot.readListBegin();
- struct.tables = new ArrayList<Table>(_list808.size);
- Table _elem809;
- for (int _i810 = 0; _i810 < _list808.size; ++_i810)
+ org.apache.thrift.protocol.TList _list816 = iprot.readListBegin();
+ struct.tables = new ArrayList<Table>(_list816.size);
+ Table _elem817;
+ for (int _i818 = 0; _i818 < _list816.size; ++_i818)
{
- _elem809 = new Table();
- _elem809.read(iprot);
- struct.tables.add(_elem809);
+ _elem817 = new Table();
+ _elem817.read(iprot);
+ struct.tables.add(_elem817);
}
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 _iter811 : struct.tables)
+ for (Table _iter819 : struct.tables)
{
- _iter811.write(oprot);
+ _iter819.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tables.size());
- for (Table _iter812 : struct.tables)
+ for (Table _iter820 : struct.tables)
{
- _iter812.write(oprot);
+ _iter820.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 _list813 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tables = new ArrayList<Table>(_list813.size);
- Table _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.STRUCT, iprot.readI32());
+ struct.tables = new ArrayList<Table>(_list821.size);
+ Table _elem822;
+ for (int _i823 = 0; _i823 < _list821.size; ++_i823)
{
- _elem814 = new Table();
- _elem814.read(iprot);
- struct.tables.add(_elem814);
+ _elem822 = new Table();
+ _elem822.read(iprot);
+ struct.tables.add(_elem822);
}
}
struct.setTablesIsSet(true);