Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

parquet

package

Go to main page

Versions in this module

v0

v0.16.1

Sep 22, 2022

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) Equals(other *AesGcmCtrV1) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmCtrV1) String() string

+ func (p *AesGcmCtrV1) Write(ctx context.Context, 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) Equals(other *AesGcmV1) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmV1) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmV1) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmV1) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *AesGcmV1) String() string

+ func (p *AesGcmV1) Write(ctx context.Context, 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) Equals(other *BloomFilterAlgorithm) bool

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

+ func (p *BloomFilterAlgorithm) IsSetBLOCK() bool

+ func (p *BloomFilterAlgorithm) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterAlgorithm) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterAlgorithm) String() string

+ func (p *BloomFilterAlgorithm) Write(ctx context.Context, 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) Equals(other *BloomFilterCompression) bool

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

+ func (p *BloomFilterCompression) IsSetUNCOMPRESSED() bool

+ func (p *BloomFilterCompression) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterCompression) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterCompression) String() string

+ func (p *BloomFilterCompression) Write(ctx context.Context, 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) Equals(other *BloomFilterHash) bool

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

+ func (p *BloomFilterHash) IsSetXXHASH() bool

+ func (p *BloomFilterHash) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHash) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHash) String() string

+ func (p *BloomFilterHash) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type BloomFilterHeader struct

+ Algorithm *BloomFilterAlgorithm

+ Compression *BloomFilterCompression

+ Hash *BloomFilterHash

+ NumBytes int32

+ func NewBloomFilterHeader() *BloomFilterHeader

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

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BloomFilterHeader) String() string

+ func (p *BloomFilterHeader) Write(ctx context.Context, 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) Equals(other *BsonType) bool

+ func (p *BsonType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *BsonType) String() string

+ func (p *BsonType) Write(ctx context.Context, 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) Equals(other *ColumnChunk) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnChunk) String() string

+ func (p *ColumnChunk) Write(ctx context.Context, 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) Equals(other *ColumnCryptoMetaData) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnCryptoMetaData) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnCryptoMetaData) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnCryptoMetaData) String() string

+ func (p *ColumnCryptoMetaData) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type ColumnIndex struct

+ BoundaryOrder BoundaryOrder

+ MaxValues [][]byte

+ MinValues [][]byte

+ NullCounts []int64

+ NullPages []bool

+ func NewColumnIndex() *ColumnIndex

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

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnIndex) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnIndex) String() string

+ func (p *ColumnIndex) Write(ctx context.Context, 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) Equals(other *ColumnMetaData) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnMetaData) String() string

+ func (p *ColumnMetaData) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type ColumnOrder struct

+ TYPE_ORDER *TypeDefinedOrder

+ func NewColumnOrder() *ColumnOrder

+ func (p *ColumnOrder) CountSetFieldsColumnOrder() int

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

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

+ func (p *ColumnOrder) IsSetTYPE_ORDER() bool

+ func (p *ColumnOrder) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnOrder) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ColumnOrder) String() string

+ func (p *ColumnOrder) Write(ctx context.Context, 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) Equals(other *DataPageHeader) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeader) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeader) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeader) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeader) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeader) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeader) String() string

+ func (p *DataPageHeader) Write(ctx context.Context, 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) Equals(other *DataPageHeaderV2) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DataPageHeaderV2) String() string

+ func (p *DataPageHeaderV2) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type DateType struct

+ var LogicalType_DATE_DEFAULT *DateType

+ func NewDateType() *DateType

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

+ func (p *DateType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DateType) String() string

+ func (p *DateType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type DecimalType struct

+ Precision int32

+ Scale int32

+ var LogicalType_DECIMAL_DEFAULT *DecimalType

+ func NewDecimalType() *DecimalType

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

+ func (p *DecimalType) GetPrecision() int32

+ func (p *DecimalType) GetScale() int32

+ func (p *DecimalType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DecimalType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DecimalType) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DecimalType) String() string

+ func (p *DecimalType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type DictionaryPageHeader struct

+ Encoding Encoding

+ IsSorted *bool

+ NumValues int32

+ var PageHeader_DictionaryPageHeader_DEFAULT *DictionaryPageHeader

+ func NewDictionaryPageHeader() *DictionaryPageHeader

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

+ func (p *DictionaryPageHeader) GetEncoding() Encoding

+ func (p *DictionaryPageHeader) GetIsSorted() bool

+ func (p *DictionaryPageHeader) GetNumValues() int32

+ func (p *DictionaryPageHeader) IsSetIsSorted() bool

+ func (p *DictionaryPageHeader) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DictionaryPageHeader) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DictionaryPageHeader) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DictionaryPageHeader) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *DictionaryPageHeader) String() string

+ func (p *DictionaryPageHeader) Write(ctx context.Context, 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_MAX_ENUM_VALUE

+ 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) Equals(other *EncryptionAlgorithm) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionAlgorithm) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionAlgorithm) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionAlgorithm) String() string

+ func (p *EncryptionAlgorithm) Write(ctx context.Context, 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) Equals(other *EncryptionWithColumnKey) bool

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

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

+ func (p *EncryptionWithColumnKey) IsSetKeyMetadata() bool

+ func (p *EncryptionWithColumnKey) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionWithColumnKey) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionWithColumnKey) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionWithColumnKey) String() string

+ func (p *EncryptionWithColumnKey) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type EncryptionWithFooterKey struct

+ var ColumnCryptoMetaData_ENCRYPTION_WITH_FOOTER_KEY_DEFAULT *EncryptionWithFooterKey

+ func NewEncryptionWithFooterKey() *EncryptionWithFooterKey

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

+ func (p *EncryptionWithFooterKey) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EncryptionWithFooterKey) String() string

+ func (p *EncryptionWithFooterKey) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type EnumType struct

+ var LogicalType_ENUM_DEFAULT *EnumType

+ func NewEnumType() *EnumType

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

+ func (p *EnumType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *EnumType) String() string

+ func (p *EnumType) Write(ctx context.Context, 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) Equals(other *FileCryptoMetaData) bool

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

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

+ func (p *FileCryptoMetaData) IsSetEncryptionAlgorithm() bool

+ func (p *FileCryptoMetaData) IsSetKeyMetadata() bool

+ func (p *FileCryptoMetaData) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileCryptoMetaData) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileCryptoMetaData) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileCryptoMetaData) String() string

+ func (p *FileCryptoMetaData) Write(ctx context.Context, 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) Equals(other *FileMetaData) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *FileMetaData) String() string

+ func (p *FileMetaData) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type IndexPageHeader struct

+ var PageHeader_IndexPageHeader_DEFAULT *IndexPageHeader

+ func NewIndexPageHeader() *IndexPageHeader

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

+ func (p *IndexPageHeader) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *IndexPageHeader) String() string

+ func (p *IndexPageHeader) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type IntType struct

+ BitWidth int8

+ IsSigned bool

+ var LogicalType_INTEGER_DEFAULT *IntType

+ func NewIntType() *IntType

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

+ func (p *IntType) GetBitWidth() int8

+ func (p *IntType) GetIsSigned() bool

+ func (p *IntType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *IntType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *IntType) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *IntType) String() string

+ func (p *IntType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type JsonType struct

+ var LogicalType_JSON_DEFAULT *JsonType

+ func NewJsonType() *JsonType

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

+ func (p *JsonType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *JsonType) String() string

+ func (p *JsonType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type KeyValue struct

+ Key string

+ Value *string

+ func NewKeyValue() *KeyValue

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

+ func (p *KeyValue) GetKey() string

+ func (p *KeyValue) GetValue() string

+ func (p *KeyValue) IsSetValue() bool

+ func (p *KeyValue) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *KeyValue) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *KeyValue) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *KeyValue) String() string

+ func (p *KeyValue) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type ListType struct

+ var LogicalType_LIST_DEFAULT *ListType

+ func NewListType() *ListType

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

+ func (p *ListType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *ListType) String() string

+ func (p *ListType) Write(ctx context.Context, 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) Equals(other *LogicalType) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *LogicalType) String() string

+ func (p *LogicalType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type MapType struct

+ var LogicalType_MAP_DEFAULT *MapType

+ func NewMapType() *MapType

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

+ func (p *MapType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *MapType) String() string

+ func (p *MapType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type MicroSeconds struct

+ var TimeUnit_MICROS_DEFAULT *MicroSeconds

+ func NewMicroSeconds() *MicroSeconds

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

+ func (p *MicroSeconds) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *MicroSeconds) String() string

+ func (p *MicroSeconds) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type MilliSeconds struct

+ var TimeUnit_MILLIS_DEFAULT *MilliSeconds

+ func NewMilliSeconds() *MilliSeconds

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

+ func (p *MilliSeconds) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *MilliSeconds) String() string

+ func (p *MilliSeconds) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type NanoSeconds struct

+ var TimeUnit_NANOS_DEFAULT *NanoSeconds

+ func NewNanoSeconds() *NanoSeconds

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

+ func (p *NanoSeconds) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *NanoSeconds) String() string

+ func (p *NanoSeconds) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type NullType struct

+ var LogicalType_UNKNOWN_DEFAULT *NullType

+ func NewNullType() *NullType

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

+ func (p *NullType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *NullType) String() string

+ func (p *NullType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type OffsetIndex struct

+ PageLocations []*PageLocation

+ func NewOffsetIndex() *OffsetIndex

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

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

+ func (p *OffsetIndex) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *OffsetIndex) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *OffsetIndex) String() string

+ func (p *OffsetIndex) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type PageEncodingStats struct

+ Count int32

+ Encoding Encoding

+ PageType PageType

+ func NewPageEncodingStats() *PageEncodingStats

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

+ func (p *PageEncodingStats) GetCount() int32

+ func (p *PageEncodingStats) GetEncoding() Encoding

+ func (p *PageEncodingStats) GetPageType() PageType

+ func (p *PageEncodingStats) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageEncodingStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageEncodingStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageEncodingStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageEncodingStats) String() string

+ func (p *PageEncodingStats) Write(ctx context.Context, 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) Equals(other *PageHeader) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageHeader) String() string

+ func (p *PageHeader) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type PageLocation struct

+ CompressedPageSize int32

+ FirstRowIndex int64

+ Offset int64

+ func NewPageLocation() *PageLocation

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

+ func (p *PageLocation) GetCompressedPageSize() int32

+ func (p *PageLocation) GetFirstRowIndex() int64

+ func (p *PageLocation) GetOffset() int64

+ func (p *PageLocation) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageLocation) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageLocation) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageLocation) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *PageLocation) String() string

+ func (p *PageLocation) Write(ctx context.Context, 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) Equals(other *RowGroup) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *RowGroup) String() string

+ func (p *RowGroup) Write(ctx context.Context, 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) Equals(other *SchemaElement) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SchemaElement) String() string

+ func (p *SchemaElement) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type SortingColumn struct

+ ColumnIdx int32

+ Descending bool

+ NullsFirst bool

+ func NewSortingColumn() *SortingColumn

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

+ func (p *SortingColumn) GetColumnIdx() int32

+ func (p *SortingColumn) GetDescending() bool

+ func (p *SortingColumn) GetNullsFirst() bool

+ func (p *SortingColumn) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SortingColumn) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SortingColumn) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SortingColumn) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SortingColumn) String() string

+ func (p *SortingColumn) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type SplitBlockAlgorithm struct

+ var BloomFilterAlgorithm_BLOCK_DEFAULT *SplitBlockAlgorithm

+ func NewSplitBlockAlgorithm() *SplitBlockAlgorithm

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

+ func (p *SplitBlockAlgorithm) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *SplitBlockAlgorithm) String() string

+ func (p *SplitBlockAlgorithm) Write(ctx context.Context, 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) Equals(other *Statistics) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Statistics) String() string

+ func (p *Statistics) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type StringType struct

+ var LogicalType_STRING_DEFAULT *StringType

+ func NewStringType() *StringType

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

+ func (p *StringType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *StringType) String() string

+ func (p *StringType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TimeType struct

+ IsAdjustedToUTC bool

+ Unit *TimeUnit

+ var LogicalType_TIME_DEFAULT *TimeType

+ func NewTimeType() *TimeType

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

+ func (p *TimeType) GetIsAdjustedToUTC() bool

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

+ func (p *TimeType) IsSetUnit() bool

+ func (p *TimeType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeType) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeType) String() string

+ func (p *TimeType) Write(ctx context.Context, 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) Equals(other *TimeUnit) bool

+ 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(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeUnit) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeUnit) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeUnit) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimeUnit) String() string

+ func (p *TimeUnit) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TimestampType struct

+ IsAdjustedToUTC bool

+ Unit *TimeUnit

+ var LogicalType_TIMESTAMP_DEFAULT *TimestampType

+ func NewTimestampType() *TimestampType

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

+ func (p *TimestampType) GetIsAdjustedToUTC() bool

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

+ func (p *TimestampType) IsSetUnit() bool

+ func (p *TimestampType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimestampType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimestampType) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TimestampType) String() string

+ func (p *TimestampType) Write(ctx context.Context, 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

+ const Type_UBSAN_FORCE_WIDTH

+ 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) Equals(other *TypeDefinedOrder) bool

+ func (p *TypeDefinedOrder) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TypeDefinedOrder) String() string

+ func (p *TypeDefinedOrder) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type UUIDType struct

+ var LogicalType_UUID_DEFAULT *UUIDType

+ func NewUUIDType() *UUIDType

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

+ func (p *UUIDType) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *UUIDType) String() string

+ func (p *UUIDType) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type Uncompressed struct

+ var BloomFilterCompression_UNCOMPRESSED_DEFAULT *Uncompressed

+ func NewUncompressed() *Uncompressed

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

+ func (p *Uncompressed) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *Uncompressed) String() string

+ func (p *Uncompressed) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type XxHash struct

+ var BloomFilterHash_XXHASH_DEFAULT *XxHash

+ func NewXxHash() *XxHash

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

+ func (p *XxHash) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *XxHash) String() string

+ func (p *XxHash) Write(ctx context.Context, oprot thrift.TProtocol) error

v0.16.0

Aug 25, 2022

v0.13.1

Aug 25, 2022