You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2012/11/08 10:44:29 UTC
svn commit: r1406984 [5/29] - in /hive/trunk:
contrib/src/java/org/apache/hadoop/hive/contrib/genericudf/example/
contrib/src/java/org/apache/hadoop/hive/contrib/serde2/
contrib/src/java/org/apache/hadoop/hive/contrib/util/typedbytes/
contrib/src/test/...
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h Thu Nov 8 09:44:19 2012
@@ -1,15 +1,16 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
*/
#ifndef hive_metastore_TYPES_H
#define hive_metastore_TYPES_H
-#include <Thrift.h>
-#include <TApplicationException.h>
-#include <protocol/TProtocol.h>
-#include <transport/TTransport.h>
+#include <thrift/Thrift.h>
+#include <thrift/TApplicationException.h>
+#include <thrift/protocol/TProtocol.h>
+#include <thrift/transport/TTransport.h>
#include "fb303_types.h"
@@ -58,7 +59,7 @@ class Version {
static const char* ascii_fingerprint; // = "07A9615F837F7D0A952B595DD3020972";
static const uint8_t binary_fingerprint[16]; // = {0x07,0xA9,0x61,0x5F,0x83,0x7F,0x7D,0x0A,0x95,0x2B,0x59,0x5D,0xD3,0x02,0x09,0x72};
- Version() : version(""), comments("") {
+ Version() : version(), comments() {
}
virtual ~Version() throw() {}
@@ -95,6 +96,8 @@ class Version {
};
+void swap(Version &a, Version &b);
+
typedef struct _FieldSchema__isset {
_FieldSchema__isset() : name(false), type(false), comment(false) {}
bool name;
@@ -108,7 +111,7 @@ class FieldSchema {
static const char* ascii_fingerprint; // = "AB879940BD15B6B25691265F7384B271";
static const uint8_t binary_fingerprint[16]; // = {0xAB,0x87,0x99,0x40,0xBD,0x15,0xB6,0xB2,0x56,0x91,0x26,0x5F,0x73,0x84,0xB2,0x71};
- FieldSchema() : name(""), type(""), comment("") {
+ FieldSchema() : name(), type(), comment() {
}
virtual ~FieldSchema() throw() {}
@@ -152,6 +155,8 @@ class FieldSchema {
};
+void swap(FieldSchema &a, FieldSchema &b);
+
typedef struct _Type__isset {
_Type__isset() : name(false), type1(false), type2(false), fields(false) {}
bool name;
@@ -166,7 +171,7 @@ class Type {
static const char* ascii_fingerprint; // = "20DF02DE523C27F7066C7BD4D9120842";
static const uint8_t binary_fingerprint[16]; // = {0x20,0xDF,0x02,0xDE,0x52,0x3C,0x27,0xF7,0x06,0x6C,0x7B,0xD4,0xD9,0x12,0x08,0x42};
- Type() : name(""), type1(""), type2("") {
+ Type() : name(), type1(), type2() {
}
virtual ~Type() throw() {}
@@ -226,6 +231,8 @@ class Type {
};
+void swap(Type &a, Type &b);
+
typedef struct _HiveObjectRef__isset {
_HiveObjectRef__isset() : objectType(false), dbName(false), objectName(false), partValues(false), columnName(false) {}
bool objectType;
@@ -241,7 +248,7 @@ class HiveObjectRef {
static const char* ascii_fingerprint; // = "205CD8311CF3AA9EC161BAEF8D7C933C";
static const uint8_t binary_fingerprint[16]; // = {0x20,0x5C,0xD8,0x31,0x1C,0xF3,0xAA,0x9E,0xC1,0x61,0xBA,0xEF,0x8D,0x7C,0x93,0x3C};
- HiveObjectRef() : dbName(""), objectName(""), columnName("") {
+ HiveObjectRef() : objectType((HiveObjectType::type)0), dbName(), objectName(), columnName() {
}
virtual ~HiveObjectRef() throw() {}
@@ -299,6 +306,8 @@ class HiveObjectRef {
};
+void swap(HiveObjectRef &a, HiveObjectRef &b);
+
typedef struct _PrivilegeGrantInfo__isset {
_PrivilegeGrantInfo__isset() : privilege(false), createTime(false), grantor(false), grantorType(false), grantOption(false) {}
bool privilege;
@@ -314,7 +323,7 @@ class PrivilegeGrantInfo {
static const char* ascii_fingerprint; // = "A58923AF7294BE492D6F90E07E8CEE1F";
static const uint8_t binary_fingerprint[16]; // = {0xA5,0x89,0x23,0xAF,0x72,0x94,0xBE,0x49,0x2D,0x6F,0x90,0xE0,0x7E,0x8C,0xEE,0x1F};
- PrivilegeGrantInfo() : privilege(""), createTime(0), grantor(""), grantOption(0) {
+ PrivilegeGrantInfo() : privilege(), createTime(0), grantor(), grantorType((PrincipalType::type)0), grantOption(0) {
}
virtual ~PrivilegeGrantInfo() throw() {}
@@ -372,6 +381,8 @@ class PrivilegeGrantInfo {
};
+void swap(PrivilegeGrantInfo &a, PrivilegeGrantInfo &b);
+
typedef struct _HiveObjectPrivilege__isset {
_HiveObjectPrivilege__isset() : hiveObject(false), principalName(false), principalType(false), grantInfo(false) {}
bool hiveObject;
@@ -386,7 +397,7 @@ class HiveObjectPrivilege {
static const char* ascii_fingerprint; // = "83D71969B23BD853E29DBA9D43B29AF8";
static const uint8_t binary_fingerprint[16]; // = {0x83,0xD7,0x19,0x69,0xB2,0x3B,0xD8,0x53,0xE2,0x9D,0xBA,0x9D,0x43,0xB2,0x9A,0xF8};
- HiveObjectPrivilege() : principalName("") {
+ HiveObjectPrivilege() : principalName(), principalType((PrincipalType::type)0) {
}
virtual ~HiveObjectPrivilege() throw() {}
@@ -437,6 +448,8 @@ class HiveObjectPrivilege {
};
+void swap(HiveObjectPrivilege &a, HiveObjectPrivilege &b);
+
typedef struct _PrivilegeBag__isset {
_PrivilegeBag__isset() : privileges(false) {}
bool privileges;
@@ -478,6 +491,8 @@ class PrivilegeBag {
};
+void swap(PrivilegeBag &a, PrivilegeBag &b);
+
typedef struct _PrincipalPrivilegeSet__isset {
_PrincipalPrivilegeSet__isset() : userPrivileges(false), groupPrivileges(false), rolePrivileges(false) {}
bool userPrivileges;
@@ -535,6 +550,8 @@ class PrincipalPrivilegeSet {
};
+void swap(PrincipalPrivilegeSet &a, PrincipalPrivilegeSet &b);
+
typedef struct _Role__isset {
_Role__isset() : roleName(false), createTime(false), ownerName(false) {}
bool roleName;
@@ -548,7 +565,7 @@ class Role {
static const char* ascii_fingerprint; // = "70563A0628F75DF9555F4D24690B1E26";
static const uint8_t binary_fingerprint[16]; // = {0x70,0x56,0x3A,0x06,0x28,0xF7,0x5D,0xF9,0x55,0x5F,0x4D,0x24,0x69,0x0B,0x1E,0x26};
- Role() : roleName(""), createTime(0), ownerName("") {
+ Role() : roleName(), createTime(0), ownerName() {
}
virtual ~Role() throw() {}
@@ -592,6 +609,8 @@ class Role {
};
+void swap(Role &a, Role &b);
+
typedef struct _Database__isset {
_Database__isset() : name(false), description(false), locationUri(false), parameters(false), privileges(false) {}
bool name;
@@ -607,7 +626,7 @@ class Database {
static const char* ascii_fingerprint; // = "213967572143E49C9F1A23F7A866E2F5";
static const uint8_t binary_fingerprint[16]; // = {0x21,0x39,0x67,0x57,0x21,0x43,0xE4,0x9C,0x9F,0x1A,0x23,0xF7,0xA8,0x66,0xE2,0xF5};
- Database() : name(""), description(""), locationUri("") {
+ Database() : name(), description(), locationUri() {
}
virtual ~Database() throw() {}
@@ -668,6 +687,8 @@ class Database {
};
+void swap(Database &a, Database &b);
+
typedef struct _SerDeInfo__isset {
_SerDeInfo__isset() : name(false), serializationLib(false), parameters(false) {}
bool name;
@@ -681,7 +702,7 @@ class SerDeInfo {
static const char* ascii_fingerprint; // = "B1021C32A35A2AEFCD2F57A5424159A7";
static const uint8_t binary_fingerprint[16]; // = {0xB1,0x02,0x1C,0x32,0xA3,0x5A,0x2A,0xEF,0xCD,0x2F,0x57,0xA5,0x42,0x41,0x59,0xA7};
- SerDeInfo() : name(""), serializationLib("") {
+ SerDeInfo() : name(), serializationLib() {
}
virtual ~SerDeInfo() throw() {}
@@ -725,6 +746,8 @@ class SerDeInfo {
};
+void swap(SerDeInfo &a, SerDeInfo &b);
+
typedef struct _Order__isset {
_Order__isset() : col(false), order(false) {}
bool col;
@@ -737,7 +760,7 @@ class Order {
static const char* ascii_fingerprint; // = "EEBC915CE44901401D881E6091423036";
static const uint8_t binary_fingerprint[16]; // = {0xEE,0xBC,0x91,0x5C,0xE4,0x49,0x01,0x40,0x1D,0x88,0x1E,0x60,0x91,0x42,0x30,0x36};
- Order() : col(""), order(0) {
+ Order() : col(), order(0) {
}
virtual ~Order() throw() {}
@@ -774,6 +797,8 @@ class Order {
};
+void swap(Order &a, Order &b);
+
typedef struct _SkewedInfo__isset {
_SkewedInfo__isset() : skewedColNames(false), skewedColValues(false), skewedColValueLocationMaps(false) {}
bool skewedColNames;
@@ -831,6 +856,8 @@ class SkewedInfo {
};
+void swap(SkewedInfo &a, SkewedInfo &b);
+
typedef struct _StorageDescriptor__isset {
_StorageDescriptor__isset() : cols(false), location(false), inputFormat(false), outputFormat(false), compressed(false), numBuckets(false), serdeInfo(false), bucketCols(false), sortCols(false), parameters(false), skewedInfo(false) {}
bool cols;
@@ -852,7 +879,7 @@ class StorageDescriptor {
static const char* ascii_fingerprint; // = "BDC4DB93B74677CE1C04198D60E6CB80";
static const uint8_t binary_fingerprint[16]; // = {0xBD,0xC4,0xDB,0x93,0xB7,0x46,0x77,0xCE,0x1C,0x04,0x19,0x8D,0x60,0xE6,0xCB,0x80};
- StorageDescriptor() : location(""), inputFormat(""), outputFormat(""), compressed(0), numBuckets(0) {
+ StorageDescriptor() : location(), inputFormat(), outputFormat(), compressed(0), numBuckets(0) {
}
virtual ~StorageDescriptor() throw() {}
@@ -955,6 +982,8 @@ class StorageDescriptor {
};
+void swap(StorageDescriptor &a, StorageDescriptor &b);
+
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) {}
bool tableName;
@@ -978,7 +1007,7 @@ class Table {
static const char* ascii_fingerprint; // = "F21F7F0ACA98ECCFC83F6605440D007F";
static const uint8_t binary_fingerprint[16]; // = {0xF2,0x1F,0x7F,0x0A,0xCA,0x98,0xEC,0xCF,0xC8,0x3F,0x66,0x05,0x44,0x0D,0x00,0x7F};
- Table() : tableName(""), dbName(""), owner(""), createTime(0), lastAccessTime(0), retention(0), viewOriginalText(""), viewExpandedText(""), tableType("") {
+ Table() : tableName(), dbName(), owner(), createTime(0), lastAccessTime(0), retention(0), viewOriginalText(), viewExpandedText(), tableType() {
}
virtual ~Table() throw() {}
@@ -1095,6 +1124,8 @@ class Table {
};
+void swap(Table &a, Table &b);
+
typedef struct _Partition__isset {
_Partition__isset() : values(false), dbName(false), tableName(false), createTime(false), lastAccessTime(false), sd(false), parameters(false), privileges(false) {}
bool values;
@@ -1113,7 +1144,7 @@ class Partition {
static const char* ascii_fingerprint; // = "E5EF1F030CF964C052658DD22257D025";
static const uint8_t binary_fingerprint[16]; // = {0xE5,0xEF,0x1F,0x03,0x0C,0xF9,0x64,0xC0,0x52,0x65,0x8D,0xD2,0x22,0x57,0xD0,0x25};
- Partition() : dbName(""), tableName(""), createTime(0), lastAccessTime(0) {
+ Partition() : dbName(), tableName(), createTime(0), lastAccessTime(0) {
}
virtual ~Partition() throw() {}
@@ -1195,6 +1226,8 @@ class Partition {
};
+void swap(Partition &a, Partition &b);
+
typedef struct _Index__isset {
_Index__isset() : indexName(false), indexHandlerClass(false), dbName(false), origTableName(false), createTime(false), lastAccessTime(false), indexTableName(false), sd(false), parameters(false), deferredRebuild(false) {}
bool indexName;
@@ -1215,7 +1248,7 @@ class Index {
static const char* ascii_fingerprint; // = "BA1090E838C806A4F8D8D137C5085EDD";
static const uint8_t binary_fingerprint[16]; // = {0xBA,0x10,0x90,0xE8,0x38,0xC8,0x06,0xA4,0xF8,0xD8,0xD1,0x37,0xC5,0x08,0x5E,0xDD};
- Index() : indexName(""), indexHandlerClass(""), dbName(""), origTableName(""), createTime(0), lastAccessTime(0), indexTableName(""), deferredRebuild(0) {
+ Index() : indexName(), indexHandlerClass(), dbName(), origTableName(), createTime(0), lastAccessTime(0), indexTableName(), deferredRebuild(0) {
}
virtual ~Index() throw() {}
@@ -1308,6 +1341,8 @@ class Index {
};
+void swap(Index &a, Index &b);
+
class BooleanColumnStatsData {
public:
@@ -1357,6 +1392,8 @@ class BooleanColumnStatsData {
};
+void swap(BooleanColumnStatsData &a, BooleanColumnStatsData &b);
+
class DoubleColumnStatsData {
public:
@@ -1413,6 +1450,8 @@ class DoubleColumnStatsData {
};
+void swap(DoubleColumnStatsData &a, DoubleColumnStatsData &b);
+
class LongColumnStatsData {
public:
@@ -1469,6 +1508,8 @@ class LongColumnStatsData {
};
+void swap(LongColumnStatsData &a, LongColumnStatsData &b);
+
class StringColumnStatsData {
public:
@@ -1525,6 +1566,8 @@ class StringColumnStatsData {
};
+void swap(StringColumnStatsData &a, StringColumnStatsData &b);
+
class BinaryColumnStatsData {
public:
@@ -1574,6 +1617,8 @@ class BinaryColumnStatsData {
};
+void swap(BinaryColumnStatsData &a, BinaryColumnStatsData &b);
+
typedef struct _ColumnStatisticsData__isset {
_ColumnStatisticsData__isset() : booleanStats(false), longStats(false), doubleStats(false), stringStats(false), binaryStats(false) {}
bool booleanStats;
@@ -1647,6 +1692,8 @@ class ColumnStatisticsData {
};
+void swap(ColumnStatisticsData &a, ColumnStatisticsData &b);
+
class ColumnStatisticsObj {
public:
@@ -1654,7 +1701,7 @@ class ColumnStatisticsObj {
static const char* ascii_fingerprint; // = "DEE09584C51BCAF60824FE4509B59567";
static const uint8_t binary_fingerprint[16]; // = {0xDE,0xE0,0x95,0x84,0xC5,0x1B,0xCA,0xF6,0x08,0x24,0xFE,0x45,0x09,0xB5,0x95,0x67};
- ColumnStatisticsObj() : colName(""), colType("") {
+ ColumnStatisticsObj() : colName(), colType() {
}
virtual ~ColumnStatisticsObj() throw() {}
@@ -1696,6 +1743,8 @@ class ColumnStatisticsObj {
};
+void swap(ColumnStatisticsObj &a, ColumnStatisticsObj &b);
+
typedef struct _ColumnStatisticsDesc__isset {
_ColumnStatisticsDesc__isset() : partName(false), lastAnalyzed(false) {}
bool partName;
@@ -1708,7 +1757,7 @@ class ColumnStatisticsDesc {
static const char* ascii_fingerprint; // = "261759FF6F8FAB53F941453007FE18CB";
static const uint8_t binary_fingerprint[16]; // = {0x26,0x17,0x59,0xFF,0x6F,0x8F,0xAB,0x53,0xF9,0x41,0x45,0x30,0x07,0xFE,0x18,0xCB};
- ColumnStatisticsDesc() : isTblLevel(0), dbName(""), tableName(""), partName(""), lastAnalyzed(0) {
+ ColumnStatisticsDesc() : isTblLevel(0), dbName(), tableName(), partName(), lastAnalyzed(0) {
}
virtual ~ColumnStatisticsDesc() throw() {}
@@ -1772,6 +1821,8 @@ class ColumnStatisticsDesc {
};
+void swap(ColumnStatisticsDesc &a, ColumnStatisticsDesc &b);
+
class ColumnStatistics {
public:
@@ -1814,6 +1865,8 @@ class ColumnStatistics {
};
+void swap(ColumnStatistics &a, ColumnStatistics &b);
+
typedef struct _Schema__isset {
_Schema__isset() : fieldSchemas(false), properties(false) {}
bool fieldSchemas;
@@ -1863,6 +1916,8 @@ class Schema {
};
+void swap(Schema &a, Schema &b);
+
typedef struct _EnvironmentContext__isset {
_EnvironmentContext__isset() : properties(false) {}
bool properties;
@@ -1904,6 +1959,8 @@ class EnvironmentContext {
};
+void swap(EnvironmentContext &a, EnvironmentContext &b);
+
typedef struct _MetaException__isset {
_MetaException__isset() : message(false) {}
bool message;
@@ -1915,7 +1972,7 @@ class MetaException : public ::apache::t
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- MetaException() : message("") {
+ MetaException() : message() {
}
virtual ~MetaException() throw() {}
@@ -1945,6 +2002,8 @@ class MetaException : public ::apache::t
};
+void swap(MetaException &a, MetaException &b);
+
typedef struct _UnknownTableException__isset {
_UnknownTableException__isset() : message(false) {}
bool message;
@@ -1956,7 +2015,7 @@ class UnknownTableException : public ::a
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- UnknownTableException() : message("") {
+ UnknownTableException() : message() {
}
virtual ~UnknownTableException() throw() {}
@@ -1986,6 +2045,8 @@ class UnknownTableException : public ::a
};
+void swap(UnknownTableException &a, UnknownTableException &b);
+
typedef struct _UnknownDBException__isset {
_UnknownDBException__isset() : message(false) {}
bool message;
@@ -1997,7 +2058,7 @@ class UnknownDBException : public ::apac
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- UnknownDBException() : message("") {
+ UnknownDBException() : message() {
}
virtual ~UnknownDBException() throw() {}
@@ -2027,6 +2088,8 @@ class UnknownDBException : public ::apac
};
+void swap(UnknownDBException &a, UnknownDBException &b);
+
typedef struct _AlreadyExistsException__isset {
_AlreadyExistsException__isset() : message(false) {}
bool message;
@@ -2038,7 +2101,7 @@ class AlreadyExistsException : public ::
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- AlreadyExistsException() : message("") {
+ AlreadyExistsException() : message() {
}
virtual ~AlreadyExistsException() throw() {}
@@ -2068,6 +2131,8 @@ class AlreadyExistsException : public ::
};
+void swap(AlreadyExistsException &a, AlreadyExistsException &b);
+
typedef struct _InvalidPartitionException__isset {
_InvalidPartitionException__isset() : message(false) {}
bool message;
@@ -2079,7 +2144,7 @@ class InvalidPartitionException : public
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- InvalidPartitionException() : message("") {
+ InvalidPartitionException() : message() {
}
virtual ~InvalidPartitionException() throw() {}
@@ -2109,6 +2174,8 @@ class InvalidPartitionException : public
};
+void swap(InvalidPartitionException &a, InvalidPartitionException &b);
+
typedef struct _UnknownPartitionException__isset {
_UnknownPartitionException__isset() : message(false) {}
bool message;
@@ -2120,7 +2187,7 @@ class UnknownPartitionException : public
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- UnknownPartitionException() : message("") {
+ UnknownPartitionException() : message() {
}
virtual ~UnknownPartitionException() throw() {}
@@ -2150,6 +2217,8 @@ class UnknownPartitionException : public
};
+void swap(UnknownPartitionException &a, UnknownPartitionException &b);
+
typedef struct _InvalidObjectException__isset {
_InvalidObjectException__isset() : message(false) {}
bool message;
@@ -2161,7 +2230,7 @@ class InvalidObjectException : public ::
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- InvalidObjectException() : message("") {
+ InvalidObjectException() : message() {
}
virtual ~InvalidObjectException() throw() {}
@@ -2191,6 +2260,8 @@ class InvalidObjectException : public ::
};
+void swap(InvalidObjectException &a, InvalidObjectException &b);
+
typedef struct _NoSuchObjectException__isset {
_NoSuchObjectException__isset() : message(false) {}
bool message;
@@ -2202,7 +2273,7 @@ class NoSuchObjectException : public ::a
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- NoSuchObjectException() : message("") {
+ NoSuchObjectException() : message() {
}
virtual ~NoSuchObjectException() throw() {}
@@ -2232,6 +2303,8 @@ class NoSuchObjectException : public ::a
};
+void swap(NoSuchObjectException &a, NoSuchObjectException &b);
+
typedef struct _IndexAlreadyExistsException__isset {
_IndexAlreadyExistsException__isset() : message(false) {}
bool message;
@@ -2243,7 +2316,7 @@ class IndexAlreadyExistsException : publ
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- IndexAlreadyExistsException() : message("") {
+ IndexAlreadyExistsException() : message() {
}
virtual ~IndexAlreadyExistsException() throw() {}
@@ -2273,6 +2346,8 @@ class IndexAlreadyExistsException : publ
};
+void swap(IndexAlreadyExistsException &a, IndexAlreadyExistsException &b);
+
typedef struct _InvalidOperationException__isset {
_InvalidOperationException__isset() : message(false) {}
bool message;
@@ -2284,7 +2359,7 @@ class InvalidOperationException : public
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- InvalidOperationException() : message("") {
+ InvalidOperationException() : message() {
}
virtual ~InvalidOperationException() throw() {}
@@ -2314,6 +2389,8 @@ class InvalidOperationException : public
};
+void swap(InvalidOperationException &a, InvalidOperationException &b);
+
typedef struct _ConfigValSecurityException__isset {
_ConfigValSecurityException__isset() : message(false) {}
bool message;
@@ -2325,7 +2402,7 @@ class ConfigValSecurityException : publi
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- ConfigValSecurityException() : message("") {
+ ConfigValSecurityException() : message() {
}
virtual ~ConfigValSecurityException() throw() {}
@@ -2355,6 +2432,8 @@ class ConfigValSecurityException : publi
};
+void swap(ConfigValSecurityException &a, ConfigValSecurityException &b);
+
typedef struct _InvalidInputException__isset {
_InvalidInputException__isset() : message(false) {}
bool message;
@@ -2366,7 +2445,7 @@ class InvalidInputException : public ::a
static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1";
static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1};
- InvalidInputException() : message("") {
+ InvalidInputException() : message() {
}
virtual ~InvalidInputException() throw() {}
@@ -2396,6 +2475,8 @@ class InvalidInputException : public ::a
};
+void swap(InvalidInputException &a, InvalidInputException &b);
+
}}} // namespace
#endif
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -21,11 +31,17 @@ import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class AlreadyExistsException extends Exception implements org.apache.thrift.TBase<AlreadyExistsException, AlreadyExistsException._Fields>, java.io.Serializable, Cloneable {
+public class AlreadyExistsException extends TException implements org.apache.thrift.TBase<AlreadyExistsException, AlreadyExistsException._Fields>, java.io.Serializable, Cloneable {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyExistsException");
private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new AlreadyExistsExceptionStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new AlreadyExistsExceptionTupleSchemeFactory());
+ }
+
private String message; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -87,7 +103,6 @@ public class AlreadyExistsException exte
}
// isset id assignments
-
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);
@@ -246,42 +261,11 @@ public class AlreadyExistsException exte
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // MESSAGE
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.message = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.message != null) {
- oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
- oprot.writeString(this.message);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -302,6 +286,7 @@ public class AlreadyExistsException exte
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -320,5 +305,87 @@ public class AlreadyExistsException exte
}
}
+ private static class AlreadyExistsExceptionStandardSchemeFactory implements SchemeFactory {
+ public AlreadyExistsExceptionStandardScheme getScheme() {
+ return new AlreadyExistsExceptionStandardScheme();
+ }
+ }
+
+ private static class AlreadyExistsExceptionStandardScheme extends StandardScheme<AlreadyExistsException> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, AlreadyExistsException 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: // MESSAGE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.message = iprot.readString();
+ struct.setMessageIsSet(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, AlreadyExistsException struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.message != null) {
+ oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
+ oprot.writeString(struct.message);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class AlreadyExistsExceptionTupleSchemeFactory implements SchemeFactory {
+ public AlreadyExistsExceptionTupleScheme getScheme() {
+ return new AlreadyExistsExceptionTupleScheme();
+ }
+ }
+
+ private static class AlreadyExistsExceptionTupleScheme extends TupleScheme<AlreadyExistsException> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, AlreadyExistsException struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetMessage()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetMessage()) {
+ oprot.writeString(struct.message);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, AlreadyExistsException struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.message = iprot.readString();
+ struct.setMessageIsSet(true);
+ }
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,6 +38,12 @@ public class BinaryColumnStatsData imple
private static final org.apache.thrift.protocol.TField AVG_COL_LEN_FIELD_DESC = new org.apache.thrift.protocol.TField("avgColLen", org.apache.thrift.protocol.TType.DOUBLE, (short)2);
private static final org.apache.thrift.protocol.TField NUM_NULLS_FIELD_DESC = new org.apache.thrift.protocol.TField("numNulls", org.apache.thrift.protocol.TType.I64, (short)3);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new BinaryColumnStatsDataStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new BinaryColumnStatsDataTupleSchemeFactory());
+ }
+
private long maxColLen; // required
private double avgColLen; // required
private long numNulls; // required
@@ -100,8 +116,7 @@ public class BinaryColumnStatsData imple
private static final int __MAXCOLLEN_ISSET_ID = 0;
private static final int __AVGCOLLEN_ISSET_ID = 1;
private static final int __NUMNULLS_ISSET_ID = 2;
- private BitSet __isset_bit_vector = new BitSet(3);
-
+ private byte __isset_bitfield = 0;
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);
@@ -136,8 +151,7 @@ public class BinaryColumnStatsData imple
* Performs a deep copy on <i>other</i>.
*/
public BinaryColumnStatsData(BinaryColumnStatsData other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.maxColLen = other.maxColLen;
this.avgColLen = other.avgColLen;
this.numNulls = other.numNulls;
@@ -167,16 +181,16 @@ public class BinaryColumnStatsData imple
}
public void unsetMaxColLen() {
- __isset_bit_vector.clear(__MAXCOLLEN_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXCOLLEN_ISSET_ID);
}
/** Returns true if field maxColLen is set (has been assigned a value) and false otherwise */
public boolean isSetMaxColLen() {
- return __isset_bit_vector.get(__MAXCOLLEN_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __MAXCOLLEN_ISSET_ID);
}
public void setMaxColLenIsSet(boolean value) {
- __isset_bit_vector.set(__MAXCOLLEN_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXCOLLEN_ISSET_ID, value);
}
public double getAvgColLen() {
@@ -189,16 +203,16 @@ public class BinaryColumnStatsData imple
}
public void unsetAvgColLen() {
- __isset_bit_vector.clear(__AVGCOLLEN_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __AVGCOLLEN_ISSET_ID);
}
/** Returns true if field avgColLen is set (has been assigned a value) and false otherwise */
public boolean isSetAvgColLen() {
- return __isset_bit_vector.get(__AVGCOLLEN_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __AVGCOLLEN_ISSET_ID);
}
public void setAvgColLenIsSet(boolean value) {
- __isset_bit_vector.set(__AVGCOLLEN_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __AVGCOLLEN_ISSET_ID, value);
}
public long getNumNulls() {
@@ -211,16 +225,16 @@ public class BinaryColumnStatsData imple
}
public void unsetNumNulls() {
- __isset_bit_vector.clear(__NUMNULLS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
}
/** Returns true if field numNulls is set (has been assigned a value) and false otherwise */
public boolean isSetNumNulls() {
- return __isset_bit_vector.get(__NUMNULLS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
}
public void setNumNullsIsSet(boolean value) {
- __isset_bit_vector.set(__NUMNULLS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMNULLS_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -395,63 +409,11 @@ public class BinaryColumnStatsData imple
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // MAX_COL_LEN
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.maxColLen = iprot.readI64();
- setMaxColLenIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // AVG_COL_LEN
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.avgColLen = iprot.readDouble();
- setAvgColLenIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // NUM_NULLS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.numNulls = iprot.readI64();
- setNumNullsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(MAX_COL_LEN_FIELD_DESC);
- oprot.writeI64(this.maxColLen);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(AVG_COL_LEN_FIELD_DESC);
- oprot.writeDouble(this.avgColLen);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
- oprot.writeI64(this.numNulls);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -488,6 +450,7 @@ public class BinaryColumnStatsData imple
throw new org.apache.thrift.protocol.TProtocolException("Required field 'numNulls' is unset! Struct:" + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -501,12 +464,110 @@ public class BinaryColumnStatsData imple
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_bit_vector = new BitSet(1);
+ __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 BinaryColumnStatsDataStandardSchemeFactory implements SchemeFactory {
+ public BinaryColumnStatsDataStandardScheme getScheme() {
+ return new BinaryColumnStatsDataStandardScheme();
+ }
+ }
+
+ private static class BinaryColumnStatsDataStandardScheme extends StandardScheme<BinaryColumnStatsData> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, BinaryColumnStatsData 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: // MAX_COL_LEN
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.maxColLen = iprot.readI64();
+ struct.setMaxColLenIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // AVG_COL_LEN
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.avgColLen = iprot.readDouble();
+ struct.setAvgColLenIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NUM_NULLS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(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, BinaryColumnStatsData struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(MAX_COL_LEN_FIELD_DESC);
+ oprot.writeI64(struct.maxColLen);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(AVG_COL_LEN_FIELD_DESC);
+ oprot.writeDouble(struct.avgColLen);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
+ oprot.writeI64(struct.numNulls);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class BinaryColumnStatsDataTupleSchemeFactory implements SchemeFactory {
+ public BinaryColumnStatsDataTupleScheme getScheme() {
+ return new BinaryColumnStatsDataTupleScheme();
+ }
+ }
+
+ private static class BinaryColumnStatsDataTupleScheme extends TupleScheme<BinaryColumnStatsData> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, BinaryColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.maxColLen);
+ oprot.writeDouble(struct.avgColLen);
+ oprot.writeI64(struct.numNulls);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, BinaryColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.maxColLen = iprot.readI64();
+ struct.setMaxColLenIsSet(true);
+ struct.avgColLen = iprot.readDouble();
+ struct.setAvgColLenIsSet(true);
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(true);
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,6 +38,12 @@ public class BooleanColumnStatsData impl
private static final org.apache.thrift.protocol.TField NUM_FALSES_FIELD_DESC = new org.apache.thrift.protocol.TField("numFalses", org.apache.thrift.protocol.TType.I64, (short)2);
private static final org.apache.thrift.protocol.TField NUM_NULLS_FIELD_DESC = new org.apache.thrift.protocol.TField("numNulls", org.apache.thrift.protocol.TType.I64, (short)3);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new BooleanColumnStatsDataStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new BooleanColumnStatsDataTupleSchemeFactory());
+ }
+
private long numTrues; // required
private long numFalses; // required
private long numNulls; // required
@@ -100,8 +116,7 @@ public class BooleanColumnStatsData impl
private static final int __NUMTRUES_ISSET_ID = 0;
private static final int __NUMFALSES_ISSET_ID = 1;
private static final int __NUMNULLS_ISSET_ID = 2;
- private BitSet __isset_bit_vector = new BitSet(3);
-
+ private byte __isset_bitfield = 0;
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);
@@ -136,8 +151,7 @@ public class BooleanColumnStatsData impl
* Performs a deep copy on <i>other</i>.
*/
public BooleanColumnStatsData(BooleanColumnStatsData other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.numTrues = other.numTrues;
this.numFalses = other.numFalses;
this.numNulls = other.numNulls;
@@ -167,16 +181,16 @@ public class BooleanColumnStatsData impl
}
public void unsetNumTrues() {
- __isset_bit_vector.clear(__NUMTRUES_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMTRUES_ISSET_ID);
}
/** Returns true if field numTrues is set (has been assigned a value) and false otherwise */
public boolean isSetNumTrues() {
- return __isset_bit_vector.get(__NUMTRUES_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMTRUES_ISSET_ID);
}
public void setNumTruesIsSet(boolean value) {
- __isset_bit_vector.set(__NUMTRUES_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMTRUES_ISSET_ID, value);
}
public long getNumFalses() {
@@ -189,16 +203,16 @@ public class BooleanColumnStatsData impl
}
public void unsetNumFalses() {
- __isset_bit_vector.clear(__NUMFALSES_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMFALSES_ISSET_ID);
}
/** Returns true if field numFalses is set (has been assigned a value) and false otherwise */
public boolean isSetNumFalses() {
- return __isset_bit_vector.get(__NUMFALSES_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMFALSES_ISSET_ID);
}
public void setNumFalsesIsSet(boolean value) {
- __isset_bit_vector.set(__NUMFALSES_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMFALSES_ISSET_ID, value);
}
public long getNumNulls() {
@@ -211,16 +225,16 @@ public class BooleanColumnStatsData impl
}
public void unsetNumNulls() {
- __isset_bit_vector.clear(__NUMNULLS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
}
/** Returns true if field numNulls is set (has been assigned a value) and false otherwise */
public boolean isSetNumNulls() {
- return __isset_bit_vector.get(__NUMNULLS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
}
public void setNumNullsIsSet(boolean value) {
- __isset_bit_vector.set(__NUMNULLS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMNULLS_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -395,63 +409,11 @@ public class BooleanColumnStatsData impl
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // NUM_TRUES
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.numTrues = iprot.readI64();
- setNumTruesIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // NUM_FALSES
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.numFalses = iprot.readI64();
- setNumFalsesIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // NUM_NULLS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.numNulls = iprot.readI64();
- setNumNullsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(NUM_TRUES_FIELD_DESC);
- oprot.writeI64(this.numTrues);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(NUM_FALSES_FIELD_DESC);
- oprot.writeI64(this.numFalses);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
- oprot.writeI64(this.numNulls);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -488,6 +450,7 @@ public class BooleanColumnStatsData impl
throw new org.apache.thrift.protocol.TProtocolException("Required field 'numNulls' is unset! Struct:" + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -501,12 +464,110 @@ public class BooleanColumnStatsData impl
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_bit_vector = new BitSet(1);
+ __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 BooleanColumnStatsDataStandardSchemeFactory implements SchemeFactory {
+ public BooleanColumnStatsDataStandardScheme getScheme() {
+ return new BooleanColumnStatsDataStandardScheme();
+ }
+ }
+
+ private static class BooleanColumnStatsDataStandardScheme extends StandardScheme<BooleanColumnStatsData> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, BooleanColumnStatsData 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: // NUM_TRUES
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numTrues = iprot.readI64();
+ struct.setNumTruesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // NUM_FALSES
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numFalses = iprot.readI64();
+ struct.setNumFalsesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NUM_NULLS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(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, BooleanColumnStatsData struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(NUM_TRUES_FIELD_DESC);
+ oprot.writeI64(struct.numTrues);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_FALSES_FIELD_DESC);
+ oprot.writeI64(struct.numFalses);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
+ oprot.writeI64(struct.numNulls);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class BooleanColumnStatsDataTupleSchemeFactory implements SchemeFactory {
+ public BooleanColumnStatsDataTupleScheme getScheme() {
+ return new BooleanColumnStatsDataTupleScheme();
+ }
+ }
+
+ private static class BooleanColumnStatsDataTupleScheme extends TupleScheme<BooleanColumnStatsData> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, BooleanColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.numTrues);
+ oprot.writeI64(struct.numFalses);
+ oprot.writeI64(struct.numNulls);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, BooleanColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.numTrues = iprot.readI64();
+ struct.setNumTruesIsSet(true);
+ struct.numFalses = iprot.readI64();
+ struct.setNumFalsesIsSet(true);
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(true);
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -27,6 +37,12 @@ public class ColumnStatistics implements
private static final org.apache.thrift.protocol.TField STATS_DESC_FIELD_DESC = new org.apache.thrift.protocol.TField("statsDesc", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField STATS_OBJ_FIELD_DESC = new org.apache.thrift.protocol.TField("statsObj", org.apache.thrift.protocol.TType.LIST, (short)2);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ColumnStatisticsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ColumnStatisticsTupleSchemeFactory());
+ }
+
private ColumnStatisticsDesc statsDesc; // required
private List<ColumnStatisticsObj> statsObj; // required
@@ -92,7 +108,6 @@ public class ColumnStatistics implements
}
// isset id assignments
-
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);
@@ -339,73 +354,11 @@ public class ColumnStatistics implements
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // STATS_DESC
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.statsDesc = new ColumnStatisticsDesc();
- this.statsDesc.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // STATS_OBJ
- if (field.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list110 = iprot.readListBegin();
- this.statsObj = new ArrayList<ColumnStatisticsObj>(_list110.size);
- for (int _i111 = 0; _i111 < _list110.size; ++_i111)
- {
- ColumnStatisticsObj _elem112; // required
- _elem112 = new ColumnStatisticsObj();
- _elem112.read(iprot);
- this.statsObj.add(_elem112);
- }
- iprot.readListEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.statsDesc != null) {
- oprot.writeFieldBegin(STATS_DESC_FIELD_DESC);
- this.statsDesc.write(oprot);
- oprot.writeFieldEnd();
- }
- if (this.statsObj != null) {
- oprot.writeFieldBegin(STATS_OBJ_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.statsObj.size()));
- for (ColumnStatisticsObj _iter113 : this.statsObj)
- {
- _iter113.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -442,6 +395,10 @@ public class ColumnStatistics implements
throw new org.apache.thrift.protocol.TProtocolException("Required field 'statsObj' is unset! Struct:" + toString());
}
+ // check for sub-struct validity
+ if (statsDesc != null) {
+ statsDesc.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -460,5 +417,129 @@ public class ColumnStatistics implements
}
}
+ private static class ColumnStatisticsStandardSchemeFactory implements SchemeFactory {
+ public ColumnStatisticsStandardScheme getScheme() {
+ return new ColumnStatisticsStandardScheme();
+ }
+ }
+
+ private static class ColumnStatisticsStandardScheme extends StandardScheme<ColumnStatistics> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatistics 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: // STATS_DESC
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.statsDesc = new ColumnStatisticsDesc();
+ struct.statsDesc.read(iprot);
+ struct.setStatsDescIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // STATS_OBJ
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list220 = iprot.readListBegin();
+ struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list220.size);
+ for (int _i221 = 0; _i221 < _list220.size; ++_i221)
+ {
+ ColumnStatisticsObj _elem222; // required
+ _elem222 = new ColumnStatisticsObj();
+ _elem222.read(iprot);
+ struct.statsObj.add(_elem222);
+ }
+ iprot.readListEnd();
+ }
+ struct.setStatsObjIsSet(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, ColumnStatistics struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.statsDesc != null) {
+ oprot.writeFieldBegin(STATS_DESC_FIELD_DESC);
+ struct.statsDesc.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.statsObj != null) {
+ 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 _iter223 : struct.statsObj)
+ {
+ _iter223.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ColumnStatisticsTupleSchemeFactory implements SchemeFactory {
+ public ColumnStatisticsTupleScheme getScheme() {
+ return new ColumnStatisticsTupleScheme();
+ }
+ }
+
+ private static class ColumnStatisticsTupleScheme extends TupleScheme<ColumnStatistics> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ColumnStatistics struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ struct.statsDesc.write(oprot);
+ {
+ oprot.writeI32(struct.statsObj.size());
+ for (ColumnStatisticsObj _iter224 : struct.statsObj)
+ {
+ _iter224.write(oprot);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatistics struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.statsDesc = new ColumnStatisticsDesc();
+ struct.statsDesc.read(iprot);
+ struct.setStatsDescIsSet(true);
+ {
+ org.apache.thrift.protocol.TList _list225 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list225.size);
+ for (int _i226 = 0; _i226 < _list225.size; ++_i226)
+ {
+ ColumnStatisticsObj _elem227; // required
+ _elem227 = new ColumnStatisticsObj();
+ _elem227.read(iprot);
+ struct.statsObj.add(_elem227);
+ }
+ }
+ struct.setStatsObjIsSet(true);
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -196,7 +206,7 @@ public class ColumnStatisticsData extend
}
@Override
- protected Object readValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException {
+ protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException {
_Fields setField = _Fields.findByThriftId(field.id);
if (setField != null) {
switch (setField) {
@@ -254,13 +264,78 @@ public class ColumnStatisticsData extend
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
}
@Override
- protected void writeValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ protected void standardSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ switch (setField_) {
+ case BOOLEAN_STATS:
+ BooleanColumnStatsData booleanStats = (BooleanColumnStatsData)value_;
+ booleanStats.write(oprot);
+ return;
+ case LONG_STATS:
+ LongColumnStatsData longStats = (LongColumnStatsData)value_;
+ longStats.write(oprot);
+ return;
+ case DOUBLE_STATS:
+ DoubleColumnStatsData doubleStats = (DoubleColumnStatsData)value_;
+ doubleStats.write(oprot);
+ return;
+ case STRING_STATS:
+ StringColumnStatsData stringStats = (StringColumnStatsData)value_;
+ stringStats.write(oprot);
+ return;
+ case BINARY_STATS:
+ BinaryColumnStatsData binaryStats = (BinaryColumnStatsData)value_;
+ binaryStats.write(oprot);
+ return;
+ default:
+ throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+ }
+ }
+
+ @Override
+ protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException {
+ _Fields setField = _Fields.findByThriftId(fieldID);
+ if (setField != null) {
+ switch (setField) {
+ case BOOLEAN_STATS:
+ BooleanColumnStatsData booleanStats;
+ booleanStats = new BooleanColumnStatsData();
+ booleanStats.read(iprot);
+ return booleanStats;
+ case LONG_STATS:
+ LongColumnStatsData longStats;
+ longStats = new LongColumnStatsData();
+ longStats.read(iprot);
+ return longStats;
+ case DOUBLE_STATS:
+ DoubleColumnStatsData doubleStats;
+ doubleStats = new DoubleColumnStatsData();
+ doubleStats.read(iprot);
+ return doubleStats;
+ case STRING_STATS:
+ StringColumnStatsData stringStats;
+ stringStats = new StringColumnStatsData();
+ stringStats.read(iprot);
+ return stringStats;
+ case BINARY_STATS:
+ BinaryColumnStatsData binaryStats;
+ binaryStats = new BinaryColumnStatsData();
+ binaryStats.read(iprot);
+ return binaryStats;
+ default:
+ throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+ }
+ } else {
+ throw new TProtocolException("Couldn't find a field with field id " + fieldID);
+ }
+ }
+
+ @Override
+ protected void tupleSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
switch (setField_) {
case BOOLEAN_STATS:
BooleanColumnStatsData booleanStats = (BooleanColumnStatsData)value_;
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -30,11 +40,17 @@ public class ColumnStatisticsDesc implem
private static final org.apache.thrift.protocol.TField PART_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("partName", org.apache.thrift.protocol.TType.STRING, (short)4);
private static final org.apache.thrift.protocol.TField LAST_ANALYZED_FIELD_DESC = new org.apache.thrift.protocol.TField("lastAnalyzed", org.apache.thrift.protocol.TType.I64, (short)5);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ColumnStatisticsDescStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ColumnStatisticsDescTupleSchemeFactory());
+ }
+
private boolean isTblLevel; // required
private String dbName; // required
private String tableName; // required
- private String partName; // required
- private long lastAnalyzed; // required
+ private String partName; // optional
+ private long lastAnalyzed; // 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 {
@@ -109,8 +125,8 @@ public class ColumnStatisticsDesc implem
// isset id assignments
private static final int __ISTBLLEVEL_ISSET_ID = 0;
private static final int __LASTANALYZED_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
-
+ private byte __isset_bitfield = 0;
+ private _Fields optionals[] = {_Fields.PART_NAME,_Fields.LAST_ANALYZED};
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);
@@ -147,8 +163,7 @@ public class ColumnStatisticsDesc implem
* Performs a deep copy on <i>other</i>.
*/
public ColumnStatisticsDesc(ColumnStatisticsDesc other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.isTblLevel = other.isTblLevel;
if (other.isSetDbName()) {
this.dbName = other.dbName;
@@ -187,16 +202,16 @@ public class ColumnStatisticsDesc implem
}
public void unsetIsTblLevel() {
- __isset_bit_vector.clear(__ISTBLLEVEL_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISTBLLEVEL_ISSET_ID);
}
/** Returns true if field isTblLevel is set (has been assigned a value) and false otherwise */
public boolean isSetIsTblLevel() {
- return __isset_bit_vector.get(__ISTBLLEVEL_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __ISTBLLEVEL_ISSET_ID);
}
public void setIsTblLevelIsSet(boolean value) {
- __isset_bit_vector.set(__ISTBLLEVEL_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISTBLLEVEL_ISSET_ID, value);
}
public String getDbName() {
@@ -278,16 +293,16 @@ public class ColumnStatisticsDesc implem
}
public void unsetLastAnalyzed() {
- __isset_bit_vector.clear(__LASTANALYZED_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LASTANALYZED_ISSET_ID);
}
/** Returns true if field lastAnalyzed is set (has been assigned a value) and false otherwise */
public boolean isSetLastAnalyzed() {
- return __isset_bit_vector.get(__LASTANALYZED_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __LASTANALYZED_ISSET_ID);
}
public void setLastAnalyzedIsSet(boolean value) {
- __isset_bit_vector.set(__LASTANALYZED_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LASTANALYZED_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -536,92 +551,11 @@ public class ColumnStatisticsDesc implem
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // IS_TBL_LEVEL
- if (field.type == org.apache.thrift.protocol.TType.BOOL) {
- this.isTblLevel = iprot.readBool();
- setIsTblLevelIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // DB_NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.dbName = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // TABLE_NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.tableName = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 4: // PART_NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.partName = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 5: // LAST_ANALYZED
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.lastAnalyzed = iprot.readI64();
- setLastAnalyzedIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(IS_TBL_LEVEL_FIELD_DESC);
- oprot.writeBool(this.isTblLevel);
- oprot.writeFieldEnd();
- if (this.dbName != null) {
- oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
- oprot.writeString(this.dbName);
- oprot.writeFieldEnd();
- }
- if (this.tableName != null) {
- oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
- oprot.writeString(this.tableName);
- oprot.writeFieldEnd();
- }
- if (this.partName != null) {
- if (isSetPartName()) {
- oprot.writeFieldBegin(PART_NAME_FIELD_DESC);
- oprot.writeString(this.partName);
- oprot.writeFieldEnd();
- }
- }
- if (isSetLastAnalyzed()) {
- oprot.writeFieldBegin(LAST_ANALYZED_FIELD_DESC);
- oprot.writeI64(this.lastAnalyzed);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -682,6 +616,7 @@ public class ColumnStatisticsDesc implem
throw new org.apache.thrift.protocol.TProtocolException("Required field 'tableName' is unset! Struct:" + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -695,12 +630,165 @@ public class ColumnStatisticsDesc implem
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_bit_vector = new BitSet(1);
+ __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 ColumnStatisticsDescStandardSchemeFactory implements SchemeFactory {
+ public ColumnStatisticsDescStandardScheme getScheme() {
+ return new ColumnStatisticsDescStandardScheme();
+ }
+ }
+
+ private static class ColumnStatisticsDescStandardScheme extends StandardScheme<ColumnStatisticsDesc> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsDesc 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: // IS_TBL_LEVEL
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.isTblLevel = iprot.readBool();
+ struct.setIsTblLevelIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // DB_NAME
+ 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 3: // TABLE_NAME
+ 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 4: // PART_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.partName = iprot.readString();
+ struct.setPartNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // LAST_ANALYZED
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.lastAnalyzed = iprot.readI64();
+ struct.setLastAnalyzedIsSet(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, ColumnStatisticsDesc struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(IS_TBL_LEVEL_FIELD_DESC);
+ oprot.writeBool(struct.isTblLevel);
+ oprot.writeFieldEnd();
+ if (struct.dbName != null) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.dbName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.tableName != null) {
+ oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
+ oprot.writeString(struct.tableName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.partName != null) {
+ if (struct.isSetPartName()) {
+ oprot.writeFieldBegin(PART_NAME_FIELD_DESC);
+ oprot.writeString(struct.partName);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.isSetLastAnalyzed()) {
+ oprot.writeFieldBegin(LAST_ANALYZED_FIELD_DESC);
+ oprot.writeI64(struct.lastAnalyzed);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ColumnStatisticsDescTupleSchemeFactory implements SchemeFactory {
+ public ColumnStatisticsDescTupleScheme getScheme() {
+ return new ColumnStatisticsDescTupleScheme();
+ }
+ }
+
+ private static class ColumnStatisticsDescTupleScheme extends TupleScheme<ColumnStatisticsDesc> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsDesc struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeBool(struct.isTblLevel);
+ oprot.writeString(struct.dbName);
+ oprot.writeString(struct.tableName);
+ BitSet optionals = new BitSet();
+ if (struct.isSetPartName()) {
+ optionals.set(0);
+ }
+ if (struct.isSetLastAnalyzed()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetPartName()) {
+ oprot.writeString(struct.partName);
+ }
+ if (struct.isSetLastAnalyzed()) {
+ oprot.writeI64(struct.lastAnalyzed);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsDesc struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.isTblLevel = iprot.readBool();
+ struct.setIsTblLevelIsSet(true);
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ struct.tableName = iprot.readString();
+ struct.setTableNameIsSet(true);
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.partName = iprot.readString();
+ struct.setPartNameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.lastAnalyzed = iprot.readI64();
+ struct.setLastAnalyzedIsSet(true);
+ }
+ }
+ }
+
}