Versions in this module Expand all Collapse all 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
Go to main page