http://git-wip-us.apache.org/repos/asf/parquet-cpp/blob/fed33172/src/parquet/thrift/parquet_types.cpp
----------------------------------------------------------------------
diff --git a/src/parquet/thrift/parquet_types.cpp
b/src/parquet/thrift/parquet_types.cpp
deleted file mode 100644
index 8834e3e..0000000
--- a/src/parquet/thrift/parquet_types.cpp
+++ /dev/null
@@ -1,2188 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-#include "parquet_types.h"
-
-#include <algorithm>
-
-namespace parquet {
-
-int _kTypeValues[] = {
- Type::BOOLEAN,
- Type::INT32,
- Type::INT64,
- Type::INT96,
- Type::FLOAT,
- Type::DOUBLE,
- Type::BYTE_ARRAY,
- Type::FIXED_LEN_BYTE_ARRAY
-};
-const char* _kTypeNames[] = {
- "BOOLEAN",
- "INT32",
- "INT64",
- "INT96",
- "FLOAT",
- "DOUBLE",
- "BYTE_ARRAY",
- "FIXED_LEN_BYTE_ARRAY"
-};
-const std::map<int, const char*>
_Type_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(8, _kTypeValues,
_kTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kConvertedTypeValues[] = {
- ConvertedType::UTF8,
- ConvertedType::MAP,
- ConvertedType::MAP_KEY_VALUE,
- ConvertedType::LIST,
- ConvertedType::ENUM,
- ConvertedType::DECIMAL,
- ConvertedType::DATE,
- ConvertedType::TIME_MILLIS,
- ConvertedType::TIMESTAMP_MILLIS,
- ConvertedType::UINT_8,
- ConvertedType::UINT_16,
- ConvertedType::UINT_32,
- ConvertedType::UINT_64,
- ConvertedType::INT_8,
- ConvertedType::INT_16,
- ConvertedType::INT_32,
- ConvertedType::INT_64,
- ConvertedType::JSON,
- ConvertedType::BSON,
- ConvertedType::INTERVAL
-};
-const char* _kConvertedTypeNames[] = {
- "UTF8",
- "MAP",
- "MAP_KEY_VALUE",
- "LIST",
- "ENUM",
- "DECIMAL",
- "DATE",
- "TIME_MILLIS",
- "TIMESTAMP_MILLIS",
- "UINT_8",
- "UINT_16",
- "UINT_32",
- "UINT_64",
- "INT_8",
- "INT_16",
- "INT_32",
- "INT_64",
- "JSON",
- "BSON",
- "INTERVAL"
-};
-const std::map<int, const char*>
_ConvertedType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(20,
_kConvertedTypeValues, _kConvertedTypeNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kFieldRepetitionTypeValues[] = {
- FieldRepetitionType::REQUIRED,
- FieldRepetitionType::OPTIONAL,
- FieldRepetitionType::REPEATED
-};
-const char* _kFieldRepetitionTypeNames[] = {
- "REQUIRED",
- "OPTIONAL",
- "REPEATED"
-};
-const std::map<int, const char*>
_FieldRepetitionType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3,
_kFieldRepetitionTypeValues, _kFieldRepetitionTypeNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kEncodingValues[] = {
- Encoding::PLAIN,
- Encoding::PLAIN_DICTIONARY,
- Encoding::RLE,
- Encoding::BIT_PACKED,
- Encoding::DELTA_BINARY_PACKED,
- Encoding::DELTA_LENGTH_BYTE_ARRAY,
- Encoding::DELTA_BYTE_ARRAY,
- Encoding::RLE_DICTIONARY
-};
-const char* _kEncodingNames[] = {
- "PLAIN",
- "PLAIN_DICTIONARY",
- "RLE",
- "BIT_PACKED",
- "DELTA_BINARY_PACKED",
- "DELTA_LENGTH_BYTE_ARRAY",
- "DELTA_BYTE_ARRAY",
- "RLE_DICTIONARY"
-};
-const std::map<int, const char*>
_Encoding_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(8, _kEncodingValues,
_kEncodingNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kCompressionCodecValues[] = {
- CompressionCodec::UNCOMPRESSED,
- CompressionCodec::SNAPPY,
- CompressionCodec::GZIP,
- CompressionCodec::LZO
-};
-const char* _kCompressionCodecNames[] = {
- "UNCOMPRESSED",
- "SNAPPY",
- "GZIP",
- "LZO"
-};
-const std::map<int, const char*>
_CompressionCodec_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4,
_kCompressionCodecValues, _kCompressionCodecNames),
::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-int _kPageTypeValues[] = {
- PageType::DATA_PAGE,
- PageType::INDEX_PAGE,
- PageType::DICTIONARY_PAGE,
- PageType::DATA_PAGE_V2
-};
-const char* _kPageTypeNames[] = {
- "DATA_PAGE",
- "INDEX_PAGE",
- "DICTIONARY_PAGE",
- "DATA_PAGE_V2"
-};
-const std::map<int, const char*>
_PageType_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(4, _kPageTypeValues,
_kPageTypeNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
-const char* Statistics::ascii_fingerprint = "CE004821871820DD79A8FD98BB101F6D";
-const uint8_t Statistics::binary_fingerprint[16] =
{0xCE,0x00,0x48,0x21,0x87,0x18,0x20,0xDD,0x79,0xA8,0xFD,0x98,0xBB,0x10,0x1F,0x6D};
-
-uint32_t Statistics::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readBinary(this->max);
- this->__isset.max = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readBinary(this->min);
- this->__isset.min = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->null_count);
- this->__isset.null_count = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->distinct_count);
- this->__isset.distinct_count = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- return xfer;
-}
-
-uint32_t Statistics::write(::apache::thrift::protocol::TProtocol* oprot) const
{
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("Statistics");
-
- if (this->__isset.max) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("max",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeBinary(this->max);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.min) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("min",
::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeBinary(this->min);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.null_count) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("null_count",
::apache::thrift::protocol::T_I64, 3);
- xfer += oprot->writeI64(this->null_count);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.distinct_count) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("distinct_count",
::apache::thrift::protocol::T_I64, 4);
- xfer += oprot->writeI64(this->distinct_count);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(Statistics &a, Statistics &b) {
- using ::std::swap;
- swap(a.max, b.max);
- swap(a.min, b.min);
- swap(a.null_count, b.null_count);
- swap(a.distinct_count, b.distinct_count);
- swap(a.__isset, b.__isset);
-}
-
-const char* SchemaElement::ascii_fingerprint =
"22DC89BFD9E48E604F01FB8CFDFB8229";
-const uint8_t SchemaElement::binary_fingerprint[16] =
{0x22,0xDC,0x89,0xBF,0xD9,0xE4,0x8E,0x60,0x4F,0x01,0xFB,0x8C,0xFD,0xFB,0x82,0x29};
-
-uint32_t SchemaElement::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_name = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast0;
- xfer += iprot->readI32(ecast0);
- this->type = (Type::type)ecast0;
- this->__isset.type = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->type_length);
- this->__isset.type_length = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast1;
- xfer += iprot->readI32(ecast1);
- this->repetition_type = (FieldRepetitionType::type)ecast1;
- this->__isset.repetition_type = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->name);
- isset_name = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->num_children);
- this->__isset.num_children = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast2;
- xfer += iprot->readI32(ecast2);
- this->converted_type = (ConvertedType::type)ecast2;
- this->__isset.converted_type = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->scale);
- this->__isset.scale = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->precision);
- this->__isset.precision = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 9:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->field_id);
- this->__isset.field_id = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_name)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t SchemaElement::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("SchemaElement");
-
- if (this->__isset.type) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("type", ::apache::thrift::protocol::T_I32,
1);
- xfer += oprot->writeI32((int32_t)this->type);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.type_length) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("type_length",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32(this->type_length);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.repetition_type) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("repetition_type",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((int32_t)this->repetition_type);
- xfer += oprot->writeFieldEnd();
- }
- ++fcnt;
- xfer += oprot->writeFieldBegin("name", ::apache::thrift::protocol::T_STRING,
4);
- xfer += oprot->writeString(this->name);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.num_children) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_children",
::apache::thrift::protocol::T_I32, 5);
- xfer += oprot->writeI32(this->num_children);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.converted_type) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("converted_type",
::apache::thrift::protocol::T_I32, 6);
- xfer += oprot->writeI32((int32_t)this->converted_type);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.scale) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("scale", ::apache::thrift::protocol::T_I32,
7);
- xfer += oprot->writeI32(this->scale);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.precision) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("precision",
::apache::thrift::protocol::T_I32, 8);
- xfer += oprot->writeI32(this->precision);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.field_id) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("field_id",
::apache::thrift::protocol::T_I32, 9);
- xfer += oprot->writeI32(this->field_id);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(SchemaElement &a, SchemaElement &b) {
- using ::std::swap;
- swap(a.type, b.type);
- swap(a.type_length, b.type_length);
- swap(a.repetition_type, b.repetition_type);
- swap(a.name, b.name);
- swap(a.num_children, b.num_children);
- swap(a.converted_type, b.converted_type);
- swap(a.scale, b.scale);
- swap(a.precision, b.precision);
- swap(a.field_id, b.field_id);
- swap(a.__isset, b.__isset);
-}
-
-const char* DataPageHeader::ascii_fingerprint =
"5FC1792B0483E9C984475384165040B1";
-const uint8_t DataPageHeader::binary_fingerprint[16] =
{0x5F,0xC1,0x79,0x2B,0x04,0x83,0xE9,0xC9,0x84,0x47,0x53,0x84,0x16,0x50,0x40,0xB1};
-
-uint32_t DataPageHeader::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_num_values = false;
- bool isset_encoding = false;
- bool isset_definition_level_encoding = false;
- bool isset_repetition_level_encoding = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->num_values);
- isset_num_values = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast3;
- xfer += iprot->readI32(ecast3);
- this->encoding = (Encoding::type)ecast3;
- isset_encoding = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast4;
- xfer += iprot->readI32(ecast4);
- this->definition_level_encoding = (Encoding::type)ecast4;
- isset_definition_level_encoding = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast5;
- xfer += iprot->readI32(ecast5);
- this->repetition_level_encoding = (Encoding::type)ecast5;
- isset_repetition_level_encoding = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->statistics.read(iprot);
- this->__isset.statistics = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_num_values)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_encoding)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_definition_level_encoding)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_repetition_level_encoding)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t DataPageHeader::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("DataPageHeader");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_values",
::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32(this->num_values);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("encoding",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->encoding);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("definition_level_encoding",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((int32_t)this->definition_level_encoding);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("repetition_level_encoding",
::apache::thrift::protocol::T_I32, 4);
- xfer += oprot->writeI32((int32_t)this->repetition_level_encoding);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.statistics) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("statistics",
::apache::thrift::protocol::T_STRUCT, 5);
- xfer += this->statistics.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(DataPageHeader &a, DataPageHeader &b) {
- using ::std::swap;
- swap(a.num_values, b.num_values);
- swap(a.encoding, b.encoding);
- swap(a.definition_level_encoding, b.definition_level_encoding);
- swap(a.repetition_level_encoding, b.repetition_level_encoding);
- swap(a.statistics, b.statistics);
- swap(a.__isset, b.__isset);
-}
-
-const char* IndexPageHeader::ascii_fingerprint =
"99914B932BD37A50B983C5E7C90AE93B";
-const uint8_t IndexPageHeader::binary_fingerprint[16] =
{0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B};
-
-uint32_t IndexPageHeader::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- xfer += iprot->skip(ftype);
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- return xfer;
-}
-
-uint32_t IndexPageHeader::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("IndexPageHeader");
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(IndexPageHeader &a, IndexPageHeader &b) {
- using ::std::swap;
- (void) a;
- (void) b;
-}
-
-const char* DictionaryPageHeader::ascii_fingerprint =
"B149E4528254D495610C22AE4BD539C5";
-const uint8_t DictionaryPageHeader::binary_fingerprint[16] =
{0xB1,0x49,0xE4,0x52,0x82,0x54,0xD4,0x95,0x61,0x0C,0x22,0xAE,0x4B,0xD5,0x39,0xC5};
-
-uint32_t DictionaryPageHeader::read(::apache::thrift::protocol::TProtocol*
iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_num_values = false;
- bool isset_encoding = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->num_values);
- isset_num_values = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast6;
- xfer += iprot->readI32(ecast6);
- this->encoding = (Encoding::type)ecast6;
- isset_encoding = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->is_sorted);
- this->__isset.is_sorted = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_num_values)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_encoding)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t DictionaryPageHeader::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("DictionaryPageHeader");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_values",
::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32(this->num_values);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("encoding",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->encoding);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.is_sorted) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("is_sorted",
::apache::thrift::protocol::T_BOOL, 3);
- xfer += oprot->writeBool(this->is_sorted);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(DictionaryPageHeader &a, DictionaryPageHeader &b) {
- using ::std::swap;
- swap(a.num_values, b.num_values);
- swap(a.encoding, b.encoding);
- swap(a.is_sorted, b.is_sorted);
- swap(a.__isset, b.__isset);
-}
-
-const char* DataPageHeaderV2::ascii_fingerprint =
"69FF2F6BD1A443440D5E46ABA5A3A919";
-const uint8_t DataPageHeaderV2::binary_fingerprint[16] =
{0x69,0xFF,0x2F,0x6B,0xD1,0xA4,0x43,0x44,0x0D,0x5E,0x46,0xAB,0xA5,0xA3,0xA9,0x19};
-
-uint32_t DataPageHeaderV2::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_num_values = false;
- bool isset_num_nulls = false;
- bool isset_num_rows = false;
- bool isset_encoding = false;
- bool isset_definition_levels_byte_length = false;
- bool isset_repetition_levels_byte_length = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->num_values);
- isset_num_values = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->num_nulls);
- isset_num_nulls = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->num_rows);
- isset_num_rows = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast7;
- xfer += iprot->readI32(ecast7);
- this->encoding = (Encoding::type)ecast7;
- isset_encoding = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->definition_levels_byte_length);
- isset_definition_levels_byte_length = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->repetition_levels_byte_length);
- isset_repetition_levels_byte_length = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->is_compressed);
- this->__isset.is_compressed = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->statistics.read(iprot);
- this->__isset.statistics = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_num_values)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_num_nulls)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_num_rows)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_encoding)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_definition_levels_byte_length)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_repetition_levels_byte_length)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t DataPageHeaderV2::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("DataPageHeaderV2");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_values",
::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32(this->num_values);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_nulls",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32(this->num_nulls);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_rows",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->num_rows);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("encoding",
::apache::thrift::protocol::T_I32, 4);
- xfer += oprot->writeI32((int32_t)this->encoding);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("definition_levels_byte_length",
::apache::thrift::protocol::T_I32, 5);
- xfer += oprot->writeI32(this->definition_levels_byte_length);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("repetition_levels_byte_length",
::apache::thrift::protocol::T_I32, 6);
- xfer += oprot->writeI32(this->repetition_levels_byte_length);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.is_compressed) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("is_compressed",
::apache::thrift::protocol::T_BOOL, 7);
- xfer += oprot->writeBool(this->is_compressed);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.statistics) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("statistics",
::apache::thrift::protocol::T_STRUCT, 8);
- xfer += this->statistics.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(DataPageHeaderV2 &a, DataPageHeaderV2 &b) {
- using ::std::swap;
- swap(a.num_values, b.num_values);
- swap(a.num_nulls, b.num_nulls);
- swap(a.num_rows, b.num_rows);
- swap(a.encoding, b.encoding);
- swap(a.definition_levels_byte_length, b.definition_levels_byte_length);
- swap(a.repetition_levels_byte_length, b.repetition_levels_byte_length);
- swap(a.is_compressed, b.is_compressed);
- swap(a.statistics, b.statistics);
- swap(a.__isset, b.__isset);
-}
-
-const char* PageHeader::ascii_fingerprint = "B5BD2BDF3756C883A58B30B9C9F204A0";
-const uint8_t PageHeader::binary_fingerprint[16] =
{0xB5,0xBD,0x2B,0xDF,0x37,0x56,0xC8,0x83,0xA5,0x8B,0x30,0xB9,0xC9,0xF2,0x04,0xA0};
-
-uint32_t PageHeader::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_type = false;
- bool isset_uncompressed_page_size = false;
- bool isset_compressed_page_size = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast8;
- xfer += iprot->readI32(ecast8);
- this->type = (PageType::type)ecast8;
- isset_type = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->uncompressed_page_size);
- isset_uncompressed_page_size = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->compressed_page_size);
- isset_compressed_page_size = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->crc);
- this->__isset.crc = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->data_page_header.read(iprot);
- this->__isset.data_page_header = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->index_page_header.read(iprot);
- this->__isset.index_page_header = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->dictionary_page_header.read(iprot);
- this->__isset.dictionary_page_header = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->data_page_header_v2.read(iprot);
- this->__isset.data_page_header_v2 = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_type)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_uncompressed_page_size)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_compressed_page_size)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t PageHeader::write(::apache::thrift::protocol::TProtocol* oprot) const
{
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("PageHeader");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("type", ::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32((int32_t)this->type);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("uncompressed_page_size",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32(this->uncompressed_page_size);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("compressed_page_size",
::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32(this->compressed_page_size);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.crc) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("crc", ::apache::thrift::protocol::T_I32,
4);
- xfer += oprot->writeI32(this->crc);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.data_page_header) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("data_page_header",
::apache::thrift::protocol::T_STRUCT, 5);
- xfer += this->data_page_header.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.index_page_header) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("index_page_header",
::apache::thrift::protocol::T_STRUCT, 6);
- xfer += this->index_page_header.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.dictionary_page_header) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("dictionary_page_header",
::apache::thrift::protocol::T_STRUCT, 7);
- xfer += this->dictionary_page_header.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.data_page_header_v2) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("data_page_header_v2",
::apache::thrift::protocol::T_STRUCT, 8);
- xfer += this->data_page_header_v2.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(PageHeader &a, PageHeader &b) {
- using ::std::swap;
- swap(a.type, b.type);
- swap(a.uncompressed_page_size, b.uncompressed_page_size);
- swap(a.compressed_page_size, b.compressed_page_size);
- swap(a.crc, b.crc);
- swap(a.data_page_header, b.data_page_header);
- swap(a.index_page_header, b.index_page_header);
- swap(a.dictionary_page_header, b.dictionary_page_header);
- swap(a.data_page_header_v2, b.data_page_header_v2);
- swap(a.__isset, b.__isset);
-}
-
-const char* KeyValue::ascii_fingerprint = "5B708A954C550ECA9C1A49D3C5CAFAB9";
-const uint8_t KeyValue::binary_fingerprint[16] =
{0x5B,0x70,0x8A,0x95,0x4C,0x55,0x0E,0xCA,0x9C,0x1A,0x49,0xD3,0xC5,0xCA,0xFA,0xB9};
-
-uint32_t KeyValue::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_key = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->key);
- isset_key = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->value);
- this->__isset.value = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_key)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t KeyValue::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("KeyValue");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("key", ::apache::thrift::protocol::T_STRING,
1);
- xfer += oprot->writeString(this->key);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.value) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("value",
::apache::thrift::protocol::T_STRING, 2);
- xfer += oprot->writeString(this->value);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(KeyValue &a, KeyValue &b) {
- using ::std::swap;
- swap(a.key, b.key);
- swap(a.value, b.value);
- swap(a.__isset, b.__isset);
-}
-
-const char* SortingColumn::ascii_fingerprint =
"F079C2D58A783AD90F9BE05D10DBBC6F";
-const uint8_t SortingColumn::binary_fingerprint[16] =
{0xF0,0x79,0xC2,0xD5,0x8A,0x78,0x3A,0xD9,0x0F,0x9B,0xE0,0x5D,0x10,0xDB,0xBC,0x6F};
-
-uint32_t SortingColumn::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_column_idx = false;
- bool isset_descending = false;
- bool isset_nulls_first = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->column_idx);
- isset_column_idx = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->descending);
- isset_descending = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_BOOL) {
- xfer += iprot->readBool(this->nulls_first);
- isset_nulls_first = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_column_idx)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_descending)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_nulls_first)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t SortingColumn::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("SortingColumn");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("column_idx",
::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32(this->column_idx);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("descending",
::apache::thrift::protocol::T_BOOL, 2);
- xfer += oprot->writeBool(this->descending);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("nulls_first",
::apache::thrift::protocol::T_BOOL, 3);
- xfer += oprot->writeBool(this->nulls_first);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(SortingColumn &a, SortingColumn &b) {
- using ::std::swap;
- swap(a.column_idx, b.column_idx);
- swap(a.descending, b.descending);
- swap(a.nulls_first, b.nulls_first);
-}
-
-const char* PageEncodingStats::ascii_fingerprint =
"5F1BEE04836FAA3055D3EE2492AE44FB";
-const uint8_t PageEncodingStats::binary_fingerprint[16] =
{0x5F,0x1B,0xEE,0x04,0x83,0x6F,0xAA,0x30,0x55,0xD3,0xEE,0x24,0x92,0xAE,0x44,0xFB};
-
-uint32_t PageEncodingStats::read(::apache::thrift::protocol::TProtocol* iprot)
{
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_page_type = false;
- bool isset_encoding = false;
- bool isset_count = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast9;
- xfer += iprot->readI32(ecast9);
- this->page_type = (PageType::type)ecast9;
- isset_page_type = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast10;
- xfer += iprot->readI32(ecast10);
- this->encoding = (Encoding::type)ecast10;
- isset_encoding = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->count);
- isset_count = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_page_type)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_encoding)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_count)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t PageEncodingStats::write(::apache::thrift::protocol::TProtocol*
oprot) const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("PageEncodingStats");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("page_type",
::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32((int32_t)this->page_type);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("encoding",
::apache::thrift::protocol::T_I32, 2);
- xfer += oprot->writeI32((int32_t)this->encoding);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("count", ::apache::thrift::protocol::T_I32,
3);
- xfer += oprot->writeI32(this->count);
- xfer += oprot->writeFieldEnd();
-
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(PageEncodingStats &a, PageEncodingStats &b) {
- using ::std::swap;
- swap(a.page_type, b.page_type);
- swap(a.encoding, b.encoding);
- swap(a.count, b.count);
-}
-
-const char* ColumnMetaData::ascii_fingerprint =
"AEE7317B6DB9719FE828388D537DBD71";
-const uint8_t ColumnMetaData::binary_fingerprint[16] =
{0xAE,0xE7,0x31,0x7B,0x6D,0xB9,0x71,0x9F,0xE8,0x28,0x38,0x8D,0x53,0x7D,0xBD,0x71};
-
-uint32_t ColumnMetaData::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_type = false;
- bool isset_encodings = false;
- bool isset_path_in_schema = false;
- bool isset_codec = false;
- bool isset_num_values = false;
- bool isset_total_uncompressed_size = false;
- bool isset_total_compressed_size = false;
- bool isset_data_page_offset = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast11;
- xfer += iprot->readI32(ecast11);
- this->type = (Type::type)ecast11;
- isset_type = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->encodings.clear();
- uint32_t _size12;
- ::apache::thrift::protocol::TType _etype15;
- xfer += iprot->readListBegin(_etype15, _size12);
- this->encodings.resize(_size12);
- uint32_t _i16;
- for (_i16 = 0; _i16 < _size12; ++_i16)
- {
- int32_t ecast17;
- xfer += iprot->readI32(ecast17);
- this->encodings[_i16] = (Encoding::type)ecast17;
- }
- xfer += iprot->readListEnd();
- }
- isset_encodings = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->path_in_schema.clear();
- uint32_t _size18;
- ::apache::thrift::protocol::TType _etype21;
- xfer += iprot->readListBegin(_etype21, _size18);
- this->path_in_schema.resize(_size18);
- uint32_t _i22;
- for (_i22 = 0; _i22 < _size18; ++_i22)
- {
- xfer += iprot->readString(this->path_in_schema[_i22]);
- }
- xfer += iprot->readListEnd();
- }
- isset_path_in_schema = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast23;
- xfer += iprot->readI32(ecast23);
- this->codec = (CompressionCodec::type)ecast23;
- isset_codec = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->num_values);
- isset_num_values = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->total_uncompressed_size);
- isset_total_uncompressed_size = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 7:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->total_compressed_size);
- isset_total_compressed_size = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->key_value_metadata.clear();
- uint32_t _size24;
- ::apache::thrift::protocol::TType _etype27;
- xfer += iprot->readListBegin(_etype27, _size24);
- this->key_value_metadata.resize(_size24);
- uint32_t _i28;
- for (_i28 = 0; _i28 < _size24; ++_i28)
- {
- xfer += this->key_value_metadata[_i28].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.key_value_metadata = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 9:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->data_page_offset);
- isset_data_page_offset = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 10:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->index_page_offset);
- this->__isset.index_page_offset = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 11:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->dictionary_page_offset);
- this->__isset.dictionary_page_offset = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 12:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->statistics.read(iprot);
- this->__isset.statistics = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 13:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->encoding_stats.clear();
- uint32_t _size29;
- ::apache::thrift::protocol::TType _etype32;
- xfer += iprot->readListBegin(_etype32, _size29);
- this->encoding_stats.resize(_size29);
- uint32_t _i33;
- for (_i33 = 0; _i33 < _size29; ++_i33)
- {
- xfer += this->encoding_stats[_i33].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.encoding_stats = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_type)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_encodings)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_path_in_schema)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_codec)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_num_values)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_total_uncompressed_size)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_total_compressed_size)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_data_page_offset)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t ColumnMetaData::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("ColumnMetaData");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("type", ::apache::thrift::protocol::T_I32, 1);
- xfer += oprot->writeI32((int32_t)this->type);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("encodings",
::apache::thrift::protocol::T_LIST, 2);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I32,
static_cast<uint32_t>(this->encodings.size()));
- std::vector<Encoding::type> ::const_iterator _iter34;
- for (_iter34 = this->encodings.begin(); _iter34 != this->encodings.end();
++_iter34)
- {
- xfer += oprot->writeI32((int32_t)(*_iter34));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("path_in_schema",
::apache::thrift::protocol::T_LIST, 3);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING,
static_cast<uint32_t>(this->path_in_schema.size()));
- std::vector<std::string> ::const_iterator _iter35;
- for (_iter35 = this->path_in_schema.begin(); _iter35 !=
this->path_in_schema.end(); ++_iter35)
- {
- xfer += oprot->writeString((*_iter35));
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("codec", ::apache::thrift::protocol::T_I32,
4);
- xfer += oprot->writeI32((int32_t)this->codec);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_values",
::apache::thrift::protocol::T_I64, 5);
- xfer += oprot->writeI64(this->num_values);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("total_uncompressed_size",
::apache::thrift::protocol::T_I64, 6);
- xfer += oprot->writeI64(this->total_uncompressed_size);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("total_compressed_size",
::apache::thrift::protocol::T_I64, 7);
- xfer += oprot->writeI64(this->total_compressed_size);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.key_value_metadata) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("key_value_metadata",
::apache::thrift::protocol::T_LIST, 8);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->key_value_metadata.size()));
- std::vector<KeyValue> ::const_iterator _iter36;
- for (_iter36 = this->key_value_metadata.begin(); _iter36 !=
this->key_value_metadata.end(); ++_iter36)
- {
- xfer += (*_iter36).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- ++fcnt;
- xfer += oprot->writeFieldBegin("data_page_offset",
::apache::thrift::protocol::T_I64, 9);
- xfer += oprot->writeI64(this->data_page_offset);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.index_page_offset) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("index_page_offset",
::apache::thrift::protocol::T_I64, 10);
- xfer += oprot->writeI64(this->index_page_offset);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.dictionary_page_offset) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("dictionary_page_offset",
::apache::thrift::protocol::T_I64, 11);
- xfer += oprot->writeI64(this->dictionary_page_offset);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.statistics) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("statistics",
::apache::thrift::protocol::T_STRUCT, 12);
- xfer += this->statistics.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.encoding_stats) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("encoding_stats",
::apache::thrift::protocol::T_LIST, 13);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->encoding_stats.size()));
- std::vector<PageEncodingStats> ::const_iterator _iter37;
- for (_iter37 = this->encoding_stats.begin(); _iter37 !=
this->encoding_stats.end(); ++_iter37)
- {
- xfer += (*_iter37).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(ColumnMetaData &a, ColumnMetaData &b) {
- using ::std::swap;
- swap(a.type, b.type);
- swap(a.encodings, b.encodings);
- swap(a.path_in_schema, b.path_in_schema);
- swap(a.codec, b.codec);
- swap(a.num_values, b.num_values);
- swap(a.total_uncompressed_size, b.total_uncompressed_size);
- swap(a.total_compressed_size, b.total_compressed_size);
- swap(a.key_value_metadata, b.key_value_metadata);
- swap(a.data_page_offset, b.data_page_offset);
- swap(a.index_page_offset, b.index_page_offset);
- swap(a.dictionary_page_offset, b.dictionary_page_offset);
- swap(a.statistics, b.statistics);
- swap(a.encoding_stats, b.encoding_stats);
- swap(a.__isset, b.__isset);
-}
-
-const char* ColumnChunk::ascii_fingerprint =
"F9F2DFFF1A7805AEF05AA10B23AF3108";
-const uint8_t ColumnChunk::binary_fingerprint[16] =
{0xF9,0xF2,0xDF,0xFF,0x1A,0x78,0x05,0xAE,0xF0,0x5A,0xA1,0x0B,0x23,0xAF,0x31,0x08};
-
-uint32_t ColumnChunk::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_file_offset = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->file_path);
- this->__isset.file_path = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->file_offset);
- isset_file_offset = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_STRUCT) {
- xfer += this->meta_data.read(iprot);
- this->__isset.meta_data = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_file_offset)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t ColumnChunk::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("ColumnChunk");
-
- if (this->__isset.file_path) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("file_path",
::apache::thrift::protocol::T_STRING, 1);
- xfer += oprot->writeString(this->file_path);
- xfer += oprot->writeFieldEnd();
- }
- ++fcnt;
- xfer += oprot->writeFieldBegin("file_offset",
::apache::thrift::protocol::T_I64, 2);
- xfer += oprot->writeI64(this->file_offset);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.meta_data) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("meta_data",
::apache::thrift::protocol::T_STRUCT, 3);
- xfer += this->meta_data.write(oprot);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(ColumnChunk &a, ColumnChunk &b) {
- using ::std::swap;
- swap(a.file_path, b.file_path);
- swap(a.file_offset, b.file_offset);
- swap(a.meta_data, b.meta_data);
- swap(a.__isset, b.__isset);
-}
-
-const char* RowGroup::ascii_fingerprint = "9BCFCB6790B06809B46424957993EDA6";
-const uint8_t RowGroup::binary_fingerprint[16] =
{0x9B,0xCF,0xCB,0x67,0x90,0xB0,0x68,0x09,0xB4,0x64,0x24,0x95,0x79,0x93,0xED,0xA6};
-
-uint32_t RowGroup::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_columns = false;
- bool isset_total_byte_size = false;
- bool isset_num_rows = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->columns.clear();
- uint32_t _size38;
- ::apache::thrift::protocol::TType _etype41;
- xfer += iprot->readListBegin(_etype41, _size38);
- this->columns.resize(_size38);
- uint32_t _i42;
- for (_i42 = 0; _i42 < _size38; ++_i42)
- {
- xfer += this->columns[_i42].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- isset_columns = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->total_byte_size);
- isset_total_byte_size = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->num_rows);
- isset_num_rows = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->sorting_columns.clear();
- uint32_t _size43;
- ::apache::thrift::protocol::TType _etype46;
- xfer += iprot->readListBegin(_etype46, _size43);
- this->sorting_columns.resize(_size43);
- uint32_t _i47;
- for (_i47 = 0; _i47 < _size43; ++_i47)
- {
- xfer += this->sorting_columns[_i47].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.sorting_columns = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_columns)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_total_byte_size)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_num_rows)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t RowGroup::write(::apache::thrift::protocol::TProtocol* oprot) const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("RowGroup");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("columns",
::apache::thrift::protocol::T_LIST, 1);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->columns.size()));
- std::vector<ColumnChunk> ::const_iterator _iter48;
- for (_iter48 = this->columns.begin(); _iter48 != this->columns.end();
++_iter48)
- {
- xfer += (*_iter48).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("total_byte_size",
::apache::thrift::protocol::T_I64, 2);
- xfer += oprot->writeI64(this->total_byte_size);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_rows",
::apache::thrift::protocol::T_I64, 3);
- xfer += oprot->writeI64(this->num_rows);
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.sorting_columns) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("sorting_columns",
::apache::thrift::protocol::T_LIST, 4);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->sorting_columns.size()));
- std::vector<SortingColumn> ::const_iterator _iter49;
- for (_iter49 = this->sorting_columns.begin(); _iter49 !=
this->sorting_columns.end(); ++_iter49)
- {
- xfer += (*_iter49).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(RowGroup &a, RowGroup &b) {
- using ::std::swap;
- swap(a.columns, b.columns);
- swap(a.total_byte_size, b.total_byte_size);
- swap(a.num_rows, b.num_rows);
- swap(a.sorting_columns, b.sorting_columns);
- swap(a.__isset, b.__isset);
-}
-
-const char* FileMetaData::ascii_fingerprint =
"D76119B1A4F2B4F404F095255FBDBD9A";
-const uint8_t FileMetaData::binary_fingerprint[16] =
{0xD7,0x61,0x19,0xB1,0xA4,0xF2,0xB4,0xF4,0x04,0xF0,0x95,0x25,0x5F,0xBD,0xBD,0x9A};
-
-uint32_t FileMetaData::read(::apache::thrift::protocol::TProtocol* iprot) {
-
- uint32_t xfer = 0;
- std::string fname;
- ::apache::thrift::protocol::TType ftype;
- int16_t fid;
-
- xfer += iprot->readStructBegin(fname);
-
- using ::apache::thrift::protocol::TProtocolException;
-
- bool isset_version = false;
- bool isset_schema = false;
- bool isset_num_rows = false;
- bool isset_row_groups = false;
-
- while (true)
- {
- xfer += iprot->readFieldBegin(fname, ftype, fid);
- if (ftype == ::apache::thrift::protocol::T_STOP) {
- break;
- }
- switch (fid)
- {
- case 1:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- xfer += iprot->readI32(this->version);
- isset_version = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 2:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->schema.clear();
- uint32_t _size50;
- ::apache::thrift::protocol::TType _etype53;
- xfer += iprot->readListBegin(_etype53, _size50);
- this->schema.resize(_size50);
- uint32_t _i54;
- for (_i54 = 0; _i54 < _size50; ++_i54)
- {
- xfer += this->schema[_i54].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- isset_schema = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 3:
- if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->num_rows);
- isset_num_rows = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 4:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->row_groups.clear();
- uint32_t _size55;
- ::apache::thrift::protocol::TType _etype58;
- xfer += iprot->readListBegin(_etype58, _size55);
- this->row_groups.resize(_size55);
- uint32_t _i59;
- for (_i59 = 0; _i59 < _size55; ++_i59)
- {
- xfer += this->row_groups[_i59].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- isset_row_groups = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 5:
- if (ftype == ::apache::thrift::protocol::T_LIST) {
- {
- this->key_value_metadata.clear();
- uint32_t _size60;
- ::apache::thrift::protocol::TType _etype63;
- xfer += iprot->readListBegin(_etype63, _size60);
- this->key_value_metadata.resize(_size60);
- uint32_t _i64;
- for (_i64 = 0; _i64 < _size60; ++_i64)
- {
- xfer += this->key_value_metadata[_i64].read(iprot);
- }
- xfer += iprot->readListEnd();
- }
- this->__isset.key_value_metadata = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 6:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->created_by);
- this->__isset.created_by = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- default:
- xfer += iprot->skip(ftype);
- break;
- }
- xfer += iprot->readFieldEnd();
- }
-
- xfer += iprot->readStructEnd();
-
- if (!isset_version)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_schema)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_num_rows)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- if (!isset_row_groups)
- throw TProtocolException(TProtocolException::INVALID_DATA);
- return xfer;
-}
-
-uint32_t FileMetaData::write(::apache::thrift::protocol::TProtocol* oprot)
const {
- uint32_t xfer = 0;
- uint32_t fcnt = 0;
- xfer += oprot->writeStructBegin("FileMetaData");
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("version", ::apache::thrift::protocol::T_I32,
1);
- xfer += oprot->writeI32(this->version);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("schema", ::apache::thrift::protocol::T_LIST,
2);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->schema.size()));
- std::vector<SchemaElement> ::const_iterator _iter65;
- for (_iter65 = this->schema.begin(); _iter65 != this->schema.end();
++_iter65)
- {
- xfer += (*_iter65).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("num_rows",
::apache::thrift::protocol::T_I64, 3);
- xfer += oprot->writeI64(this->num_rows);
- xfer += oprot->writeFieldEnd();
-
- ++fcnt;
- xfer += oprot->writeFieldBegin("row_groups",
::apache::thrift::protocol::T_LIST, 4);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->row_groups.size()));
- std::vector<RowGroup> ::const_iterator _iter66;
- for (_iter66 = this->row_groups.begin(); _iter66 !=
this->row_groups.end(); ++_iter66)
- {
- xfer += (*_iter66).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
-
- if (this->__isset.key_value_metadata) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("key_value_metadata",
::apache::thrift::protocol::T_LIST, 5);
- {
- xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT,
static_cast<uint32_t>(this->key_value_metadata.size()));
- std::vector<KeyValue> ::const_iterator _iter67;
- for (_iter67 = this->key_value_metadata.begin(); _iter67 !=
this->key_value_metadata.end(); ++_iter67)
- {
- xfer += (*_iter67).write(oprot);
- }
- xfer += oprot->writeListEnd();
- }
- xfer += oprot->writeFieldEnd();
- }
- if (this->__isset.created_by) {
- ++fcnt;
- xfer += oprot->writeFieldBegin("created_by",
::apache::thrift::protocol::T_STRING, 6);
- xfer += oprot->writeString(this->created_by);
- xfer += oprot->writeFieldEnd();
- }
- xfer += oprot->writeFieldStop();
- xfer += oprot->writeStructEnd();
- return xfer;
-}
-
-void swap(FileMetaData &a, FileMetaData &b) {
- using ::std::swap;
- swap(a.version, b.version);
- swap(a.schema, b.schema);
- swap(a.num_rows, b.num_rows);
- swap(a.row_groups, b.row_groups);
- swap(a.key_value_metadata, b.key_value_metadata);
- swap(a.created_by, b.created_by);
- swap(a.__isset, b.__isset);
-}
-
-} // namespace
