Versions in this module Expand all Collapse all v0 v0.1.1 Nov 16, 2022 Changes in this version + var ColumnChunk_FilePath_DEFAULT string + var ColumnMetaData_DictionaryPageOffset_DEFAULT int64 + var ColumnMetaData_EncodingStats_DEFAULT []*PageEncodingStats + var ColumnMetaData_IndexPageOffset_DEFAULT int64 + var ColumnMetaData_KeyValueMetadata_DEFAULT []*KeyValue + var DataPageHeaderV2_IsCompressed_DEFAULT = true + var DictionaryPageHeader_IsSorted_DEFAULT bool + var FileMetaData_CreatedBy_DEFAULT string + var FileMetaData_KeyValueMetadata_DEFAULT []*KeyValue + var GoUnusedProtection__ int + var KeyValue_Value_DEFAULT string + var PageHeader_Crc_DEFAULT int32 + var RowGroup_SortingColumns_DEFAULT []*SortingColumn + var SchemaElement_FieldID_DEFAULT int32 + var SchemaElement_NumChildren_DEFAULT int32 + var SchemaElement_Precision_DEFAULT int32 + var SchemaElement_Scale_DEFAULT int32 + var SchemaElement_TypeLength_DEFAULT int32 + var Statistics_DistinctCount_DEFAULT int64 + var Statistics_Max_DEFAULT []byte + var Statistics_Min_DEFAULT []byte + var Statistics_NullCount_DEFAULT int64 + type ColumnChunk struct + FileOffset int64 + FilePath *string + MetaData *ColumnMetaData + func NewColumnChunk() *ColumnChunk + func (p *ColumnChunk) GetFileOffset() int64 + func (p *ColumnChunk) GetFilePath() string + func (p *ColumnChunk) GetMetaData() *ColumnMetaData + func (p *ColumnChunk) IsSetFilePath() bool + func (p *ColumnChunk) IsSetMetaData() bool + func (p *ColumnChunk) Read(iprot thrift.TProtocol) error + func (p *ColumnChunk) ReadField1(iprot thrift.TProtocol) error + func (p *ColumnChunk) ReadField2(iprot thrift.TProtocol) error + func (p *ColumnChunk) ReadField3(iprot thrift.TProtocol) error + func (p *ColumnChunk) String() string + func (p *ColumnChunk) Write(oprot thrift.TProtocol) error + type ColumnMetaData struct + Codec CompressionCodec + DataPageOffset int64 + DictionaryPageOffset *int64 + EncodingStats []*PageEncodingStats + Encodings []Encoding + IndexPageOffset *int64 + KeyValueMetadata []*KeyValue + NumValues int64 + PathInSchema []string + Statistics *Statistics + TotalCompressedSize int64 + TotalUncompressedSize int64 + Type Type + var ColumnChunk_MetaData_DEFAULT *ColumnMetaData + func NewColumnMetaData() *ColumnMetaData + func (p *ColumnMetaData) GetCodec() CompressionCodec + func (p *ColumnMetaData) GetDataPageOffset() int64 + func (p *ColumnMetaData) GetDictionaryPageOffset() int64 + func (p *ColumnMetaData) GetEncodingStats() []*PageEncodingStats + func (p *ColumnMetaData) GetEncodings() []Encoding + func (p *ColumnMetaData) GetIndexPageOffset() int64 + func (p *ColumnMetaData) GetKeyValueMetadata() []*KeyValue + func (p *ColumnMetaData) GetNumValues() int64 + func (p *ColumnMetaData) GetPathInSchema() []string + func (p *ColumnMetaData) GetStatistics() *Statistics + func (p *ColumnMetaData) GetTotalCompressedSize() int64 + func (p *ColumnMetaData) GetTotalUncompressedSize() int64 + func (p *ColumnMetaData) GetType() Type + func (p *ColumnMetaData) IsSetDictionaryPageOffset() bool + func (p *ColumnMetaData) IsSetEncodingStats() bool + func (p *ColumnMetaData) IsSetIndexPageOffset() bool + func (p *ColumnMetaData) IsSetKeyValueMetadata() bool + func (p *ColumnMetaData) IsSetStatistics() bool + func (p *ColumnMetaData) Read(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField1(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField10(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField11(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField12(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField13(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField2(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField3(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField4(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField5(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField6(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField7(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField8(iprot thrift.TProtocol) error + func (p *ColumnMetaData) ReadField9(iprot thrift.TProtocol) error + func (p *ColumnMetaData) String() string + func (p *ColumnMetaData) Write(oprot thrift.TProtocol) error + type CompressionCodec int64 + const CompressionCodec_GZIP + const CompressionCodec_LZO + const CompressionCodec_SNAPPY + const CompressionCodec_UNCOMPRESSED + func CompressionCodecFromString(s string) (CompressionCodec, error) + func CompressionCodecPtr(v CompressionCodec) *CompressionCodec + func (p *CompressionCodec) Scan(value interface{}) error + func (p *CompressionCodec) UnmarshalText(text []byte) error + func (p *CompressionCodec) Value() (driver.Value, error) + func (p CompressionCodec) MarshalText() ([]byte, error) + func (p CompressionCodec) String() string + type ConvertedType int64 + const ConvertedType_BSON + const ConvertedType_DATE + const ConvertedType_DECIMAL + const ConvertedType_ENUM + const ConvertedType_INTERVAL + const ConvertedType_INT_16 + const ConvertedType_INT_32 + const ConvertedType_INT_64 + const ConvertedType_INT_8 + const ConvertedType_JSON + const ConvertedType_LIST + const ConvertedType_MAP + const ConvertedType_MAP_KEY_VALUE + const ConvertedType_TIMESTAMP_MICROS + const ConvertedType_TIMESTAMP_MILLIS + const ConvertedType_TIME_MICROS + const ConvertedType_TIME_MILLIS + const ConvertedType_UINT_16 + const ConvertedType_UINT_32 + const ConvertedType_UINT_64 + const ConvertedType_UINT_8 + const ConvertedType_UTF8 + var SchemaElement_ConvertedType_DEFAULT ConvertedType + func ConvertedTypeFromString(s string) (ConvertedType, error) + func ConvertedTypePtr(v ConvertedType) *ConvertedType + func (p *ConvertedType) Scan(value interface{}) error + func (p *ConvertedType) UnmarshalText(text []byte) error + func (p *ConvertedType) Value() (driver.Value, error) + func (p ConvertedType) MarshalText() ([]byte, error) + func (p ConvertedType) String() string + type DataPageHeader struct + DefinitionLevelEncoding Encoding + Encoding Encoding + NumValues int32 + RepetitionLevelEncoding Encoding + Statistics *Statistics + var PageHeader_DataPageHeader_DEFAULT *DataPageHeader + func NewDataPageHeader() *DataPageHeader + func (p *DataPageHeader) GetDefinitionLevelEncoding() Encoding + func (p *DataPageHeader) GetEncoding() Encoding + func (p *DataPageHeader) GetNumValues() int32 + func (p *DataPageHeader) GetRepetitionLevelEncoding() Encoding + func (p *DataPageHeader) GetStatistics() *Statistics + func (p *DataPageHeader) IsSetStatistics() bool + func (p *DataPageHeader) Read(iprot thrift.TProtocol) error + func (p *DataPageHeader) ReadField1(iprot thrift.TProtocol) error + func (p *DataPageHeader) ReadField2(iprot thrift.TProtocol) error + func (p *DataPageHeader) ReadField3(iprot thrift.TProtocol) error + func (p *DataPageHeader) ReadField4(iprot thrift.TProtocol) error + func (p *DataPageHeader) ReadField5(iprot thrift.TProtocol) error + func (p *DataPageHeader) String() string + func (p *DataPageHeader) Write(oprot thrift.TProtocol) error + type DataPageHeaderV2 struct + DefinitionLevelsByteLength int32 + Encoding Encoding + IsCompressed bool + NumNulls int32 + NumRows int32 + NumValues int32 + RepetitionLevelsByteLength int32 + Statistics *Statistics + var PageHeader_DataPageHeaderV2_DEFAULT *DataPageHeaderV2 + func NewDataPageHeaderV2() *DataPageHeaderV2 + func (p *DataPageHeaderV2) GetDefinitionLevelsByteLength() int32 + func (p *DataPageHeaderV2) GetEncoding() Encoding + func (p *DataPageHeaderV2) GetIsCompressed() bool + func (p *DataPageHeaderV2) GetNumNulls() int32 + func (p *DataPageHeaderV2) GetNumRows() int32 + func (p *DataPageHeaderV2) GetNumValues() int32 + func (p *DataPageHeaderV2) GetRepetitionLevelsByteLength() int32 + func (p *DataPageHeaderV2) GetStatistics() *Statistics + func (p *DataPageHeaderV2) IsSetIsCompressed() bool + func (p *DataPageHeaderV2) IsSetStatistics() bool + func (p *DataPageHeaderV2) Read(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField1(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField2(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField3(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField4(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField5(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField6(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField7(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) ReadField8(iprot thrift.TProtocol) error + func (p *DataPageHeaderV2) String() string + func (p *DataPageHeaderV2) Write(oprot thrift.TProtocol) error + type DictionaryPageHeader struct + Encoding Encoding + IsSorted *bool + NumValues int32 + var PageHeader_DictionaryPageHeader_DEFAULT *DictionaryPageHeader + func NewDictionaryPageHeader() *DictionaryPageHeader + func (p *DictionaryPageHeader) GetEncoding() Encoding + func (p *DictionaryPageHeader) GetIsSorted() bool + func (p *DictionaryPageHeader) GetNumValues() int32 + func (p *DictionaryPageHeader) IsSetIsSorted() bool + func (p *DictionaryPageHeader) Read(iprot thrift.TProtocol) error + func (p *DictionaryPageHeader) ReadField1(iprot thrift.TProtocol) error + func (p *DictionaryPageHeader) ReadField2(iprot thrift.TProtocol) error + func (p *DictionaryPageHeader) ReadField3(iprot thrift.TProtocol) error + func (p *DictionaryPageHeader) String() string + func (p *DictionaryPageHeader) Write(oprot thrift.TProtocol) error + type Encoding int64 + const Encoding_BIT_PACKED + const Encoding_DELTA_BINARY_PACKED + const Encoding_DELTA_BYTE_ARRAY + const Encoding_DELTA_LENGTH_BYTE_ARRAY + const Encoding_PLAIN + const Encoding_PLAIN_DICTIONARY + const Encoding_RLE + const Encoding_RLE_DICTIONARY + func EncodingFromString(s string) (Encoding, error) + func EncodingPtr(v Encoding) *Encoding + func (p *Encoding) Scan(value interface{}) error + func (p *Encoding) UnmarshalText(text []byte) error + func (p *Encoding) Value() (driver.Value, error) + func (p Encoding) MarshalText() ([]byte, error) + func (p Encoding) String() string + type FieldRepetitionType int64 + const FieldRepetitionType_OPTIONAL + const FieldRepetitionType_REPEATED + const FieldRepetitionType_REQUIRED + var SchemaElement_RepetitionType_DEFAULT FieldRepetitionType + func FieldRepetitionTypeFromString(s string) (FieldRepetitionType, error) + func FieldRepetitionTypePtr(v FieldRepetitionType) *FieldRepetitionType + func (p *FieldRepetitionType) Scan(value interface{}) error + func (p *FieldRepetitionType) UnmarshalText(text []byte) error + func (p *FieldRepetitionType) Value() (driver.Value, error) + func (p FieldRepetitionType) MarshalText() ([]byte, error) + func (p FieldRepetitionType) String() string + type FileMetaData struct + CreatedBy *string + KeyValueMetadata []*KeyValue + NumRows int64 + RowGroups []*RowGroup + Schema []*SchemaElement + Version int32 + func NewFileMetaData() *FileMetaData + func (p *FileMetaData) GetCreatedBy() string + func (p *FileMetaData) GetKeyValueMetadata() []*KeyValue + func (p *FileMetaData) GetNumRows() int64 + func (p *FileMetaData) GetRowGroups() []*RowGroup + func (p *FileMetaData) GetSchema() []*SchemaElement + func (p *FileMetaData) GetVersion() int32 + func (p *FileMetaData) IsSetCreatedBy() bool + func (p *FileMetaData) IsSetKeyValueMetadata() bool + func (p *FileMetaData) Read(iprot thrift.TProtocol) error + func (p *FileMetaData) ReadField1(iprot thrift.TProtocol) error + func (p *FileMetaData) ReadField2(iprot thrift.TProtocol) error + func (p *FileMetaData) ReadField3(iprot thrift.TProtocol) error + func (p *FileMetaData) ReadField4(iprot thrift.TProtocol) error + func (p *FileMetaData) ReadField5(iprot thrift.TProtocol) error + func (p *FileMetaData) ReadField6(iprot thrift.TProtocol) error + func (p *FileMetaData) String() string + func (p *FileMetaData) Write(oprot thrift.TProtocol) error + type IndexPageHeader struct + var PageHeader_IndexPageHeader_DEFAULT *IndexPageHeader + func NewIndexPageHeader() *IndexPageHeader + func (p *IndexPageHeader) Read(iprot thrift.TProtocol) error + func (p *IndexPageHeader) String() string + func (p *IndexPageHeader) Write(oprot thrift.TProtocol) error + type KeyValue struct + Key string + Value *string + func NewKeyValue() *KeyValue + func (p *KeyValue) GetKey() string + func (p *KeyValue) GetValue() string + func (p *KeyValue) IsSetValue() bool + func (p *KeyValue) Read(iprot thrift.TProtocol) error + func (p *KeyValue) ReadField1(iprot thrift.TProtocol) error + func (p *KeyValue) ReadField2(iprot thrift.TProtocol) error + func (p *KeyValue) String() string + func (p *KeyValue) Write(oprot thrift.TProtocol) error + type PageEncodingStats struct + Count int32 + Encoding Encoding + PageType PageType + func NewPageEncodingStats() *PageEncodingStats + func (p *PageEncodingStats) GetCount() int32 + func (p *PageEncodingStats) GetEncoding() Encoding + func (p *PageEncodingStats) GetPageType() PageType + func (p *PageEncodingStats) Read(iprot thrift.TProtocol) error + func (p *PageEncodingStats) ReadField1(iprot thrift.TProtocol) error + func (p *PageEncodingStats) ReadField2(iprot thrift.TProtocol) error + func (p *PageEncodingStats) ReadField3(iprot thrift.TProtocol) error + func (p *PageEncodingStats) String() string + func (p *PageEncodingStats) Write(oprot thrift.TProtocol) error + type PageHeader struct + CompressedPageSize int32 + Crc *int32 + DataPageHeader *DataPageHeader + DataPageHeaderV2 *DataPageHeaderV2 + DictionaryPageHeader *DictionaryPageHeader + IndexPageHeader *IndexPageHeader + Type PageType + UncompressedPageSize int32 + func NewPageHeader() *PageHeader + func (p *PageHeader) GetCompressedPageSize() int32 + func (p *PageHeader) GetCrc() int32 + func (p *PageHeader) GetDataPageHeader() *DataPageHeader + func (p *PageHeader) GetDataPageHeaderV2() *DataPageHeaderV2 + func (p *PageHeader) GetDictionaryPageHeader() *DictionaryPageHeader + func (p *PageHeader) GetIndexPageHeader() *IndexPageHeader + func (p *PageHeader) GetType() PageType + func (p *PageHeader) GetUncompressedPageSize() int32 + func (p *PageHeader) IsSetCrc() bool + func (p *PageHeader) IsSetDataPageHeader() bool + func (p *PageHeader) IsSetDataPageHeaderV2() bool + func (p *PageHeader) IsSetDictionaryPageHeader() bool + func (p *PageHeader) IsSetIndexPageHeader() bool + func (p *PageHeader) Read(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField1(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField2(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField3(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField4(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField5(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField6(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField7(iprot thrift.TProtocol) error + func (p *PageHeader) ReadField8(iprot thrift.TProtocol) error + func (p *PageHeader) String() string + func (p *PageHeader) Write(oprot thrift.TProtocol) error + type PageType int64 + const PageType_DATA_PAGE + const PageType_DATA_PAGE_V2 + const PageType_DICTIONARY_PAGE + const PageType_INDEX_PAGE + func PageTypeFromString(s string) (PageType, error) + func PageTypePtr(v PageType) *PageType + func (p *PageType) Scan(value interface{}) error + func (p *PageType) UnmarshalText(text []byte) error + func (p *PageType) Value() (driver.Value, error) + func (p PageType) MarshalText() ([]byte, error) + func (p PageType) String() string + type RowGroup struct + Columns []*ColumnChunk + NumRows int64 + SortingColumns []*SortingColumn + TotalByteSize int64 + func NewRowGroup() *RowGroup + func (p *RowGroup) GetColumns() []*ColumnChunk + func (p *RowGroup) GetNumRows() int64 + func (p *RowGroup) GetSortingColumns() []*SortingColumn + func (p *RowGroup) GetTotalByteSize() int64 + func (p *RowGroup) IsSetSortingColumns() bool + func (p *RowGroup) Read(iprot thrift.TProtocol) error + func (p *RowGroup) ReadField1(iprot thrift.TProtocol) error + func (p *RowGroup) ReadField2(iprot thrift.TProtocol) error + func (p *RowGroup) ReadField3(iprot thrift.TProtocol) error + func (p *RowGroup) ReadField4(iprot thrift.TProtocol) error + func (p *RowGroup) String() string + func (p *RowGroup) Write(oprot thrift.TProtocol) error + type SchemaElement struct + ConvertedType *ConvertedType + FieldID *int32 + Name string + NumChildren *int32 + Precision *int32 + RepetitionType *FieldRepetitionType + Scale *int32 + Type *Type + TypeLength *int32 + func NewSchemaElement() *SchemaElement + func (p *SchemaElement) GetConvertedType() ConvertedType + func (p *SchemaElement) GetFieldID() int32 + func (p *SchemaElement) GetName() string + func (p *SchemaElement) GetNumChildren() int32 + func (p *SchemaElement) GetPrecision() int32 + func (p *SchemaElement) GetRepetitionType() FieldRepetitionType + func (p *SchemaElement) GetScale() int32 + func (p *SchemaElement) GetType() Type + func (p *SchemaElement) GetTypeLength() int32 + func (p *SchemaElement) IsSetConvertedType() bool + func (p *SchemaElement) IsSetFieldID() bool + func (p *SchemaElement) IsSetNumChildren() bool + func (p *SchemaElement) IsSetPrecision() bool + func (p *SchemaElement) IsSetRepetitionType() bool + func (p *SchemaElement) IsSetScale() bool + func (p *SchemaElement) IsSetType() bool + func (p *SchemaElement) IsSetTypeLength() bool + func (p *SchemaElement) Read(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField1(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField2(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField3(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField4(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField5(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField6(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField7(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField8(iprot thrift.TProtocol) error + func (p *SchemaElement) ReadField9(iprot thrift.TProtocol) error + func (p *SchemaElement) String() string + func (p *SchemaElement) Write(oprot thrift.TProtocol) error + type SortingColumn struct + ColumnIdx int32 + Descending bool + NullsFirst bool + func NewSortingColumn() *SortingColumn + func (p *SortingColumn) GetColumnIdx() int32 + func (p *SortingColumn) GetDescending() bool + func (p *SortingColumn) GetNullsFirst() bool + func (p *SortingColumn) Read(iprot thrift.TProtocol) error + func (p *SortingColumn) ReadField1(iprot thrift.TProtocol) error + func (p *SortingColumn) ReadField2(iprot thrift.TProtocol) error + func (p *SortingColumn) ReadField3(iprot thrift.TProtocol) error + func (p *SortingColumn) String() string + func (p *SortingColumn) Write(oprot thrift.TProtocol) error + type Statistics struct + DistinctCount *int64 + Max []byte + Min []byte + NullCount *int64 + var ColumnMetaData_Statistics_DEFAULT *Statistics + var DataPageHeaderV2_Statistics_DEFAULT *Statistics + var DataPageHeader_Statistics_DEFAULT *Statistics + func NewStatistics() *Statistics + func (p *Statistics) GetDistinctCount() int64 + func (p *Statistics) GetMax() []byte + func (p *Statistics) GetMin() []byte + func (p *Statistics) GetNullCount() int64 + func (p *Statistics) IsSetDistinctCount() bool + func (p *Statistics) IsSetMax() bool + func (p *Statistics) IsSetMin() bool + func (p *Statistics) IsSetNullCount() bool + func (p *Statistics) Read(iprot thrift.TProtocol) error + func (p *Statistics) ReadField1(iprot thrift.TProtocol) error + func (p *Statistics) ReadField2(iprot thrift.TProtocol) error + func (p *Statistics) ReadField3(iprot thrift.TProtocol) error + func (p *Statistics) ReadField4(iprot thrift.TProtocol) error + func (p *Statistics) String() string + func (p *Statistics) Write(oprot thrift.TProtocol) error + type Type int64 + const Type_BOOLEAN + const Type_BYTE_ARRAY + const Type_DOUBLE + const Type_FIXED_LEN_BYTE_ARRAY + const Type_FLOAT + const Type_INT32 + const Type_INT64 + const Type_INT96 + var SchemaElement_Type_DEFAULT Type + func TypeFromString(s string) (Type, error) + func TypePtr(v Type) *Type + func (p *Type) Scan(value interface{}) error + func (p *Type) UnmarshalText(text []byte) error + func (p *Type) Value() (driver.Value, error) + func (p Type) MarshalText() ([]byte, error) + func (p Type) String() string v0.1.0 Sep 14, 2019