You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jc...@apache.org on 2018/01/11 21:54:53 UTC
[13/22] hive git commit: HIVE-14498: Freshness period for query
rewriting using materialized views (Jesus Camacho Rodriguez,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/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 74ce8d3..3218d9a 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
@@ -398,6 +398,10 @@ class ShowCompactResponse;
class AddDynamicPartitions;
+class BasicTxnInfo;
+
+class TxnsSnapshot;
+
class NotificationEventRequest;
class NotificationEvent;
@@ -458,6 +462,8 @@ class CmRecycleResponse;
class TableMeta;
+class Materialization;
+
class WMResourcePlan;
class WMPool;
@@ -2362,7 +2368,7 @@ inline std::ostream& operator<<(std::ostream& out, const StorageDescriptor& obj)
}
typedef struct _Table__isset {
- _Table__isset() : tableName(false), dbName(false), owner(false), createTime(false), lastAccessTime(false), retention(false), sd(false), partitionKeys(false), parameters(false), viewOriginalText(false), viewExpandedText(false), tableType(false), privileges(false), temporary(true), rewriteEnabled(false) {}
+ _Table__isset() : tableName(false), dbName(false), owner(false), createTime(false), lastAccessTime(false), retention(false), sd(false), partitionKeys(false), parameters(false), viewOriginalText(false), viewExpandedText(false), tableType(false), privileges(false), temporary(true), rewriteEnabled(false), creationMetadata(false) {}
bool tableName :1;
bool dbName :1;
bool owner :1;
@@ -2378,6 +2384,7 @@ typedef struct _Table__isset {
bool privileges :1;
bool temporary :1;
bool rewriteEnabled :1;
+ bool creationMetadata :1;
} _Table__isset;
class Table {
@@ -2404,6 +2411,7 @@ class Table {
PrincipalPrivilegeSet privileges;
bool temporary;
bool rewriteEnabled;
+ std::map<std::string, BasicTxnInfo> creationMetadata;
_Table__isset __isset;
@@ -2437,6 +2445,8 @@ class Table {
void __set_rewriteEnabled(const bool val);
+ void __set_creationMetadata(const std::map<std::string, BasicTxnInfo> & val);
+
bool operator == (const Table & rhs) const
{
if (!(tableName == rhs.tableName))
@@ -2475,6 +2485,10 @@ class Table {
return false;
else if (__isset.rewriteEnabled && !(rewriteEnabled == rhs.rewriteEnabled))
return false;
+ if (__isset.creationMetadata != rhs.__isset.creationMetadata)
+ return false;
+ else if (__isset.creationMetadata && !(creationMetadata == rhs.creationMetadata))
+ return false;
return true;
}
bool operator != (const Table &rhs) const {
@@ -7067,6 +7081,144 @@ inline std::ostream& operator<<(std::ostream& out, const AddDynamicPartitions& o
return out;
}
+typedef struct _BasicTxnInfo__isset {
+ _BasicTxnInfo__isset() : id(false), time(false), txnid(false), dbname(false), tablename(false), partitionname(false) {}
+ bool id :1;
+ bool time :1;
+ bool txnid :1;
+ bool dbname :1;
+ bool tablename :1;
+ bool partitionname :1;
+} _BasicTxnInfo__isset;
+
+class BasicTxnInfo {
+ public:
+
+ BasicTxnInfo(const BasicTxnInfo&);
+ BasicTxnInfo& operator=(const BasicTxnInfo&);
+ BasicTxnInfo() : isnull(0), id(0), time(0), txnid(0), dbname(), tablename(), partitionname() {
+ }
+
+ virtual ~BasicTxnInfo() throw();
+ bool isnull;
+ int64_t id;
+ int64_t time;
+ int64_t txnid;
+ std::string dbname;
+ std::string tablename;
+ std::string partitionname;
+
+ _BasicTxnInfo__isset __isset;
+
+ void __set_isnull(const bool val);
+
+ void __set_id(const int64_t val);
+
+ void __set_time(const int64_t val);
+
+ void __set_txnid(const int64_t val);
+
+ void __set_dbname(const std::string& val);
+
+ void __set_tablename(const std::string& val);
+
+ void __set_partitionname(const std::string& val);
+
+ bool operator == (const BasicTxnInfo & rhs) const
+ {
+ if (!(isnull == rhs.isnull))
+ return false;
+ if (__isset.id != rhs.__isset.id)
+ return false;
+ else if (__isset.id && !(id == rhs.id))
+ return false;
+ if (__isset.time != rhs.__isset.time)
+ return false;
+ else if (__isset.time && !(time == rhs.time))
+ return false;
+ if (__isset.txnid != rhs.__isset.txnid)
+ return false;
+ else if (__isset.txnid && !(txnid == rhs.txnid))
+ return false;
+ if (__isset.dbname != rhs.__isset.dbname)
+ return false;
+ else if (__isset.dbname && !(dbname == rhs.dbname))
+ return false;
+ if (__isset.tablename != rhs.__isset.tablename)
+ return false;
+ else if (__isset.tablename && !(tablename == rhs.tablename))
+ return false;
+ if (__isset.partitionname != rhs.__isset.partitionname)
+ return false;
+ else if (__isset.partitionname && !(partitionname == rhs.partitionname))
+ return false;
+ return true;
+ }
+ bool operator != (const BasicTxnInfo &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const BasicTxnInfo & ) 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(BasicTxnInfo &a, BasicTxnInfo &b);
+
+inline std::ostream& operator<<(std::ostream& out, const BasicTxnInfo& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
+class TxnsSnapshot {
+ public:
+
+ TxnsSnapshot(const TxnsSnapshot&);
+ TxnsSnapshot& operator=(const TxnsSnapshot&);
+ TxnsSnapshot() : txn_high_water_mark(0) {
+ }
+
+ virtual ~TxnsSnapshot() throw();
+ int64_t txn_high_water_mark;
+ std::vector<int64_t> open_txns;
+
+ void __set_txn_high_water_mark(const int64_t val);
+
+ void __set_open_txns(const std::vector<int64_t> & val);
+
+ bool operator == (const TxnsSnapshot & rhs) const
+ {
+ if (!(txn_high_water_mark == rhs.txn_high_water_mark))
+ return false;
+ if (!(open_txns == rhs.open_txns))
+ return false;
+ return true;
+ }
+ bool operator != (const TxnsSnapshot &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const TxnsSnapshot & ) 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(TxnsSnapshot &a, TxnsSnapshot &b);
+
+inline std::ostream& operator<<(std::ostream& out, const TxnsSnapshot& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
typedef struct _NotificationEventRequest__isset {
_NotificationEventRequest__isset() : maxEvents(false) {}
bool maxEvents :1;
@@ -8541,6 +8693,56 @@ inline std::ostream& operator<<(std::ostream& out, const TableMeta& obj)
return out;
}
+
+class Materialization {
+ public:
+
+ Materialization(const Materialization&);
+ Materialization& operator=(const Materialization&);
+ Materialization() : invalidationTime(0) {
+ }
+
+ virtual ~Materialization() throw();
+ Table materializationTable;
+ std::set<std::string> tablesUsed;
+ int64_t invalidationTime;
+
+ void __set_materializationTable(const Table& val);
+
+ void __set_tablesUsed(const std::set<std::string> & val);
+
+ void __set_invalidationTime(const int64_t val);
+
+ bool operator == (const Materialization & rhs) const
+ {
+ if (!(materializationTable == rhs.materializationTable))
+ return false;
+ if (!(tablesUsed == rhs.tablesUsed))
+ return false;
+ if (!(invalidationTime == rhs.invalidationTime))
+ return false;
+ return true;
+ }
+ bool operator != (const Materialization &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Materialization & ) 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(Materialization &a, Materialization &b);
+
+inline std::ostream& operator<<(std::ostream& out, const Materialization& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
typedef struct _WMResourcePlan__isset {
_WMResourcePlan__isset() : status(false), queryParallelism(false), defaultPoolPath(false) {}
bool status :1;
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/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 0e5dbf7..398f8d4 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 _list548 = iprot.readListBegin();
- struct.txn_ids = new ArrayList<Long>(_list548.size);
- long _elem549;
- for (int _i550 = 0; _i550 < _list548.size; ++_i550)
+ org.apache.thrift.protocol.TList _list558 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list558.size);
+ long _elem559;
+ for (int _i560 = 0; _i560 < _list558.size; ++_i560)
{
- _elem549 = iprot.readI64();
- struct.txn_ids.add(_elem549);
+ _elem559 = iprot.readI64();
+ struct.txn_ids.add(_elem559);
}
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 _iter551 : struct.txn_ids)
+ for (long _iter561 : struct.txn_ids)
{
- oprot.writeI64(_iter551);
+ oprot.writeI64(_iter561);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txn_ids.size());
- for (long _iter552 : struct.txn_ids)
+ for (long _iter562 : struct.txn_ids)
{
- oprot.writeI64(_iter552);
+ oprot.writeI64(_iter562);
}
}
}
@@ -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 _list553 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txn_ids = new ArrayList<Long>(_list553.size);
- long _elem554;
- for (int _i555 = 0; _i555 < _list553.size; ++_i555)
+ org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list563.size);
+ long _elem564;
+ for (int _i565 = 0; _i565 < _list563.size; ++_i565)
{
- _elem554 = iprot.readI64();
- struct.txn_ids.add(_elem554);
+ _elem564 = iprot.readI64();
+ struct.txn_ids.add(_elem564);
}
}
struct.setTxn_idsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/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 dae233a..2102aa5 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
@@ -727,13 +727,13 @@ import org.slf4j.LoggerFactory;
case 4: // PARTITIONNAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list606 = iprot.readListBegin();
- struct.partitionnames = new ArrayList<String>(_list606.size);
- String _elem607;
- for (int _i608 = 0; _i608 < _list606.size; ++_i608)
+ org.apache.thrift.protocol.TList _list616 = iprot.readListBegin();
+ struct.partitionnames = new ArrayList<String>(_list616.size);
+ String _elem617;
+ for (int _i618 = 0; _i618 < _list616.size; ++_i618)
{
- _elem607 = iprot.readString();
- struct.partitionnames.add(_elem607);
+ _elem617 = iprot.readString();
+ struct.partitionnames.add(_elem617);
}
iprot.readListEnd();
}
@@ -780,9 +780,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 _iter609 : struct.partitionnames)
+ for (String _iter619 : struct.partitionnames)
{
- oprot.writeString(_iter609);
+ oprot.writeString(_iter619);
}
oprot.writeListEnd();
}
@@ -817,9 +817,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tablename);
{
oprot.writeI32(struct.partitionnames.size());
- for (String _iter610 : struct.partitionnames)
+ for (String _iter620 : struct.partitionnames)
{
- oprot.writeString(_iter610);
+ oprot.writeString(_iter620);
}
}
BitSet optionals = new BitSet();
@@ -842,13 +842,13 @@ import org.slf4j.LoggerFactory;
struct.tablename = iprot.readString();
struct.setTablenameIsSet(true);
{
- org.apache.thrift.protocol.TList _list611 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionnames = new ArrayList<String>(_list611.size);
- String _elem612;
- for (int _i613 = 0; _i613 < _list611.size; ++_i613)
+ org.apache.thrift.protocol.TList _list621 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionnames = new ArrayList<String>(_list621.size);
+ String _elem622;
+ for (int _i623 = 0; _i623 < _list621.size; ++_i623)
{
- _elem612 = iprot.readString();
- struct.partitionnames.add(_elem612);
+ _elem622 = iprot.readString();
+ struct.partitionnames.add(_elem622);
}
}
struct.setPartitionnamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
index c1c0dbf..a222529 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // FOREIGN_KEY_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list362 = iprot.readListBegin();
- struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list362.size);
- SQLForeignKey _elem363;
- for (int _i364 = 0; _i364 < _list362.size; ++_i364)
+ org.apache.thrift.protocol.TList _list372 = iprot.readListBegin();
+ struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list372.size);
+ SQLForeignKey _elem373;
+ for (int _i374 = 0; _i374 < _list372.size; ++_i374)
{
- _elem363 = new SQLForeignKey();
- _elem363.read(iprot);
- struct.foreignKeyCols.add(_elem363);
+ _elem373 = new SQLForeignKey();
+ _elem373.read(iprot);
+ struct.foreignKeyCols.add(_elem373);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FOREIGN_KEY_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.foreignKeyCols.size()));
- for (SQLForeignKey _iter365 : struct.foreignKeyCols)
+ for (SQLForeignKey _iter375 : struct.foreignKeyCols)
{
- _iter365.write(oprot);
+ _iter375.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.foreignKeyCols.size());
- for (SQLForeignKey _iter366 : struct.foreignKeyCols)
+ for (SQLForeignKey _iter376 : struct.foreignKeyCols)
{
- _iter366.write(oprot);
+ _iter376.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddForeignKeyRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list367 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list367.size);
- SQLForeignKey _elem368;
- for (int _i369 = 0; _i369 < _list367.size; ++_i369)
+ org.apache.thrift.protocol.TList _list377 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list377.size);
+ SQLForeignKey _elem378;
+ for (int _i379 = 0; _i379 < _list377.size; ++_i379)
{
- _elem368 = new SQLForeignKey();
- _elem368.read(iprot);
- struct.foreignKeyCols.add(_elem368);
+ _elem378 = new SQLForeignKey();
+ _elem378.read(iprot);
+ struct.foreignKeyCols.add(_elem378);
}
}
struct.setForeignKeyColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
index 0bd85f3..ef23d30 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // NOT_NULL_CONSTRAINT_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list378 = iprot.readListBegin();
- struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list378.size);
- SQLNotNullConstraint _elem379;
- for (int _i380 = 0; _i380 < _list378.size; ++_i380)
+ org.apache.thrift.protocol.TList _list388 = iprot.readListBegin();
+ struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list388.size);
+ SQLNotNullConstraint _elem389;
+ for (int _i390 = 0; _i390 < _list388.size; ++_i390)
{
- _elem379 = new SQLNotNullConstraint();
- _elem379.read(iprot);
- struct.notNullConstraintCols.add(_elem379);
+ _elem389 = new SQLNotNullConstraint();
+ _elem389.read(iprot);
+ struct.notNullConstraintCols.add(_elem389);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOT_NULL_CONSTRAINT_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.notNullConstraintCols.size()));
- for (SQLNotNullConstraint _iter381 : struct.notNullConstraintCols)
+ for (SQLNotNullConstraint _iter391 : struct.notNullConstraintCols)
{
- _iter381.write(oprot);
+ _iter391.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.notNullConstraintCols.size());
- for (SQLNotNullConstraint _iter382 : struct.notNullConstraintCols)
+ for (SQLNotNullConstraint _iter392 : struct.notNullConstraintCols)
{
- _iter382.write(oprot);
+ _iter392.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddNotNullConstraintRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list383 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list383.size);
- SQLNotNullConstraint _elem384;
- for (int _i385 = 0; _i385 < _list383.size; ++_i385)
+ org.apache.thrift.protocol.TList _list393 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list393.size);
+ SQLNotNullConstraint _elem394;
+ for (int _i395 = 0; _i395 < _list393.size; ++_i395)
{
- _elem384 = new SQLNotNullConstraint();
- _elem384.read(iprot);
- struct.notNullConstraintCols.add(_elem384);
+ _elem394 = new SQLNotNullConstraint();
+ _elem394.read(iprot);
+ struct.notNullConstraintCols.add(_elem394);
}
}
struct.setNotNullConstraintColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
index 9119336..13a2318 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
@@ -704,14 +704,14 @@ import org.slf4j.LoggerFactory;
case 3: // PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list452 = iprot.readListBegin();
- struct.parts = new ArrayList<Partition>(_list452.size);
- Partition _elem453;
- for (int _i454 = 0; _i454 < _list452.size; ++_i454)
+ org.apache.thrift.protocol.TList _list462 = iprot.readListBegin();
+ struct.parts = new ArrayList<Partition>(_list462.size);
+ Partition _elem463;
+ for (int _i464 = 0; _i464 < _list462.size; ++_i464)
{
- _elem453 = new Partition();
- _elem453.read(iprot);
- struct.parts.add(_elem453);
+ _elem463 = new Partition();
+ _elem463.read(iprot);
+ struct.parts.add(_elem463);
}
iprot.readListEnd();
}
@@ -763,9 +763,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.parts.size()));
- for (Partition _iter455 : struct.parts)
+ for (Partition _iter465 : struct.parts)
{
- _iter455.write(oprot);
+ _iter465.write(oprot);
}
oprot.writeListEnd();
}
@@ -800,9 +800,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.parts.size());
- for (Partition _iter456 : struct.parts)
+ for (Partition _iter466 : struct.parts)
{
- _iter456.write(oprot);
+ _iter466.write(oprot);
}
}
oprot.writeBool(struct.ifNotExists);
@@ -824,14 +824,14 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TList _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.parts = new ArrayList<Partition>(_list457.size);
- Partition _elem458;
- for (int _i459 = 0; _i459 < _list457.size; ++_i459)
+ org.apache.thrift.protocol.TList _list467 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.parts = new ArrayList<Partition>(_list467.size);
+ Partition _elem468;
+ for (int _i469 = 0; _i469 < _list467.size; ++_i469)
{
- _elem458 = new Partition();
- _elem458.read(iprot);
- struct.parts.add(_elem458);
+ _elem468 = new Partition();
+ _elem468.read(iprot);
+ struct.parts.add(_elem468);
}
}
struct.setPartsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
index 57d4953..49ce6e1 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
@@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory;
case 1: // PARTITIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list444 = iprot.readListBegin();
- struct.partitions = new ArrayList<Partition>(_list444.size);
- Partition _elem445;
- for (int _i446 = 0; _i446 < _list444.size; ++_i446)
+ org.apache.thrift.protocol.TList _list454 = iprot.readListBegin();
+ struct.partitions = new ArrayList<Partition>(_list454.size);
+ Partition _elem455;
+ for (int _i456 = 0; _i456 < _list454.size; ++_i456)
{
- _elem445 = new Partition();
- _elem445.read(iprot);
- struct.partitions.add(_elem445);
+ _elem455 = new Partition();
+ _elem455.read(iprot);
+ struct.partitions.add(_elem455);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size()));
- for (Partition _iter447 : struct.partitions)
+ for (Partition _iter457 : struct.partitions)
{
- _iter447.write(oprot);
+ _iter457.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitions()) {
{
oprot.writeI32(struct.partitions.size());
- for (Partition _iter448 : struct.partitions)
+ for (Partition _iter458 : struct.partitions)
{
- _iter448.write(oprot);
+ _iter458.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.partitions = new ArrayList<Partition>(_list449.size);
- Partition _elem450;
- for (int _i451 = 0; _i451 < _list449.size; ++_i451)
+ org.apache.thrift.protocol.TList _list459 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.partitions = new ArrayList<Partition>(_list459.size);
+ Partition _elem460;
+ for (int _i461 = 0; _i461 < _list459.size; ++_i461)
{
- _elem450 = new Partition();
- _elem450.read(iprot);
- struct.partitions.add(_elem450);
+ _elem460 = new Partition();
+ _elem460.read(iprot);
+ struct.partitions.add(_elem460);
}
}
struct.setPartitionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
index 900985b..478032a 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // PRIMARY_KEY_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list354 = iprot.readListBegin();
- struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list354.size);
- SQLPrimaryKey _elem355;
- for (int _i356 = 0; _i356 < _list354.size; ++_i356)
+ org.apache.thrift.protocol.TList _list364 = iprot.readListBegin();
+ struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list364.size);
+ SQLPrimaryKey _elem365;
+ for (int _i366 = 0; _i366 < _list364.size; ++_i366)
{
- _elem355 = new SQLPrimaryKey();
- _elem355.read(iprot);
- struct.primaryKeyCols.add(_elem355);
+ _elem365 = new SQLPrimaryKey();
+ _elem365.read(iprot);
+ struct.primaryKeyCols.add(_elem365);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PRIMARY_KEY_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.primaryKeyCols.size()));
- for (SQLPrimaryKey _iter357 : struct.primaryKeyCols)
+ for (SQLPrimaryKey _iter367 : struct.primaryKeyCols)
{
- _iter357.write(oprot);
+ _iter367.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.primaryKeyCols.size());
- for (SQLPrimaryKey _iter358 : struct.primaryKeyCols)
+ for (SQLPrimaryKey _iter368 : struct.primaryKeyCols)
{
- _iter358.write(oprot);
+ _iter368.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddPrimaryKeyRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list359 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list359.size);
- SQLPrimaryKey _elem360;
- for (int _i361 = 0; _i361 < _list359.size; ++_i361)
+ org.apache.thrift.protocol.TList _list369 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list369.size);
+ SQLPrimaryKey _elem370;
+ for (int _i371 = 0; _i371 < _list369.size; ++_i371)
{
- _elem360 = new SQLPrimaryKey();
- _elem360.read(iprot);
- struct.primaryKeyCols.add(_elem360);
+ _elem370 = new SQLPrimaryKey();
+ _elem370.read(iprot);
+ struct.primaryKeyCols.add(_elem370);
}
}
struct.setPrimaryKeyColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
index df4f544..b58f39f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // UNIQUE_CONSTRAINT_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list370 = iprot.readListBegin();
- struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list370.size);
- SQLUniqueConstraint _elem371;
- for (int _i372 = 0; _i372 < _list370.size; ++_i372)
+ org.apache.thrift.protocol.TList _list380 = iprot.readListBegin();
+ struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list380.size);
+ SQLUniqueConstraint _elem381;
+ for (int _i382 = 0; _i382 < _list380.size; ++_i382)
{
- _elem371 = new SQLUniqueConstraint();
- _elem371.read(iprot);
- struct.uniqueConstraintCols.add(_elem371);
+ _elem381 = new SQLUniqueConstraint();
+ _elem381.read(iprot);
+ struct.uniqueConstraintCols.add(_elem381);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(UNIQUE_CONSTRAINT_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraintCols.size()));
- for (SQLUniqueConstraint _iter373 : struct.uniqueConstraintCols)
+ for (SQLUniqueConstraint _iter383 : struct.uniqueConstraintCols)
{
- _iter373.write(oprot);
+ _iter383.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.uniqueConstraintCols.size());
- for (SQLUniqueConstraint _iter374 : struct.uniqueConstraintCols)
+ for (SQLUniqueConstraint _iter384 : struct.uniqueConstraintCols)
{
- _iter374.write(oprot);
+ _iter384.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddUniqueConstraintRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list375 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list375.size);
- SQLUniqueConstraint _elem376;
- for (int _i377 = 0; _i377 < _list375.size; ++_i377)
+ org.apache.thrift.protocol.TList _list385 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list385.size);
+ SQLUniqueConstraint _elem386;
+ for (int _i387 = 0; _i387 < _list385.size; ++_i387)
{
- _elem376 = new SQLUniqueConstraint();
- _elem376.read(iprot);
- struct.uniqueConstraintCols.add(_elem376);
+ _elem386 = new SQLUniqueConstraint();
+ _elem386.read(iprot);
+ struct.uniqueConstraintCols.add(_elem386);
}
}
struct.setUniqueConstraintColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
index c38c8c6..54ef01f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
@@ -439,14 +439,14 @@ import org.slf4j.LoggerFactory;
case 1: // COL_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list278 = iprot.readListBegin();
- struct.colStats = new ArrayList<ColumnStatisticsObj>(_list278.size);
- ColumnStatisticsObj _elem279;
- for (int _i280 = 0; _i280 < _list278.size; ++_i280)
+ org.apache.thrift.protocol.TList _list288 = iprot.readListBegin();
+ struct.colStats = new ArrayList<ColumnStatisticsObj>(_list288.size);
+ ColumnStatisticsObj _elem289;
+ for (int _i290 = 0; _i290 < _list288.size; ++_i290)
{
- _elem279 = new ColumnStatisticsObj();
- _elem279.read(iprot);
- struct.colStats.add(_elem279);
+ _elem289 = new ColumnStatisticsObj();
+ _elem289.read(iprot);
+ struct.colStats.add(_elem289);
}
iprot.readListEnd();
}
@@ -480,9 +480,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COL_STATS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.colStats.size()));
- for (ColumnStatisticsObj _iter281 : struct.colStats)
+ for (ColumnStatisticsObj _iter291 : struct.colStats)
{
- _iter281.write(oprot);
+ _iter291.write(oprot);
}
oprot.writeListEnd();
}
@@ -510,9 +510,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.colStats.size());
- for (ColumnStatisticsObj _iter282 : struct.colStats)
+ for (ColumnStatisticsObj _iter292 : struct.colStats)
{
- _iter282.write(oprot);
+ _iter292.write(oprot);
}
}
oprot.writeI64(struct.partsFound);
@@ -522,14 +522,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AggrStats struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list283 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.colStats = new ArrayList<ColumnStatisticsObj>(_list283.size);
- ColumnStatisticsObj _elem284;
- for (int _i285 = 0; _i285 < _list283.size; ++_i285)
+ org.apache.thrift.protocol.TList _list293 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.colStats = new ArrayList<ColumnStatisticsObj>(_list293.size);
+ ColumnStatisticsObj _elem294;
+ for (int _i295 = 0; _i295 < _list293.size; ++_i295)
{
- _elem284 = new ColumnStatisticsObj();
- _elem284.read(iprot);
- struct.colStats.add(_elem284);
+ _elem294 = new ColumnStatisticsObj();
+ _elem294.read(iprot);
+ struct.colStats.add(_elem294);
}
}
struct.setColStatsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BasicTxnInfo.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BasicTxnInfo.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BasicTxnInfo.java
new file mode 100644
index 0000000..f695e5d
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BasicTxnInfo.java
@@ -0,0 +1,1006 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class BasicTxnInfo implements org.apache.thrift.TBase<BasicTxnInfo, BasicTxnInfo._Fields>, java.io.Serializable, Cloneable, Comparable<BasicTxnInfo> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BasicTxnInfo");
+
+ private static final org.apache.thrift.protocol.TField ISNULL_FIELD_DESC = new org.apache.thrift.protocol.TField("isnull", org.apache.thrift.protocol.TType.BOOL, (short)1);
+ private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.I64, (short)2);
+ private static final org.apache.thrift.protocol.TField TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("time", org.apache.thrift.protocol.TType.I64, (short)3);
+ 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)4);
+ private static final org.apache.thrift.protocol.TField DBNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbname", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField TABLENAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tablename", org.apache.thrift.protocol.TType.STRING, (short)6);
+ private static final org.apache.thrift.protocol.TField PARTITIONNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionname", org.apache.thrift.protocol.TType.STRING, (short)7);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new BasicTxnInfoStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new BasicTxnInfoTupleSchemeFactory());
+ }
+
+ private boolean isnull; // required
+ private long id; // optional
+ private long time; // optional
+ private long txnid; // optional
+ private String dbname; // optional
+ private String tablename; // optional
+ private String partitionname; // 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 {
+ ISNULL((short)1, "isnull"),
+ ID((short)2, "id"),
+ TIME((short)3, "time"),
+ TXNID((short)4, "txnid"),
+ DBNAME((short)5, "dbname"),
+ TABLENAME((short)6, "tablename"),
+ PARTITIONNAME((short)7, "partitionname");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // ISNULL
+ return ISNULL;
+ case 2: // ID
+ return ID;
+ case 3: // TIME
+ return TIME;
+ case 4: // TXNID
+ return TXNID;
+ case 5: // DBNAME
+ return DBNAME;
+ case 6: // TABLENAME
+ return TABLENAME;
+ case 7: // PARTITIONNAME
+ return PARTITIONNAME;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ private static final int __ISNULL_ISSET_ID = 0;
+ private static final int __ID_ISSET_ID = 1;
+ private static final int __TIME_ISSET_ID = 2;
+ private static final int __TXNID_ISSET_ID = 3;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.ID,_Fields.TIME,_Fields.TXNID,_Fields.DBNAME,_Fields.TABLENAME,_Fields.PARTITIONNAME};
+ 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.ISNULL, new org.apache.thrift.meta_data.FieldMetaData("isnull", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.TIME, new org.apache.thrift.meta_data.FieldMetaData("time", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.TXNID, new org.apache.thrift.meta_data.FieldMetaData("txnid", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.DBNAME, new org.apache.thrift.meta_data.FieldMetaData("dbname", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TABLENAME, new org.apache.thrift.meta_data.FieldMetaData("tablename", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.PARTITIONNAME, new org.apache.thrift.meta_data.FieldMetaData("partitionname", 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(BasicTxnInfo.class, metaDataMap);
+ }
+
+ public BasicTxnInfo() {
+ }
+
+ public BasicTxnInfo(
+ boolean isnull)
+ {
+ this();
+ this.isnull = isnull;
+ setIsnullIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public BasicTxnInfo(BasicTxnInfo other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.isnull = other.isnull;
+ this.id = other.id;
+ this.time = other.time;
+ this.txnid = other.txnid;
+ if (other.isSetDbname()) {
+ this.dbname = other.dbname;
+ }
+ if (other.isSetTablename()) {
+ this.tablename = other.tablename;
+ }
+ if (other.isSetPartitionname()) {
+ this.partitionname = other.partitionname;
+ }
+ }
+
+ public BasicTxnInfo deepCopy() {
+ return new BasicTxnInfo(this);
+ }
+
+ @Override
+ public void clear() {
+ setIsnullIsSet(false);
+ this.isnull = false;
+ setIdIsSet(false);
+ this.id = 0;
+ setTimeIsSet(false);
+ this.time = 0;
+ setTxnidIsSet(false);
+ this.txnid = 0;
+ this.dbname = null;
+ this.tablename = null;
+ this.partitionname = null;
+ }
+
+ public boolean isIsnull() {
+ return this.isnull;
+ }
+
+ public void setIsnull(boolean isnull) {
+ this.isnull = isnull;
+ setIsnullIsSet(true);
+ }
+
+ public void unsetIsnull() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISNULL_ISSET_ID);
+ }
+
+ /** Returns true if field isnull is set (has been assigned a value) and false otherwise */
+ public boolean isSetIsnull() {
+ return EncodingUtils.testBit(__isset_bitfield, __ISNULL_ISSET_ID);
+ }
+
+ public void setIsnullIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISNULL_ISSET_ID, value);
+ }
+
+ public long getId() {
+ return this.id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ setIdIsSet(true);
+ }
+
+ public void unsetId() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ID_ISSET_ID);
+ }
+
+ /** Returns true if field id is set (has been assigned a value) and false otherwise */
+ public boolean isSetId() {
+ return EncodingUtils.testBit(__isset_bitfield, __ID_ISSET_ID);
+ }
+
+ public void setIdIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ID_ISSET_ID, value);
+ }
+
+ public long getTime() {
+ return this.time;
+ }
+
+ public void setTime(long time) {
+ this.time = time;
+ setTimeIsSet(true);
+ }
+
+ public void unsetTime() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIME_ISSET_ID);
+ }
+
+ /** Returns true if field time is set (has been assigned a value) and false otherwise */
+ public boolean isSetTime() {
+ return EncodingUtils.testBit(__isset_bitfield, __TIME_ISSET_ID);
+ }
+
+ public void setTimeIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIME_ISSET_ID, value);
+ }
+
+ public long getTxnid() {
+ return this.txnid;
+ }
+
+ public void setTxnid(long txnid) {
+ this.txnid = txnid;
+ setTxnidIsSet(true);
+ }
+
+ public void unsetTxnid() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TXNID_ISSET_ID);
+ }
+
+ /** Returns true if field txnid is set (has been assigned a value) and false otherwise */
+ public boolean isSetTxnid() {
+ return EncodingUtils.testBit(__isset_bitfield, __TXNID_ISSET_ID);
+ }
+
+ public void setTxnidIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXNID_ISSET_ID, value);
+ }
+
+ public String getDbname() {
+ return this.dbname;
+ }
+
+ public void setDbname(String dbname) {
+ this.dbname = dbname;
+ }
+
+ public void unsetDbname() {
+ this.dbname = null;
+ }
+
+ /** Returns true if field dbname is set (has been assigned a value) and false otherwise */
+ public boolean isSetDbname() {
+ return this.dbname != null;
+ }
+
+ public void setDbnameIsSet(boolean value) {
+ if (!value) {
+ this.dbname = null;
+ }
+ }
+
+ public String getTablename() {
+ return this.tablename;
+ }
+
+ public void setTablename(String tablename) {
+ this.tablename = tablename;
+ }
+
+ public void unsetTablename() {
+ this.tablename = null;
+ }
+
+ /** Returns true if field tablename is set (has been assigned a value) and false otherwise */
+ public boolean isSetTablename() {
+ return this.tablename != null;
+ }
+
+ public void setTablenameIsSet(boolean value) {
+ if (!value) {
+ this.tablename = null;
+ }
+ }
+
+ public String getPartitionname() {
+ return this.partitionname;
+ }
+
+ public void setPartitionname(String partitionname) {
+ this.partitionname = partitionname;
+ }
+
+ public void unsetPartitionname() {
+ this.partitionname = null;
+ }
+
+ /** Returns true if field partitionname is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartitionname() {
+ return this.partitionname != null;
+ }
+
+ public void setPartitionnameIsSet(boolean value) {
+ if (!value) {
+ this.partitionname = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case ISNULL:
+ if (value == null) {
+ unsetIsnull();
+ } else {
+ setIsnull((Boolean)value);
+ }
+ break;
+
+ case ID:
+ if (value == null) {
+ unsetId();
+ } else {
+ setId((Long)value);
+ }
+ break;
+
+ case TIME:
+ if (value == null) {
+ unsetTime();
+ } else {
+ setTime((Long)value);
+ }
+ break;
+
+ case TXNID:
+ if (value == null) {
+ unsetTxnid();
+ } else {
+ setTxnid((Long)value);
+ }
+ break;
+
+ case DBNAME:
+ if (value == null) {
+ unsetDbname();
+ } else {
+ setDbname((String)value);
+ }
+ break;
+
+ case TABLENAME:
+ if (value == null) {
+ unsetTablename();
+ } else {
+ setTablename((String)value);
+ }
+ break;
+
+ case PARTITIONNAME:
+ if (value == null) {
+ unsetPartitionname();
+ } else {
+ setPartitionname((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case ISNULL:
+ return isIsnull();
+
+ case ID:
+ return getId();
+
+ case TIME:
+ return getTime();
+
+ case TXNID:
+ return getTxnid();
+
+ case DBNAME:
+ return getDbname();
+
+ case TABLENAME:
+ return getTablename();
+
+ case PARTITIONNAME:
+ return getPartitionname();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case ISNULL:
+ return isSetIsnull();
+ case ID:
+ return isSetId();
+ case TIME:
+ return isSetTime();
+ case TXNID:
+ return isSetTxnid();
+ case DBNAME:
+ return isSetDbname();
+ case TABLENAME:
+ return isSetTablename();
+ case PARTITIONNAME:
+ return isSetPartitionname();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof BasicTxnInfo)
+ return this.equals((BasicTxnInfo)that);
+ return false;
+ }
+
+ public boolean equals(BasicTxnInfo that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_isnull = true;
+ boolean that_present_isnull = true;
+ if (this_present_isnull || that_present_isnull) {
+ if (!(this_present_isnull && that_present_isnull))
+ return false;
+ if (this.isnull != that.isnull)
+ return false;
+ }
+
+ boolean this_present_id = true && this.isSetId();
+ boolean that_present_id = true && that.isSetId();
+ if (this_present_id || that_present_id) {
+ if (!(this_present_id && that_present_id))
+ return false;
+ if (this.id != that.id)
+ return false;
+ }
+
+ boolean this_present_time = true && this.isSetTime();
+ boolean that_present_time = true && that.isSetTime();
+ if (this_present_time || that_present_time) {
+ if (!(this_present_time && that_present_time))
+ return false;
+ if (this.time != that.time)
+ return false;
+ }
+
+ boolean this_present_txnid = true && this.isSetTxnid();
+ boolean that_present_txnid = true && that.isSetTxnid();
+ if (this_present_txnid || that_present_txnid) {
+ if (!(this_present_txnid && that_present_txnid))
+ return false;
+ if (this.txnid != that.txnid)
+ return false;
+ }
+
+ boolean this_present_dbname = true && this.isSetDbname();
+ boolean that_present_dbname = true && that.isSetDbname();
+ if (this_present_dbname || that_present_dbname) {
+ if (!(this_present_dbname && that_present_dbname))
+ return false;
+ if (!this.dbname.equals(that.dbname))
+ return false;
+ }
+
+ boolean this_present_tablename = true && this.isSetTablename();
+ boolean that_present_tablename = true && that.isSetTablename();
+ if (this_present_tablename || that_present_tablename) {
+ if (!(this_present_tablename && that_present_tablename))
+ return false;
+ if (!this.tablename.equals(that.tablename))
+ return false;
+ }
+
+ boolean this_present_partitionname = true && this.isSetPartitionname();
+ boolean that_present_partitionname = true && that.isSetPartitionname();
+ if (this_present_partitionname || that_present_partitionname) {
+ if (!(this_present_partitionname && that_present_partitionname))
+ return false;
+ if (!this.partitionname.equals(that.partitionname))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_isnull = true;
+ list.add(present_isnull);
+ if (present_isnull)
+ list.add(isnull);
+
+ boolean present_id = true && (isSetId());
+ list.add(present_id);
+ if (present_id)
+ list.add(id);
+
+ boolean present_time = true && (isSetTime());
+ list.add(present_time);
+ if (present_time)
+ list.add(time);
+
+ boolean present_txnid = true && (isSetTxnid());
+ list.add(present_txnid);
+ if (present_txnid)
+ list.add(txnid);
+
+ boolean present_dbname = true && (isSetDbname());
+ list.add(present_dbname);
+ if (present_dbname)
+ list.add(dbname);
+
+ boolean present_tablename = true && (isSetTablename());
+ list.add(present_tablename);
+ if (present_tablename)
+ list.add(tablename);
+
+ boolean present_partitionname = true && (isSetPartitionname());
+ list.add(present_partitionname);
+ if (present_partitionname)
+ list.add(partitionname);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(BasicTxnInfo other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetIsnull()).compareTo(other.isSetIsnull());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetIsnull()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isnull, other.isnull);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetId()).compareTo(other.isSetId());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetId()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.id, other.id);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTime()).compareTo(other.isSetTime());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTime()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.time, other.time);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTxnid()).compareTo(other.isSetTxnid());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTxnid()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txnid, other.txnid);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetDbname()).compareTo(other.isSetDbname());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDbname()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dbname, other.dbname);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTablename()).compareTo(other.isSetTablename());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTablename()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablename, other.tablename);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartitionname()).compareTo(other.isSetPartitionname());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartitionname()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitionname, other.partitionname);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("BasicTxnInfo(");
+ boolean first = true;
+
+ sb.append("isnull:");
+ sb.append(this.isnull);
+ first = false;
+ if (isSetId()) {
+ if (!first) sb.append(", ");
+ sb.append("id:");
+ sb.append(this.id);
+ first = false;
+ }
+ if (isSetTime()) {
+ if (!first) sb.append(", ");
+ sb.append("time:");
+ sb.append(this.time);
+ first = false;
+ }
+ if (isSetTxnid()) {
+ if (!first) sb.append(", ");
+ sb.append("txnid:");
+ sb.append(this.txnid);
+ first = false;
+ }
+ if (isSetDbname()) {
+ if (!first) sb.append(", ");
+ sb.append("dbname:");
+ if (this.dbname == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbname);
+ }
+ first = false;
+ }
+ if (isSetTablename()) {
+ if (!first) sb.append(", ");
+ sb.append("tablename:");
+ if (this.tablename == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tablename);
+ }
+ first = false;
+ }
+ if (isSetPartitionname()) {
+ if (!first) sb.append(", ");
+ sb.append("partitionname:");
+ if (this.partitionname == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partitionname);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetIsnull()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'isnull' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class BasicTxnInfoStandardSchemeFactory implements SchemeFactory {
+ public BasicTxnInfoStandardScheme getScheme() {
+ return new BasicTxnInfoStandardScheme();
+ }
+ }
+
+ private static class BasicTxnInfoStandardScheme extends StandardScheme<BasicTxnInfo> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, BasicTxnInfo struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // ISNULL
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.isnull = iprot.readBool();
+ struct.setIsnullIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // ID
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.id = iprot.readI64();
+ struct.setIdIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // TIME
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.time = iprot.readI64();
+ struct.setTimeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // TXNID
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.txnid = iprot.readI64();
+ struct.setTxnidIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // DBNAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.dbname = iprot.readString();
+ struct.setDbnameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // TABLENAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.tablename = iprot.readString();
+ struct.setTablenameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // PARTITIONNAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.partitionname = iprot.readString();
+ struct.setPartitionnameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, BasicTxnInfo struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(ISNULL_FIELD_DESC);
+ oprot.writeBool(struct.isnull);
+ oprot.writeFieldEnd();
+ if (struct.isSetId()) {
+ oprot.writeFieldBegin(ID_FIELD_DESC);
+ oprot.writeI64(struct.id);
+ oprot.writeFieldEnd();
+ }
+ if (struct.isSetTime()) {
+ oprot.writeFieldBegin(TIME_FIELD_DESC);
+ oprot.writeI64(struct.time);
+ oprot.writeFieldEnd();
+ }
+ if (struct.isSetTxnid()) {
+ oprot.writeFieldBegin(TXNID_FIELD_DESC);
+ oprot.writeI64(struct.txnid);
+ oprot.writeFieldEnd();
+ }
+ if (struct.dbname != null) {
+ if (struct.isSetDbname()) {
+ oprot.writeFieldBegin(DBNAME_FIELD_DESC);
+ oprot.writeString(struct.dbname);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.tablename != null) {
+ if (struct.isSetTablename()) {
+ oprot.writeFieldBegin(TABLENAME_FIELD_DESC);
+ oprot.writeString(struct.tablename);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.partitionname != null) {
+ if (struct.isSetPartitionname()) {
+ oprot.writeFieldBegin(PARTITIONNAME_FIELD_DESC);
+ oprot.writeString(struct.partitionname);
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class BasicTxnInfoTupleSchemeFactory implements SchemeFactory {
+ public BasicTxnInfoTupleScheme getScheme() {
+ return new BasicTxnInfoTupleScheme();
+ }
+ }
+
+ private static class BasicTxnInfoTupleScheme extends TupleScheme<BasicTxnInfo> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, BasicTxnInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeBool(struct.isnull);
+ BitSet optionals = new BitSet();
+ if (struct.isSetId()) {
+ optionals.set(0);
+ }
+ if (struct.isSetTime()) {
+ optionals.set(1);
+ }
+ if (struct.isSetTxnid()) {
+ optionals.set(2);
+ }
+ if (struct.isSetDbname()) {
+ optionals.set(3);
+ }
+ if (struct.isSetTablename()) {
+ optionals.set(4);
+ }
+ if (struct.isSetPartitionname()) {
+ optionals.set(5);
+ }
+ oprot.writeBitSet(optionals, 6);
+ if (struct.isSetId()) {
+ oprot.writeI64(struct.id);
+ }
+ if (struct.isSetTime()) {
+ oprot.writeI64(struct.time);
+ }
+ if (struct.isSetTxnid()) {
+ oprot.writeI64(struct.txnid);
+ }
+ if (struct.isSetDbname()) {
+ oprot.writeString(struct.dbname);
+ }
+ if (struct.isSetTablename()) {
+ oprot.writeString(struct.tablename);
+ }
+ if (struct.isSetPartitionname()) {
+ oprot.writeString(struct.partitionname);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, BasicTxnInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.isnull = iprot.readBool();
+ struct.setIsnullIsSet(true);
+ BitSet incoming = iprot.readBitSet(6);
+ if (incoming.get(0)) {
+ struct.id = iprot.readI64();
+ struct.setIdIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.time = iprot.readI64();
+ struct.setTimeIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.txnid = iprot.readI64();
+ struct.setTxnidIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.dbname = iprot.readString();
+ struct.setDbnameIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.tablename = iprot.readString();
+ struct.setTablenameIsSet(true);
+ }
+ if (incoming.get(5)) {
+ struct.partitionname = iprot.readString();
+ struct.setPartitionnameIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/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 7773dc6..dbda2ab 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 _list698 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list698.size);
- long _elem699;
- for (int _i700 = 0; _i700 < _list698.size; ++_i700)
+ org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list716.size);
+ long _elem717;
+ for (int _i718 = 0; _i718 < _list716.size; ++_i718)
{
- _elem699 = iprot.readI64();
- struct.fileIds.add(_elem699);
+ _elem717 = iprot.readI64();
+ struct.fileIds.add(_elem717);
}
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 _iter701 : struct.fileIds)
+ for (long _iter719 : struct.fileIds)
{
- oprot.writeI64(_iter701);
+ oprot.writeI64(_iter719);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter702 : struct.fileIds)
+ for (long _iter720 : struct.fileIds)
{
- oprot.writeI64(_iter702);
+ oprot.writeI64(_iter720);
}
}
}
@@ -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 _list703 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list703.size);
- long _elem704;
- for (int _i705 = 0; _i705 < _list703.size; ++_i705)
+ org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list721.size);
+ long _elem722;
+ for (int _i723 = 0; _i723 < _list721.size; ++_i723)
{
- _elem704 = iprot.readI64();
- struct.fileIds.add(_elem704);
+ _elem722 = iprot.readI64();
+ struct.fileIds.add(_elem722);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/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 1941065..0df33f1 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 _list714 = iprot.readListBegin();
- struct.values = new ArrayList<ClientCapability>(_list714.size);
- ClientCapability _elem715;
- for (int _i716 = 0; _i716 < _list714.size; ++_i716)
+ org.apache.thrift.protocol.TList _list732 = iprot.readListBegin();
+ struct.values = new ArrayList<ClientCapability>(_list732.size);
+ ClientCapability _elem733;
+ for (int _i734 = 0; _i734 < _list732.size; ++_i734)
{
- _elem715 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem715);
+ _elem733 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem733);
}
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 _iter717 : struct.values)
+ for (ClientCapability _iter735 : struct.values)
{
- oprot.writeI32(_iter717.getValue());
+ oprot.writeI32(_iter735.getValue());
}
oprot.writeListEnd();
}
@@ -413,9 +413,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.values.size());
- for (ClientCapability _iter718 : struct.values)
+ for (ClientCapability _iter736 : struct.values)
{
- oprot.writeI32(_iter718.getValue());
+ oprot.writeI32(_iter736.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 _list719 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.values = new ArrayList<ClientCapability>(_list719.size);
- ClientCapability _elem720;
- for (int _i721 = 0; _i721 < _list719.size; ++_i721)
+ org.apache.thrift.protocol.TList _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.values = new ArrayList<ClientCapability>(_list737.size);
+ ClientCapability _elem738;
+ for (int _i739 = 0; _i739 < _list737.size; ++_i739)
{
- _elem720 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem720);
+ _elem738 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem738);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/57d909c3/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
index 765889e..962bb1c 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
@@ -451,14 +451,14 @@ import org.slf4j.LoggerFactory;
case 2: // STATS_OBJ
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list270 = iprot.readListBegin();
- struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list270.size);
- ColumnStatisticsObj _elem271;
- for (int _i272 = 0; _i272 < _list270.size; ++_i272)
+ org.apache.thrift.protocol.TList _list280 = iprot.readListBegin();
+ struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list280.size);
+ ColumnStatisticsObj _elem281;
+ for (int _i282 = 0; _i282 < _list280.size; ++_i282)
{
- _elem271 = new ColumnStatisticsObj();
- _elem271.read(iprot);
- struct.statsObj.add(_elem271);
+ _elem281 = new ColumnStatisticsObj();
+ _elem281.read(iprot);
+ struct.statsObj.add(_elem281);
}
iprot.readListEnd();
}
@@ -489,9 +489,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(STATS_OBJ_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.statsObj.size()));
- for (ColumnStatisticsObj _iter273 : struct.statsObj)
+ for (ColumnStatisticsObj _iter283 : struct.statsObj)
{
- _iter273.write(oprot);
+ _iter283.write(oprot);
}
oprot.writeListEnd();
}
@@ -517,9 +517,9 @@ import org.slf4j.LoggerFactory;
struct.statsDesc.write(oprot);
{
oprot.writeI32(struct.statsObj.size());
- for (ColumnStatisticsObj _iter274 : struct.statsObj)
+ for (ColumnStatisticsObj _iter284 : struct.statsObj)
{
- _iter274.write(oprot);
+ _iter284.write(oprot);
}
}
}
@@ -531,14 +531,14 @@ import org.slf4j.LoggerFactory;
struct.statsDesc.read(iprot);
struct.setStatsDescIsSet(true);
{
- org.apache.thrift.protocol.TList _list275 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list275.size);
- ColumnStatisticsObj _elem276;
- for (int _i277 = 0; _i277 < _list275.size; ++_i277)
+ org.apache.thrift.protocol.TList _list285 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list285.size);
+ ColumnStatisticsObj _elem286;
+ for (int _i287 = 0; _i287 < _list285.size; ++_i287)
{
- _elem276 = new ColumnStatisticsObj();
- _elem276.read(iprot);
- struct.statsObj.add(_elem276);
+ _elem286 = new ColumnStatisticsObj();
+ _elem286.read(iprot);
+ struct.statsObj.add(_elem286);
}
}
struct.setStatsObjIsSet(true);