parquet

package

Go to main page

Versions in this module

v0

v0.12.0

Aug 18, 2022

v0.11.0

Apr 21, 2022

v0.10.0

Feb 18, 2022

Changes in this version

type CompressionCodec

+ const CompressionCodec_LZ4_RAW

v0.9.0

Feb 10, 2022

v0.8.0

Feb 2, 2022

v0.7.0

Feb 1, 2022

v0.6.1

Nov 19, 2021

v0.6.0

Nov 3, 2021

v0.5.0

Oct 29, 2021

Changes in this version

type AesGcmCtrV1

+ func (p *AesGcmCtrV1) Equals(other *AesGcmCtrV1) bool

type AesGcmV1

+ func (p *AesGcmV1) Equals(other *AesGcmV1) bool

type BloomFilterAlgorithm

+ func (p *BloomFilterAlgorithm) Equals(other *BloomFilterAlgorithm) bool

type BloomFilterCompression

+ func (p *BloomFilterCompression) Equals(other *BloomFilterCompression) bool

type BloomFilterHash

+ func (p *BloomFilterHash) Equals(other *BloomFilterHash) bool

type BloomFilterHeader

+ func (p *BloomFilterHeader) Equals(other *BloomFilterHeader) bool

type BsonType

+ func (p *BsonType) Equals(other *BsonType) bool

type ColumnChunk

+ func (p *ColumnChunk) Equals(other *ColumnChunk) bool

type ColumnCryptoMetaData

+ func (p *ColumnCryptoMetaData) Equals(other *ColumnCryptoMetaData) bool

type ColumnIndex

+ func (p *ColumnIndex) Equals(other *ColumnIndex) bool

type ColumnMetaData

+ func (p *ColumnMetaData) Equals(other *ColumnMetaData) bool

type ColumnOrder

+ func (p *ColumnOrder) Equals(other *ColumnOrder) bool

type DataPageHeader

+ func (p *DataPageHeader) Equals(other *DataPageHeader) bool

type DataPageHeaderV2

+ func (p *DataPageHeaderV2) Equals(other *DataPageHeaderV2) bool

type DateType

+ func (p *DateType) Equals(other *DateType) bool

type DecimalType

+ func (p *DecimalType) Equals(other *DecimalType) bool

type DictionaryPageHeader

+ func (p *DictionaryPageHeader) Equals(other *DictionaryPageHeader) bool

type EncryptionAlgorithm

+ func (p *EncryptionAlgorithm) Equals(other *EncryptionAlgorithm) bool

type EncryptionWithColumnKey

+ func (p *EncryptionWithColumnKey) Equals(other *EncryptionWithColumnKey) bool

type EncryptionWithFooterKey

+ func (p *EncryptionWithFooterKey) Equals(other *EncryptionWithFooterKey) bool

type EnumType

+ func (p *EnumType) Equals(other *EnumType) bool

type FileCryptoMetaData

+ func (p *FileCryptoMetaData) Equals(other *FileCryptoMetaData) bool

type FileMetaData

+ func (p *FileMetaData) Equals(other *FileMetaData) bool

type IndexPageHeader

+ func (p *IndexPageHeader) Equals(other *IndexPageHeader) bool

type IntType

+ func (p *IntType) Equals(other *IntType) bool

type JsonType

+ func (p *JsonType) Equals(other *JsonType) bool

type KeyValue

+ func (p *KeyValue) Equals(other *KeyValue) bool

type ListType

+ func (p *ListType) Equals(other *ListType) bool

type LogicalType

+ func (p *LogicalType) Equals(other *LogicalType) bool

type MapType

+ func (p *MapType) Equals(other *MapType) bool

type MicroSeconds

+ func (p *MicroSeconds) Equals(other *MicroSeconds) bool

type MilliSeconds

+ func (p *MilliSeconds) Equals(other *MilliSeconds) bool

type NanoSeconds

+ func (p *NanoSeconds) Equals(other *NanoSeconds) bool

type NullType

+ func (p *NullType) Equals(other *NullType) bool

type OffsetIndex

+ func (p *OffsetIndex) Equals(other *OffsetIndex) bool

type PageEncodingStats

+ func (p *PageEncodingStats) Equals(other *PageEncodingStats) bool

type PageHeader

+ func (p *PageHeader) Equals(other *PageHeader) bool

type PageLocation

+ func (p *PageLocation) Equals(other *PageLocation) bool

type RowGroup

+ func (p *RowGroup) Equals(other *RowGroup) bool

type SchemaElement

+ func (p *SchemaElement) Equals(other *SchemaElement) bool

type SortingColumn

+ func (p *SortingColumn) Equals(other *SortingColumn) bool

type SplitBlockAlgorithm

+ func (p *SplitBlockAlgorithm) Equals(other *SplitBlockAlgorithm) bool

type Statistics

+ func (p *Statistics) Equals(other *Statistics) bool

type StringType

+ func (p *StringType) Equals(other *StringType) bool

type TimeType

+ func (p *TimeType) Equals(other *TimeType) bool

type TimeUnit

+ func (p *TimeUnit) Equals(other *TimeUnit) bool

type TimestampType

+ func (p *TimestampType) Equals(other *TimestampType) bool

type TypeDefinedOrder

+ func (p *TypeDefinedOrder) Equals(other *TypeDefinedOrder) bool

type UUIDType

+ func (p *UUIDType) Equals(other *UUIDType) bool

type Uncompressed

+ func (p *Uncompressed) Equals(other *Uncompressed) bool

type XxHash

+ func (p *XxHash) Equals(other *XxHash) bool

v0.4.0

Oct 6, 2021

v0.3.0

Dec 15, 2020

v0.2.1

Nov 4, 2020

v0.2.0

Nov 4, 2020

v0.1.1

May 26, 2020

v0.1.0

Apr 23, 2020

Changes in this version

+ var AesGcmCtrV1_AadFileUnique_DEFAULT []byte

+ var AesGcmCtrV1_AadPrefix_DEFAULT []byte

+ var AesGcmCtrV1_SupplyAadPrefix_DEFAULT bool

+ var AesGcmV1_AadFileUnique_DEFAULT []byte

+ var AesGcmV1_AadPrefix_DEFAULT []byte

+ var AesGcmV1_SupplyAadPrefix_DEFAULT bool

+ var ColumnChunk_ColumnIndexLength_DEFAULT int32

+ var ColumnChunk_ColumnIndexOffset_DEFAULT int64

+ var ColumnChunk_EncryptedColumnMetadata_DEFAULT []byte

+ var ColumnChunk_FilePath_DEFAULT string

+ var ColumnChunk_OffsetIndexLength_DEFAULT int32

+ var ColumnChunk_OffsetIndexOffset_DEFAULT int64

+ var ColumnIndex_NullCounts_DEFAULT []int64

+ var ColumnMetaData_BloomFilterOffset_DEFAULT int64

+ var ColumnMetaData_DictionaryPageOffset_DEFAULT int64

+ var ColumnMetaData_EncodingStats_DEFAULT []*PageEncodingStats

+ var ColumnMetaData_IndexPageOffset_DEFAULT int64

+ var ColumnMetaData_KeyValueMetadata_DEFAULT []*KeyValue

+ var DataPageHeaderV2_IsCompressed_DEFAULT bool = true

+ var DictionaryPageHeader_IsSorted_DEFAULT bool

+ var EncryptionWithColumnKey_KeyMetadata_DEFAULT []byte

+ var FileCryptoMetaData_KeyMetadata_DEFAULT []byte

+ var FileMetaData_ColumnOrders_DEFAULT []*ColumnOrder

+ var FileMetaData_CreatedBy_DEFAULT string

+ var FileMetaData_FooterSigningKeyMetadata_DEFAULT []byte

+ var FileMetaData_KeyValueMetadata_DEFAULT []*KeyValue

+ var GoUnusedProtection__ int

+ var KeyValue_Value_DEFAULT string

+ var PageHeader_Crc_DEFAULT int32

+ var RowGroup_FileOffset_DEFAULT int64

+ var RowGroup_Ordinal_DEFAULT int16

+ var RowGroup_SortingColumns_DEFAULT []*SortingColumn

+ var RowGroup_TotalCompressedSize_DEFAULT int64

+ 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_MaxValue_DEFAULT []byte

+ var Statistics_Max_DEFAULT []byte

+ var Statistics_MinValue_DEFAULT []byte

+ var Statistics_Min_DEFAULT []byte

+ var Statistics_NullCount_DEFAULT int64

+ type AesGcmCtrV1 struct

+ AadFileUnique []byte

+ AadPrefix []byte

+ SupplyAadPrefix *bool

+ var EncryptionAlgorithm_AES_GCM_CTR_V1_DEFAULT *AesGcmCtrV1

+ func NewAesGcmCtrV1() *AesGcmCtrV1

+ func (p *AesGcmCtrV1) GetAadFileUnique() []byte

+ func (p *AesGcmCtrV1) GetAadPrefix() []byte

+ func (p *AesGcmCtrV1) GetSupplyAadPrefix() bool

+ func (p *AesGcmCtrV1) IsSetAadFileUnique() bool

+ func (p *AesGcmCtrV1) IsSetAadPrefix() bool

+ func (p *AesGcmCtrV1) IsSetSupplyAadPrefix() bool

+ func (p *AesGcmCtrV1) Read(iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) ReadField1(iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) ReadField2(iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) ReadField3(iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) String() string

+ func (p *AesGcmCtrV1) Write(oprot thrift.TProtocol) error

+ type AesGcmV1 struct

+ AadFileUnique []byte

+ AadPrefix []byte

+ SupplyAadPrefix *bool

+ var EncryptionAlgorithm_AES_GCM_V1_DEFAULT *AesGcmV1

+ func NewAesGcmV1() *AesGcmV1

+ func (p *AesGcmV1) GetAadFileUnique() []byte

+ func (p *AesGcmV1) GetAadPrefix() []byte

+ func (p *AesGcmV1) GetSupplyAadPrefix() bool

+ func (p *AesGcmV1) IsSetAadFileUnique() bool

+ func (p *AesGcmV1) IsSetAadPrefix() bool

+ func (p *AesGcmV1) IsSetSupplyAadPrefix() bool

+ func (p *AesGcmV1) Read(iprot thrift.TProtocol) error

+ func (p *AesGcmV1) ReadField1(iprot thrift.TProtocol) error

+ func (p *AesGcmV1) ReadField2(iprot thrift.TProtocol) error

+ func (p *AesGcmV1) ReadField3(iprot thrift.TProtocol) error

+ func (p *AesGcmV1) String() string

+ func (p *AesGcmV1) Write(oprot thrift.TProtocol) error

+ type BloomFilterAlgorithm struct

+ BLOCK *SplitBlockAlgorithm

+ var BloomFilterHeader_Algorithm_DEFAULT *BloomFilterAlgorithm

+ func NewBloomFilterAlgorithm() *BloomFilterAlgorithm

+ func (p *BloomFilterAlgorithm) CountSetFieldsBloomFilterAlgorithm() int

+ func (p *BloomFilterAlgorithm) GetBLOCK() *SplitBlockAlgorithm

+ func (p *BloomFilterAlgorithm) IsSetBLOCK() bool

+ func (p *BloomFilterAlgorithm) Read(iprot thrift.TProtocol) error

+ func (p *BloomFilterAlgorithm) ReadField1(iprot thrift.TProtocol) error

+ func (p *BloomFilterAlgorithm) String() string

+ func (p *BloomFilterAlgorithm) Write(oprot thrift.TProtocol) error

+ type BloomFilterCompression struct

+ UNCOMPRESSED *Uncompressed

+ var BloomFilterHeader_Compression_DEFAULT *BloomFilterCompression

+ func NewBloomFilterCompression() *BloomFilterCompression

+ func (p *BloomFilterCompression) CountSetFieldsBloomFilterCompression() int

+ func (p *BloomFilterCompression) GetUNCOMPRESSED() *Uncompressed

+ func (p *BloomFilterCompression) IsSetUNCOMPRESSED() bool

+ func (p *BloomFilterCompression) Read(iprot thrift.TProtocol) error

+ func (p *BloomFilterCompression) ReadField1(iprot thrift.TProtocol) error

+ func (p *BloomFilterCompression) String() string

+ func (p *BloomFilterCompression) Write(oprot thrift.TProtocol) error

+ type BloomFilterHash struct

+ XXHASH *XxHash

+ var BloomFilterHeader_Hash_DEFAULT *BloomFilterHash

+ func NewBloomFilterHash() *BloomFilterHash

+ func (p *BloomFilterHash) CountSetFieldsBloomFilterHash() int

+ func (p *BloomFilterHash) GetXXHASH() *XxHash

+ func (p *BloomFilterHash) IsSetXXHASH() bool

+ func (p *BloomFilterHash) Read(iprot thrift.TProtocol) error

+ func (p *BloomFilterHash) ReadField1(iprot thrift.TProtocol) error

+ func (p *BloomFilterHash) String() string

+ func (p *BloomFilterHash) Write(oprot thrift.TProtocol) error

+ type BloomFilterHeader struct

+ Algorithm *BloomFilterAlgorithm

+ Compression *BloomFilterCompression

+ Hash *BloomFilterHash

+ NumBytes int32

+ func NewBloomFilterHeader() *BloomFilterHeader

+ func (p *BloomFilterHeader) GetAlgorithm() *BloomFilterAlgorithm

+ func (p *BloomFilterHeader) GetCompression() *BloomFilterCompression

+ func (p *BloomFilterHeader) GetHash() *BloomFilterHash

+ func (p *BloomFilterHeader) GetNumBytes() int32

+ func (p *BloomFilterHeader) IsSetAlgorithm() bool

+ func (p *BloomFilterHeader) IsSetCompression() bool

+ func (p *BloomFilterHeader) IsSetHash() bool

+ func (p *BloomFilterHeader) Read(iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField1(iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField2(iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField3(iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField4(iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) String() string

+ func (p *BloomFilterHeader) Write(oprot thrift.TProtocol) error

+ type BoundaryOrder int64

+ const BoundaryOrder_ASCENDING

+ const BoundaryOrder_DESCENDING

+ const BoundaryOrder_UNORDERED

+ func BoundaryOrderFromString(s string) (BoundaryOrder, error)

+ func BoundaryOrderPtr(v BoundaryOrder) *BoundaryOrder

+ func (p *BoundaryOrder) Scan(value interface{}) error

+ func (p *BoundaryOrder) UnmarshalText(text []byte) error

+ func (p *BoundaryOrder) Value() (driver.Value, error)

+ func (p BoundaryOrder) MarshalText() ([]byte, error)

+ func (p BoundaryOrder) String() string

+ type BsonType struct

+ var LogicalType_BSON_DEFAULT *BsonType

+ func NewBsonType() *BsonType

+ func (p *BsonType) Read(iprot thrift.TProtocol) error

+ func (p *BsonType) String() string

+ func (p *BsonType) Write(oprot thrift.TProtocol) error

+ type ColumnChunk struct

+ ColumnIndexLength *int32

+ ColumnIndexOffset *int64

+ CryptoMetadata *ColumnCryptoMetaData

+ EncryptedColumnMetadata []byte

+ FileOffset int64

+ FilePath *string

+ MetaData *ColumnMetaData

+ OffsetIndexLength *int32

+ OffsetIndexOffset *int64

+ func NewColumnChunk() *ColumnChunk

+ func (p *ColumnChunk) GetColumnIndexLength() int32

+ func (p *ColumnChunk) GetColumnIndexOffset() int64

+ func (p *ColumnChunk) GetCryptoMetadata() *ColumnCryptoMetaData

+ func (p *ColumnChunk) GetEncryptedColumnMetadata() []byte

+ func (p *ColumnChunk) GetFileOffset() int64

+ func (p *ColumnChunk) GetFilePath() string

+ func (p *ColumnChunk) GetMetaData() *ColumnMetaData

+ func (p *ColumnChunk) GetOffsetIndexLength() int32

+ func (p *ColumnChunk) GetOffsetIndexOffset() int64

+ func (p *ColumnChunk) IsSetColumnIndexLength() bool

+ func (p *ColumnChunk) IsSetColumnIndexOffset() bool

+ func (p *ColumnChunk) IsSetCryptoMetadata() bool

+ func (p *ColumnChunk) IsSetEncryptedColumnMetadata() bool

+ func (p *ColumnChunk) IsSetFilePath() bool

+ func (p *ColumnChunk) IsSetMetaData() bool

+ func (p *ColumnChunk) IsSetOffsetIndexLength() bool

+ func (p *ColumnChunk) IsSetOffsetIndexOffset() 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) ReadField4(iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField5(iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField6(iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField7(iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField8(iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField9(iprot thrift.TProtocol) error

+ func (p *ColumnChunk) String() string

+ func (p *ColumnChunk) Write(oprot thrift.TProtocol) error

+ type ColumnCryptoMetaData struct

+ ENCRYPTION_WITH_COLUMN_KEY *EncryptionWithColumnKey

+ ENCRYPTION_WITH_FOOTER_KEY *EncryptionWithFooterKey

+ var ColumnChunk_CryptoMetadata_DEFAULT *ColumnCryptoMetaData

+ func NewColumnCryptoMetaData() *ColumnCryptoMetaData

+ func (p *ColumnCryptoMetaData) CountSetFieldsColumnCryptoMetaData() int

+ func (p *ColumnCryptoMetaData) GetENCRYPTION_WITH_COLUMN_KEY() *EncryptionWithColumnKey

+ func (p *ColumnCryptoMetaData) GetENCRYPTION_WITH_FOOTER_KEY() *EncryptionWithFooterKey

+ func (p *ColumnCryptoMetaData) IsSetENCRYPTION_WITH_COLUMN_KEY() bool

+ func (p *ColumnCryptoMetaData) IsSetENCRYPTION_WITH_FOOTER_KEY() bool

+ func (p *ColumnCryptoMetaData) Read(iprot thrift.TProtocol) error

+ func (p *ColumnCryptoMetaData) ReadField1(iprot thrift.TProtocol) error

+ func (p *ColumnCryptoMetaData) ReadField2(iprot thrift.TProtocol) error

+ func (p *ColumnCryptoMetaData) String() string

+ func (p *ColumnCryptoMetaData) Write(oprot thrift.TProtocol) error

+ type ColumnIndex struct

+ BoundaryOrder BoundaryOrder

+ MaxValues [][]byte

+ MinValues [][]byte

+ NullCounts []int64

+ NullPages []bool

+ func NewColumnIndex() *ColumnIndex

+ func (p *ColumnIndex) GetBoundaryOrder() BoundaryOrder

+ func (p *ColumnIndex) GetMaxValues() [][]byte

+ func (p *ColumnIndex) GetMinValues() [][]byte

+ func (p *ColumnIndex) GetNullCounts() []int64

+ func (p *ColumnIndex) GetNullPages() []bool

+ func (p *ColumnIndex) IsSetNullCounts() bool

+ func (p *ColumnIndex) Read(iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField1(iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField2(iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField3(iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField4(iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField5(iprot thrift.TProtocol) error

+ func (p *ColumnIndex) String() string

+ func (p *ColumnIndex) Write(oprot thrift.TProtocol) error

+ type ColumnMetaData struct

+ BloomFilterOffset *int64

+ 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) GetBloomFilterOffset() int64

+ 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) IsSetBloomFilterOffset() bool

+ 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) ReadField14(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 ColumnOrder struct

+ TYPE_ORDER *TypeDefinedOrder

+ func NewColumnOrder() *ColumnOrder

+ func (p *ColumnOrder) CountSetFieldsColumnOrder() int

+ func (p *ColumnOrder) GetTYPE_ORDER() *TypeDefinedOrder

+ func (p *ColumnOrder) IsSetTYPE_ORDER() bool

+ func (p *ColumnOrder) Read(iprot thrift.TProtocol) error

+ func (p *ColumnOrder) ReadField1(iprot thrift.TProtocol) error

+ func (p *ColumnOrder) String() string

+ func (p *ColumnOrder) Write(oprot thrift.TProtocol) error

+ type CompressionCodec int64

+ const CompressionCodec_BROTLI

+ const CompressionCodec_GZIP

+ const CompressionCodec_LZ4

+ const CompressionCodec_LZO

+ const CompressionCodec_SNAPPY

+ const CompressionCodec_UNCOMPRESSED

+ const CompressionCodec_ZSTD

+ 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 DateType struct

+ var LogicalType_DATE_DEFAULT *DateType

+ func NewDateType() *DateType

+ func (p *DateType) Read(iprot thrift.TProtocol) error

+ func (p *DateType) String() string

+ func (p *DateType) Write(oprot thrift.TProtocol) error

+ type DecimalType struct

+ Precision int32

+ Scale int32

+ var LogicalType_DECIMAL_DEFAULT *DecimalType

+ func NewDecimalType() *DecimalType

+ func (p *DecimalType) GetPrecision() int32

+ func (p *DecimalType) GetScale() int32

+ func (p *DecimalType) Read(iprot thrift.TProtocol) error

+ func (p *DecimalType) ReadField1(iprot thrift.TProtocol) error

+ func (p *DecimalType) ReadField2(iprot thrift.TProtocol) error

+ func (p *DecimalType) String() string

+ func (p *DecimalType) 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_BYTE_STREAM_SPLIT

+ 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 EncryptionAlgorithm struct

+ AES_GCM_CTR_V1 *AesGcmCtrV1

+ AES_GCM_V1 *AesGcmV1

+ var FileCryptoMetaData_EncryptionAlgorithm_DEFAULT *EncryptionAlgorithm

+ var FileMetaData_EncryptionAlgorithm_DEFAULT *EncryptionAlgorithm

+ func NewEncryptionAlgorithm() *EncryptionAlgorithm

+ func (p *EncryptionAlgorithm) CountSetFieldsEncryptionAlgorithm() int

+ func (p *EncryptionAlgorithm) GetAES_GCM_CTR_V1() *AesGcmCtrV1

+ func (p *EncryptionAlgorithm) GetAES_GCM_V1() *AesGcmV1

+ func (p *EncryptionAlgorithm) IsSetAES_GCM_CTR_V1() bool

+ func (p *EncryptionAlgorithm) IsSetAES_GCM_V1() bool

+ func (p *EncryptionAlgorithm) Read(iprot thrift.TProtocol) error

+ func (p *EncryptionAlgorithm) ReadField1(iprot thrift.TProtocol) error

+ func (p *EncryptionAlgorithm) ReadField2(iprot thrift.TProtocol) error

+ func (p *EncryptionAlgorithm) String() string

+ func (p *EncryptionAlgorithm) Write(oprot thrift.TProtocol) error

+ type EncryptionWithColumnKey struct

+ KeyMetadata []byte

+ PathInSchema []string

+ var ColumnCryptoMetaData_ENCRYPTION_WITH_COLUMN_KEY_DEFAULT *EncryptionWithColumnKey

+ func NewEncryptionWithColumnKey() *EncryptionWithColumnKey

+ func (p *EncryptionWithColumnKey) GetKeyMetadata() []byte

+ func (p *EncryptionWithColumnKey) GetPathInSchema() []string

+ func (p *EncryptionWithColumnKey) IsSetKeyMetadata() bool

+ func (p *EncryptionWithColumnKey) Read(iprot thrift.TProtocol) error

+ func (p *EncryptionWithColumnKey) ReadField1(iprot thrift.TProtocol) error

+ func (p *EncryptionWithColumnKey) ReadField2(iprot thrift.TProtocol) error

+ func (p *EncryptionWithColumnKey) String() string

+ func (p *EncryptionWithColumnKey) Write(oprot thrift.TProtocol) error

+ type EncryptionWithFooterKey struct

+ var ColumnCryptoMetaData_ENCRYPTION_WITH_FOOTER_KEY_DEFAULT *EncryptionWithFooterKey

+ func NewEncryptionWithFooterKey() *EncryptionWithFooterKey

+ func (p *EncryptionWithFooterKey) Read(iprot thrift.TProtocol) error

+ func (p *EncryptionWithFooterKey) String() string

+ func (p *EncryptionWithFooterKey) Write(oprot thrift.TProtocol) error

+ type EnumType struct

+ var LogicalType_ENUM_DEFAULT *EnumType

+ func NewEnumType() *EnumType

+ func (p *EnumType) Read(iprot thrift.TProtocol) error

+ func (p *EnumType) String() string

+ func (p *EnumType) Write(oprot thrift.TProtocol) error

+ 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 FileCryptoMetaData struct

+ EncryptionAlgorithm *EncryptionAlgorithm

+ KeyMetadata []byte

+ func NewFileCryptoMetaData() *FileCryptoMetaData

+ func (p *FileCryptoMetaData) GetEncryptionAlgorithm() *EncryptionAlgorithm

+ func (p *FileCryptoMetaData) GetKeyMetadata() []byte

+ func (p *FileCryptoMetaData) IsSetEncryptionAlgorithm() bool

+ func (p *FileCryptoMetaData) IsSetKeyMetadata() bool

+ func (p *FileCryptoMetaData) Read(iprot thrift.TProtocol) error

+ func (p *FileCryptoMetaData) ReadField1(iprot thrift.TProtocol) error

+ func (p *FileCryptoMetaData) ReadField2(iprot thrift.TProtocol) error

+ func (p *FileCryptoMetaData) String() string

+ func (p *FileCryptoMetaData) Write(oprot thrift.TProtocol) error

+ type FileMetaData struct

+ ColumnOrders []*ColumnOrder

+ CreatedBy *string

+ EncryptionAlgorithm *EncryptionAlgorithm

+ FooterSigningKeyMetadata []byte

+ KeyValueMetadata []*KeyValue

+ NumRows int64

+ RowGroups []*RowGroup

+ Schema []*SchemaElement

+ Version int32

+ func NewFileMetaData() *FileMetaData

+ func (p *FileMetaData) GetColumnOrders() []*ColumnOrder

+ func (p *FileMetaData) GetCreatedBy() string

+ func (p *FileMetaData) GetEncryptionAlgorithm() *EncryptionAlgorithm

+ func (p *FileMetaData) GetFooterSigningKeyMetadata() []byte

+ 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) IsSetColumnOrders() bool

+ func (p *FileMetaData) IsSetCreatedBy() bool

+ func (p *FileMetaData) IsSetEncryptionAlgorithm() bool

+ func (p *FileMetaData) IsSetFooterSigningKeyMetadata() 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) ReadField7(iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField8(iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField9(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 IntType struct

+ BitWidth int8

+ IsSigned bool

+ var LogicalType_INTEGER_DEFAULT *IntType

+ func NewIntType() *IntType

+ func (p *IntType) GetBitWidth() int8

+ func (p *IntType) GetIsSigned() bool

+ func (p *IntType) Read(iprot thrift.TProtocol) error

+ func (p *IntType) ReadField1(iprot thrift.TProtocol) error

+ func (p *IntType) ReadField2(iprot thrift.TProtocol) error

+ func (p *IntType) String() string

+ func (p *IntType) Write(oprot thrift.TProtocol) error

+ type JsonType struct

+ var LogicalType_JSON_DEFAULT *JsonType

+ func NewJsonType() *JsonType

+ func (p *JsonType) Read(iprot thrift.TProtocol) error

+ func (p *JsonType) String() string

+ func (p *JsonType) 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 ListType struct

+ var LogicalType_LIST_DEFAULT *ListType

+ func NewListType() *ListType

+ func (p *ListType) Read(iprot thrift.TProtocol) error

+ func (p *ListType) String() string

+ func (p *ListType) Write(oprot thrift.TProtocol) error

+ type LogicalType struct

+ BSON *BsonType

+ DATE *DateType

+ DECIMAL *DecimalType

+ ENUM *EnumType

+ INTEGER *IntType

+ JSON *JsonType

+ LIST *ListType

+ MAP *MapType

+ STRING *StringType

+ TIME *TimeType

+ TIMESTAMP *TimestampType

+ UNKNOWN *NullType

+ UUID *UUIDType

+ var SchemaElement_LogicalType_DEFAULT *LogicalType

+ func NewLogicalType() *LogicalType

+ func (p *LogicalType) CountSetFieldsLogicalType() int

+ func (p *LogicalType) GetBSON() *BsonType

+ func (p *LogicalType) GetDATE() *DateType

+ func (p *LogicalType) GetDECIMAL() *DecimalType

+ func (p *LogicalType) GetENUM() *EnumType

+ func (p *LogicalType) GetINTEGER() *IntType

+ func (p *LogicalType) GetJSON() *JsonType

+ func (p *LogicalType) GetLIST() *ListType

+ func (p *LogicalType) GetMAP() *MapType

+ func (p *LogicalType) GetSTRING() *StringType

+ func (p *LogicalType) GetTIME() *TimeType

+ func (p *LogicalType) GetTIMESTAMP() *TimestampType

+ func (p *LogicalType) GetUNKNOWN() *NullType

+ func (p *LogicalType) GetUUID() *UUIDType

+ func (p *LogicalType) IsSetBSON() bool

+ func (p *LogicalType) IsSetDATE() bool

+ func (p *LogicalType) IsSetDECIMAL() bool

+ func (p *LogicalType) IsSetENUM() bool

+ func (p *LogicalType) IsSetINTEGER() bool

+ func (p *LogicalType) IsSetJSON() bool

+ func (p *LogicalType) IsSetLIST() bool

+ func (p *LogicalType) IsSetMAP() bool

+ func (p *LogicalType) IsSetSTRING() bool

+ func (p *LogicalType) IsSetTIME() bool

+ func (p *LogicalType) IsSetTIMESTAMP() bool

+ func (p *LogicalType) IsSetUNKNOWN() bool

+ func (p *LogicalType) IsSetUUID() bool

+ func (p *LogicalType) Read(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField1(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField10(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField11(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField12(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField13(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField14(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField2(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField3(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField4(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField5(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField6(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField7(iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField8(iprot thrift.TProtocol) error

+ func (p *LogicalType) String() string

+ func (p *LogicalType) Write(oprot thrift.TProtocol) error

+ type MapType struct

+ var LogicalType_MAP_DEFAULT *MapType

+ func NewMapType() *MapType

+ func (p *MapType) Read(iprot thrift.TProtocol) error

+ func (p *MapType) String() string

+ func (p *MapType) Write(oprot thrift.TProtocol) error

+ type MicroSeconds struct

+ var TimeUnit_MICROS_DEFAULT *MicroSeconds

+ func NewMicroSeconds() *MicroSeconds

+ func (p *MicroSeconds) Read(iprot thrift.TProtocol) error

+ func (p *MicroSeconds) String() string

+ func (p *MicroSeconds) Write(oprot thrift.TProtocol) error

+ type MilliSeconds struct

+ var TimeUnit_MILLIS_DEFAULT *MilliSeconds

+ func NewMilliSeconds() *MilliSeconds

+ func (p *MilliSeconds) Read(iprot thrift.TProtocol) error

+ func (p *MilliSeconds) String() string

+ func (p *MilliSeconds) Write(oprot thrift.TProtocol) error

+ type NanoSeconds struct

+ var TimeUnit_NANOS_DEFAULT *NanoSeconds

+ func NewNanoSeconds() *NanoSeconds

+ func (p *NanoSeconds) Read(iprot thrift.TProtocol) error

+ func (p *NanoSeconds) String() string

+ func (p *NanoSeconds) Write(oprot thrift.TProtocol) error

+ type NullType struct

+ var LogicalType_UNKNOWN_DEFAULT *NullType

+ func NewNullType() *NullType

+ func (p *NullType) Read(iprot thrift.TProtocol) error

+ func (p *NullType) String() string

+ func (p *NullType) Write(oprot thrift.TProtocol) error

+ type OffsetIndex struct

+ PageLocations []*PageLocation

+ func NewOffsetIndex() *OffsetIndex

+ func (p *OffsetIndex) GetPageLocations() []*PageLocation

+ func (p *OffsetIndex) Read(iprot thrift.TProtocol) error

+ func (p *OffsetIndex) ReadField1(iprot thrift.TProtocol) error

+ func (p *OffsetIndex) String() string

+ func (p *OffsetIndex) 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 PageLocation struct

+ CompressedPageSize int32

+ FirstRowIndex int64

+ Offset int64

+ func NewPageLocation() *PageLocation

+ func (p *PageLocation) GetCompressedPageSize() int32

+ func (p *PageLocation) GetFirstRowIndex() int64

+ func (p *PageLocation) GetOffset() int64

+ func (p *PageLocation) Read(iprot thrift.TProtocol) error

+ func (p *PageLocation) ReadField1(iprot thrift.TProtocol) error

+ func (p *PageLocation) ReadField2(iprot thrift.TProtocol) error

+ func (p *PageLocation) ReadField3(iprot thrift.TProtocol) error

+ func (p *PageLocation) String() string

+ func (p *PageLocation) 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

+ FileOffset *int64

+ NumRows int64

+ Ordinal *int16

+ SortingColumns []*SortingColumn

+ TotalByteSize int64

+ TotalCompressedSize *int64

+ func NewRowGroup() *RowGroup

+ func (p *RowGroup) GetColumns() []*ColumnChunk

+ func (p *RowGroup) GetFileOffset() int64

+ func (p *RowGroup) GetNumRows() int64

+ func (p *RowGroup) GetOrdinal() int16

+ func (p *RowGroup) GetSortingColumns() []*SortingColumn

+ func (p *RowGroup) GetTotalByteSize() int64

+ func (p *RowGroup) GetTotalCompressedSize() int64

+ func (p *RowGroup) IsSetFileOffset() bool

+ func (p *RowGroup) IsSetOrdinal() bool

+ func (p *RowGroup) IsSetSortingColumns() bool

+ func (p *RowGroup) IsSetTotalCompressedSize() 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) ReadField5(iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField6(iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField7(iprot thrift.TProtocol) error

+ func (p *RowGroup) String() string

+ func (p *RowGroup) Write(oprot thrift.TProtocol) error

+ type SchemaElement struct

+ ConvertedType *ConvertedType

+ FieldID *int32

+ LogicalType *LogicalType

+ 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) GetLogicalType() *LogicalType

+ 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) IsSetLogicalType() 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) ReadField10(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 SplitBlockAlgorithm struct

+ var BloomFilterAlgorithm_BLOCK_DEFAULT *SplitBlockAlgorithm

+ func NewSplitBlockAlgorithm() *SplitBlockAlgorithm

+ func (p *SplitBlockAlgorithm) Read(iprot thrift.TProtocol) error

+ func (p *SplitBlockAlgorithm) String() string

+ func (p *SplitBlockAlgorithm) Write(oprot thrift.TProtocol) error

+ type Statistics struct

+ DistinctCount *int64

+ Max []byte

+ MaxValue []byte

+ Min []byte

+ MinValue []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) GetMaxValue() []byte

+ func (p *Statistics) GetMin() []byte

+ func (p *Statistics) GetMinValue() []byte

+ func (p *Statistics) GetNullCount() int64

+ func (p *Statistics) IsSetDistinctCount() bool

+ func (p *Statistics) IsSetMax() bool

+ func (p *Statistics) IsSetMaxValue() bool

+ func (p *Statistics) IsSetMin() bool

+ func (p *Statistics) IsSetMinValue() 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) ReadField5(iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField6(iprot thrift.TProtocol) error

+ func (p *Statistics) String() string

+ func (p *Statistics) Write(oprot thrift.TProtocol) error

+ type StringType struct

+ var LogicalType_STRING_DEFAULT *StringType

+ func NewStringType() *StringType

+ func (p *StringType) Read(iprot thrift.TProtocol) error

+ func (p *StringType) String() string

+ func (p *StringType) Write(oprot thrift.TProtocol) error

+ type TimeType struct

+ IsAdjustedToUTC bool

+ Unit *TimeUnit

+ var LogicalType_TIME_DEFAULT *TimeType

+ func NewTimeType() *TimeType

+ func (p *TimeType) GetIsAdjustedToUTC() bool

+ func (p *TimeType) GetUnit() *TimeUnit

+ func (p *TimeType) IsSetUnit() bool

+ func (p *TimeType) Read(iprot thrift.TProtocol) error

+ func (p *TimeType) ReadField1(iprot thrift.TProtocol) error

+ func (p *TimeType) ReadField2(iprot thrift.TProtocol) error

+ func (p *TimeType) String() string

+ func (p *TimeType) Write(oprot thrift.TProtocol) error

+ type TimeUnit struct

+ MICROS *MicroSeconds

+ MILLIS *MilliSeconds

+ NANOS *NanoSeconds

+ var TimeType_Unit_DEFAULT *TimeUnit

+ var TimestampType_Unit_DEFAULT *TimeUnit

+ func NewTimeUnit() *TimeUnit

+ func (p *TimeUnit) CountSetFieldsTimeUnit() int

+ func (p *TimeUnit) GetMICROS() *MicroSeconds

+ func (p *TimeUnit) GetMILLIS() *MilliSeconds

+ func (p *TimeUnit) GetNANOS() *NanoSeconds

+ func (p *TimeUnit) IsSetMICROS() bool

+ func (p *TimeUnit) IsSetMILLIS() bool

+ func (p *TimeUnit) IsSetNANOS() bool

+ func (p *TimeUnit) Read(iprot thrift.TProtocol) error

+ func (p *TimeUnit) ReadField1(iprot thrift.TProtocol) error

+ func (p *TimeUnit) ReadField2(iprot thrift.TProtocol) error

+ func (p *TimeUnit) ReadField3(iprot thrift.TProtocol) error

+ func (p *TimeUnit) String() string

+ func (p *TimeUnit) Write(oprot thrift.TProtocol) error

+ type TimestampType struct

+ IsAdjustedToUTC bool

+ Unit *TimeUnit

+ var LogicalType_TIMESTAMP_DEFAULT *TimestampType

+ func NewTimestampType() *TimestampType

+ func (p *TimestampType) GetIsAdjustedToUTC() bool

+ func (p *TimestampType) GetUnit() *TimeUnit

+ func (p *TimestampType) IsSetUnit() bool

+ func (p *TimestampType) Read(iprot thrift.TProtocol) error

+ func (p *TimestampType) ReadField1(iprot thrift.TProtocol) error

+ func (p *TimestampType) ReadField2(iprot thrift.TProtocol) error

+ func (p *TimestampType) String() string

+ func (p *TimestampType) 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

+ type TypeDefinedOrder struct

+ var ColumnOrder_TYPE_ORDER_DEFAULT *TypeDefinedOrder

+ func NewTypeDefinedOrder() *TypeDefinedOrder

+ func (p *TypeDefinedOrder) Read(iprot thrift.TProtocol) error

+ func (p *TypeDefinedOrder) String() string

+ func (p *TypeDefinedOrder) Write(oprot thrift.TProtocol) error

+ type UUIDType struct

+ var LogicalType_UUID_DEFAULT *UUIDType

+ func NewUUIDType() *UUIDType

+ func (p *UUIDType) Read(iprot thrift.TProtocol) error

+ func (p *UUIDType) String() string

+ func (p *UUIDType) Write(oprot thrift.TProtocol) error

+ type Uncompressed struct

+ var BloomFilterCompression_UNCOMPRESSED_DEFAULT *Uncompressed

+ func NewUncompressed() *Uncompressed

+ func (p *Uncompressed) Read(iprot thrift.TProtocol) error

+ func (p *Uncompressed) String() string

+ func (p *Uncompressed) Write(oprot thrift.TProtocol) error

+ type XxHash struct

+ var BloomFilterHash_XXHASH_DEFAULT *XxHash

+ func NewXxHash() *XxHash

+ func (p *XxHash) Read(iprot thrift.TProtocol) error

+ func (p *XxHash) String() string

+ func (p *XxHash) Write(oprot thrift.TProtocol) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL