parquet

package

Go to main page

Versions in this module

v0

v0.8.0

Jul 20, 2023

Changes in this version

type BsonType

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

+ func (p *BsonType) Validate() error

type ColumnChunk

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

+ func (p *ColumnChunk) Validate() error

type ColumnIndex

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

+ func (p *ColumnIndex) Validate() error

type ColumnMetaData

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

+ func (p *ColumnMetaData) Validate() error

type ColumnOrder

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

+ func (p *ColumnOrder) Validate() error

type DataPageHeader

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

+ func (p *DataPageHeader) Validate() error

type DataPageHeaderV2

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

+ func (p *DataPageHeaderV2) Validate() error

type DateType

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

+ func (p *DateType) Validate() error

type DecimalType

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

+ func (p *DecimalType) Validate() error

type DictionaryPageHeader

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

+ func (p *DictionaryPageHeader) Validate() error

type EnumType

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

+ func (p *EnumType) Validate() error

type FileMetaData

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

+ func (p *FileMetaData) Validate() error

type IndexPageHeader

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

+ func (p *IndexPageHeader) Validate() error

type IntType

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

+ func (p *IntType) Validate() error

type JsonType

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

+ func (p *JsonType) Validate() error

type KeyValue

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

+ func (p *KeyValue) Validate() error

type ListType

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

+ func (p *ListType) Validate() error

type LogicalType

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

+ func (p *LogicalType) Validate() error

type MapType

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

+ func (p *MapType) Validate() error

type MicroSeconds

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

+ func (p *MicroSeconds) Validate() error

type MilliSeconds

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

+ func (p *MilliSeconds) Validate() error

type NanoSeconds

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

+ func (p *NanoSeconds) Validate() error

type NullType

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

+ func (p *NullType) Validate() error

type OffsetIndex

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

+ func (p *OffsetIndex) Validate() error

type PageEncodingStats

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

+ func (p *PageEncodingStats) Validate() error

type PageHeader

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

+ func (p *PageHeader) Validate() error

type PageLocation

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

+ func (p *PageLocation) Validate() error

type RowGroup

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

+ func (p *RowGroup) Validate() error

type SchemaElement

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

+ func (p *SchemaElement) Validate() error

type SortingColumn

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

+ func (p *SortingColumn) Validate() error

type Statistics

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

+ func (p *Statistics) Validate() error

type StringType

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

+ func (p *StringType) Validate() error

type TimeType

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

+ func (p *TimeType) Validate() error

type TimeUnit

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

+ func (p *TimeUnit) Validate() error

type TimestampType

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

+ func (p *TimestampType) Validate() error

type TypeDefinedOrder

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

+ func (p *TypeDefinedOrder) Validate() error

type UUIDType

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

+ func (p *UUIDType) Validate() error

v0.7.1

Oct 10, 2021

v0.7.0

Aug 19, 2021

v0.6.0

Aug 17, 2021

v0.5.0

Jun 18, 2021

v0.4.0

Oct 7, 2019

v0.3.6

Sep 8, 2019

v0.3.5

Sep 7, 2019

v0.3.4

Sep 4, 2019

v0.3.3

Aug 9, 2019

v0.3.2

Aug 8, 2019

v0.3.1

Aug 8, 2019

v0.3.0

Aug 7, 2019

Changes in this version

+ var ColumnChunk_ColumnIndexLength_DEFAULT int32

+ var ColumnChunk_ColumnIndexOffset_DEFAULT int64

+ 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 FileMetaData_ColumnOrders_DEFAULT []*ColumnOrder

+ var FileMetaData_CreatedBy_DEFAULT string

+ var FileMetaData_KeyValueMetadata_DEFAULT []*KeyValue

+ var GoUnusedProtection__ int

+ var KeyValue_Value_DEFAULT string

+ var PageHeader_Crc_DEFAULT int32

+ var RowGroup_SortingColumns_DEFAULT []*SortingColumn

+ var SchemaElement_FieldID_DEFAULT int32

+ var SchemaElement_NumChildren_DEFAULT int32

+ var SchemaElement_Precision_DEFAULT int32

+ var SchemaElement_Scale_DEFAULT int32

+ var SchemaElement_TypeLength_DEFAULT int32

+ var Statistics_DistinctCount_DEFAULT int64

+ var Statistics_MaxValue_DEFAULT []byte

+ var Statistics_Max_DEFAULT []byte

+ var Statistics_MinValue_DEFAULT []byte

+ var Statistics_Min_DEFAULT []byte

+ var Statistics_NullCount_DEFAULT int64

+ type BloomFilterAlgorithm struct

+ BLOCK *SplitBlockAlgorithm

+ var BloomFilterPageHeader_Algorithm_DEFAULT *BloomFilterAlgorithm

+ func NewBloomFilterAlgorithm() *BloomFilterAlgorithm

+ func (p *BloomFilterAlgorithm) CountSetFieldsBloomFilterAlgorithm() int

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

+ func (p *BloomFilterAlgorithm) IsSetBLOCK() bool

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

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

+ func (p *BloomFilterAlgorithm) String() string

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

+ type BloomFilterHash struct

+ MURMUR3 *Murmur3

+ var BloomFilterPageHeader_Hash_DEFAULT *BloomFilterHash

+ func NewBloomFilterHash() *BloomFilterHash

+ func (p *BloomFilterHash) CountSetFieldsBloomFilterHash() int

+ func (p *BloomFilterHash) GetMURMUR3() *Murmur3

+ func (p *BloomFilterHash) IsSetMURMUR3() bool

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

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

+ func (p *BloomFilterHash) String() string

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

+ type BloomFilterPageHeader struct

+ Algorithm *BloomFilterAlgorithm

+ Hash *BloomFilterHash

+ NumBytes int32

+ var PageHeader_BloomFilterPageHeader_DEFAULT *BloomFilterPageHeader

+ func NewBloomFilterPageHeader() *BloomFilterPageHeader

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

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

+ func (p *BloomFilterPageHeader) GetNumBytes() int32

+ func (p *BloomFilterPageHeader) IsSetAlgorithm() bool

+ func (p *BloomFilterPageHeader) IsSetHash() bool

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

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

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

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

+ func (p *BloomFilterPageHeader) String() string

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

+ type BoundaryOrder int64

+ const BoundaryOrder_ASCENDING

+ const BoundaryOrder_DESCENDING

+ const BoundaryOrder_UNORDERED

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

+ func BoundaryOrderPtr(v BoundaryOrder) *BoundaryOrder

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

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

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

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

+ func (p BoundaryOrder) String() string

+ type BsonType struct

+ var LogicalType_BSON_DEFAULT *BsonType

+ func NewBsonType() *BsonType

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

+ func (p *BsonType) String() string

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

+ type ColumnChunk struct

+ ColumnIndexLength *int32

+ ColumnIndexOffset *int64

+ FileOffset int64

+ FilePath *string

+ MetaData *ColumnMetaData

+ OffsetIndexLength *int32

+ OffsetIndexOffset *int64

+ func NewColumnChunk() *ColumnChunk

+ func (p *ColumnChunk) GetColumnIndexLength() int32

+ func (p *ColumnChunk) GetColumnIndexOffset() int64

+ func (p *ColumnChunk) 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) IsSetFilePath() bool

+ func (p *ColumnChunk) IsSetMetaData() bool

+ func (p *ColumnChunk) IsSetOffsetIndexLength() bool

+ func (p *ColumnChunk) IsSetOffsetIndexOffset() bool

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

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

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

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

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

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

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

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

+ func (p *ColumnChunk) String() string

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

+ type ColumnIndex struct

+ BoundaryOrder BoundaryOrder

+ MaxValues [][]byte

+ MinValues [][]byte

+ NullCounts []int64

+ NullPages []bool

+ func NewColumnIndex() *ColumnIndex

+ func (p *ColumnIndex) GetBoundaryOrder() BoundaryOrder

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

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

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

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

+ func (p *ColumnIndex) IsSetNullCounts() bool

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

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

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

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

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

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

+ func (p *ColumnIndex) String() string

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

+ type ColumnMetaData struct

+ BloomFilterOffset *int64

+ Codec CompressionCodec

+ DataPageOffset int64

+ DictionaryPageOffset *int64

+ EncodingStats []*PageEncodingStats

+ Encodings []Encoding

+ IndexPageOffset *int64

+ KeyValueMetadata []*KeyValue

+ NumValues int64

+ PathInSchema []string

+ Statistics *Statistics

+ TotalCompressedSize int64

+ TotalUncompressedSize int64

+ Type Type

+ var ColumnChunk_MetaData_DEFAULT *ColumnMetaData

+ func NewColumnMetaData() *ColumnMetaData

+ func (p *ColumnMetaData) GetBloomFilterOffset() int64

+ func (p *ColumnMetaData) GetCodec() CompressionCodec

+ func (p *ColumnMetaData) GetDataPageOffset() int64

+ func (p *ColumnMetaData) GetDictionaryPageOffset() int64

+ func (p *ColumnMetaData) GetEncodingStats() []*PageEncodingStats

+ func (p *ColumnMetaData) GetEncodings() []Encoding

+ func (p *ColumnMetaData) GetIndexPageOffset() int64

+ func (p *ColumnMetaData) GetKeyValueMetadata() []*KeyValue

+ func (p *ColumnMetaData) GetNumValues() int64

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

+ func (p *ColumnMetaData) GetStatistics() *Statistics

+ func (p *ColumnMetaData) GetTotalCompressedSize() int64

+ func (p *ColumnMetaData) GetTotalUncompressedSize() int64

+ func (p *ColumnMetaData) GetType() Type

+ func (p *ColumnMetaData) IsSetBloomFilterOffset() bool

+ func (p *ColumnMetaData) IsSetDictionaryPageOffset() bool

+ func (p *ColumnMetaData) IsSetEncodingStats() bool

+ func (p *ColumnMetaData) IsSetIndexPageOffset() bool

+ func (p *ColumnMetaData) IsSetKeyValueMetadata() bool

+ func (p *ColumnMetaData) IsSetStatistics() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *ColumnMetaData) String() string

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

+ type ColumnOrder struct

+ TYPE_ORDER *TypeDefinedOrder

+ func NewColumnOrder() *ColumnOrder

+ func (p *ColumnOrder) CountSetFieldsColumnOrder() int

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

+ func (p *ColumnOrder) IsSetTYPE_ORDER() bool

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

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

+ func (p *ColumnOrder) String() string

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

+ type CompressionCodec int64

+ const CompressionCodec_BROTLI

+ const CompressionCodec_GZIP

+ const CompressionCodec_LZ4

+ const CompressionCodec_LZO

+ const CompressionCodec_SNAPPY

+ const CompressionCodec_UNCOMPRESSED

+ const CompressionCodec_ZSTD

+ func CompressionCodecFromString(s string) (CompressionCodec, error)

+ func CompressionCodecPtr(v CompressionCodec) *CompressionCodec

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

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

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

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

+ func (p CompressionCodec) String() string

+ type ConvertedType int64

+ const ConvertedType_BSON

+ const ConvertedType_DATE

+ const ConvertedType_DECIMAL

+ const ConvertedType_ENUM

+ const ConvertedType_INTERVAL

+ const ConvertedType_INT_16

+ const ConvertedType_INT_32

+ const ConvertedType_INT_64

+ const ConvertedType_INT_8

+ const ConvertedType_JSON

+ const ConvertedType_LIST

+ const ConvertedType_MAP

+ const ConvertedType_MAP_KEY_VALUE

+ const ConvertedType_TIMESTAMP_MICROS

+ const ConvertedType_TIMESTAMP_MILLIS

+ const ConvertedType_TIME_MICROS

+ const ConvertedType_TIME_MILLIS

+ const ConvertedType_UINT_16

+ const ConvertedType_UINT_32

+ const ConvertedType_UINT_64

+ const ConvertedType_UINT_8

+ const ConvertedType_UTF8

+ var SchemaElement_ConvertedType_DEFAULT ConvertedType

+ func ConvertedTypeFromString(s string) (ConvertedType, error)

+ func ConvertedTypePtr(v ConvertedType) *ConvertedType

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

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

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

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

+ func (p ConvertedType) String() string

+ type DataPageHeader struct

+ DefinitionLevelEncoding Encoding

+ Encoding Encoding

+ NumValues int32

+ RepetitionLevelEncoding Encoding

+ Statistics *Statistics

+ var PageHeader_DataPageHeader_DEFAULT *DataPageHeader

+ func NewDataPageHeader() *DataPageHeader

+ func (p *DataPageHeader) GetDefinitionLevelEncoding() Encoding

+ func (p *DataPageHeader) GetEncoding() Encoding

+ func (p *DataPageHeader) GetNumValues() int32

+ func (p *DataPageHeader) GetRepetitionLevelEncoding() Encoding

+ func (p *DataPageHeader) GetStatistics() *Statistics

+ func (p *DataPageHeader) IsSetStatistics() bool

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

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

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

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

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

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

+ func (p *DataPageHeader) String() string

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

+ type DataPageHeaderV2 struct

+ DefinitionLevelsByteLength int32

+ Encoding Encoding

+ IsCompressed bool

+ NumNulls int32

+ NumRows int32

+ NumValues int32

+ RepetitionLevelsByteLength int32

+ Statistics *Statistics

+ var PageHeader_DataPageHeaderV2_DEFAULT *DataPageHeaderV2

+ func NewDataPageHeaderV2() *DataPageHeaderV2

+ func (p *DataPageHeaderV2) GetDefinitionLevelsByteLength() int32

+ func (p *DataPageHeaderV2) GetEncoding() Encoding

+ func (p *DataPageHeaderV2) GetIsCompressed() bool

+ func (p *DataPageHeaderV2) GetNumNulls() int32

+ func (p *DataPageHeaderV2) GetNumRows() int32

+ func (p *DataPageHeaderV2) GetNumValues() int32

+ func (p *DataPageHeaderV2) GetRepetitionLevelsByteLength() int32

+ func (p *DataPageHeaderV2) GetStatistics() *Statistics

+ func (p *DataPageHeaderV2) IsSetIsCompressed() bool

+ func (p *DataPageHeaderV2) IsSetStatistics() bool

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

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

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

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

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

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

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

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

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

+ func (p *DataPageHeaderV2) String() string

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

+ type DateType struct

+ var LogicalType_DATE_DEFAULT *DateType

+ func NewDateType() *DateType

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

+ func (p *DateType) String() string

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

+ type DecimalType struct

+ Precision int32

+ Scale int32

+ var LogicalType_DECIMAL_DEFAULT *DecimalType

+ func NewDecimalType() *DecimalType

+ func (p *DecimalType) GetPrecision() int32

+ func (p *DecimalType) GetScale() int32

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

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

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

+ func (p *DecimalType) String() string

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

+ type DictionaryPageHeader struct

+ Encoding Encoding

+ IsSorted *bool

+ NumValues int32

+ var PageHeader_DictionaryPageHeader_DEFAULT *DictionaryPageHeader

+ func NewDictionaryPageHeader() *DictionaryPageHeader

+ func (p *DictionaryPageHeader) GetEncoding() Encoding

+ func (p *DictionaryPageHeader) GetIsSorted() bool

+ func (p *DictionaryPageHeader) GetNumValues() int32

+ func (p *DictionaryPageHeader) IsSetIsSorted() bool

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

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

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

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

+ func (p *DictionaryPageHeader) String() string

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

+ type Encoding int64

+ const Encoding_BIT_PACKED

+ const Encoding_DELTA_BINARY_PACKED

+ const Encoding_DELTA_BYTE_ARRAY

+ const Encoding_DELTA_LENGTH_BYTE_ARRAY

+ const Encoding_PLAIN

+ const Encoding_PLAIN_DICTIONARY

+ const Encoding_RLE

+ const Encoding_RLE_DICTIONARY

+ func EncodingFromString(s string) (Encoding, error)

+ func EncodingPtr(v Encoding) *Encoding

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

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

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

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

+ func (p Encoding) String() string

+ type EnumType struct

+ var LogicalType_ENUM_DEFAULT *EnumType

+ func NewEnumType() *EnumType

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

+ func (p *EnumType) String() string

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

+ type FieldRepetitionType int64

+ const FieldRepetitionType_OPTIONAL

+ const FieldRepetitionType_REPEATED

+ const FieldRepetitionType_REQUIRED

+ var SchemaElement_RepetitionType_DEFAULT FieldRepetitionType

+ func FieldRepetitionTypeFromString(s string) (FieldRepetitionType, error)

+ func FieldRepetitionTypePtr(v FieldRepetitionType) *FieldRepetitionType

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

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

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

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

+ func (p FieldRepetitionType) String() string

+ type FileMetaData struct

+ ColumnOrders []*ColumnOrder

+ CreatedBy *string

+ KeyValueMetadata []*KeyValue

+ NumRows int64

+ RowGroups []*RowGroup

+ Schema []*SchemaElement

+ Version int32

+ func NewFileMetaData() *FileMetaData

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

+ func (p *FileMetaData) GetCreatedBy() string

+ func (p *FileMetaData) 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) IsSetKeyValueMetadata() bool

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

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

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

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

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

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

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

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

+ func (p *FileMetaData) String() string

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

+ type IndexPageHeader struct

+ var PageHeader_IndexPageHeader_DEFAULT *IndexPageHeader

+ func NewIndexPageHeader() *IndexPageHeader

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

+ func (p *IndexPageHeader) String() string

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

+ type IntType struct

+ BitWidth int8

+ IsSigned bool

+ var LogicalType_INTEGER_DEFAULT *IntType

+ func NewIntType() *IntType

+ func (p *IntType) GetBitWidth() int8

+ func (p *IntType) GetIsSigned() bool

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

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

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

+ func (p *IntType) String() string

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

+ type JsonType struct

+ var LogicalType_JSON_DEFAULT *JsonType

+ func NewJsonType() *JsonType

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

+ func (p *JsonType) String() string

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

+ type KeyValue struct

+ Key string

+ Value *string

+ func NewKeyValue() *KeyValue

+ func (p *KeyValue) GetKey() string

+ func (p *KeyValue) GetValue() string

+ func (p *KeyValue) IsSetValue() bool

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

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

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

+ func (p *KeyValue) String() string

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

+ type ListType struct

+ var LogicalType_LIST_DEFAULT *ListType

+ func NewListType() *ListType

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

+ func (p *ListType) String() string

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

+ type LogicalType struct

+ BSON *BsonType

+ DATE *DateType

+ DECIMAL *DecimalType

+ ENUM *EnumType

+ INTEGER *IntType

+ JSON *JsonType

+ LIST *ListType

+ MAP *MapType

+ STRING *StringType

+ TIME *TimeType

+ TIMESTAMP *TimestampType

+ UNKNOWN *NullType

+ UUID *UUIDType

+ var SchemaElement_LogicalType_DEFAULT *LogicalType

+ func NewLogicalType() *LogicalType

+ func (p *LogicalType) CountSetFieldsLogicalType() int

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *LogicalType) IsSetBSON() bool

+ func (p *LogicalType) IsSetDATE() bool

+ func (p *LogicalType) IsSetDECIMAL() bool

+ func (p *LogicalType) IsSetENUM() bool

+ func (p *LogicalType) IsSetINTEGER() bool

+ func (p *LogicalType) IsSetJSON() bool

+ func (p *LogicalType) IsSetLIST() bool

+ func (p *LogicalType) IsSetMAP() bool

+ func (p *LogicalType) IsSetSTRING() bool

+ func (p *LogicalType) IsSetTIME() bool

+ func (p *LogicalType) IsSetTIMESTAMP() bool

+ func (p *LogicalType) IsSetUNKNOWN() bool

+ func (p *LogicalType) IsSetUUID() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *LogicalType) String() string

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

+ type MapType struct

+ var LogicalType_MAP_DEFAULT *MapType

+ func NewMapType() *MapType

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

+ func (p *MapType) String() string

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

+ type MicroSeconds struct

+ var TimeUnit_MICROS_DEFAULT *MicroSeconds

+ func NewMicroSeconds() *MicroSeconds

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

+ func (p *MicroSeconds) String() string

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

+ type MilliSeconds struct

+ var TimeUnit_MILLIS_DEFAULT *MilliSeconds

+ func NewMilliSeconds() *MilliSeconds

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

+ func (p *MilliSeconds) String() string

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

+ type Murmur3 struct

+ var BloomFilterHash_MURMUR3_DEFAULT *Murmur3

+ func NewMurmur3() *Murmur3

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

+ func (p *Murmur3) String() string

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

+ type NanoSeconds struct

+ var TimeUnit_NANOS_DEFAULT *NanoSeconds

+ func NewNanoSeconds() *NanoSeconds

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

+ func (p *NanoSeconds) String() string

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

+ type NullType struct

+ var LogicalType_UNKNOWN_DEFAULT *NullType

+ func NewNullType() *NullType

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

+ func (p *NullType) String() string

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

+ type OffsetIndex struct

+ PageLocations []*PageLocation

+ func NewOffsetIndex() *OffsetIndex

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

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

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

+ func (p *OffsetIndex) String() string

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

+ type PageEncodingStats struct

+ Count int32

+ Encoding Encoding

+ PageType PageType

+ func NewPageEncodingStats() *PageEncodingStats

+ func (p *PageEncodingStats) GetCount() int32

+ func (p *PageEncodingStats) GetEncoding() Encoding

+ func (p *PageEncodingStats) GetPageType() PageType

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

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

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

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

+ func (p *PageEncodingStats) String() string

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

+ type PageHeader struct

+ BloomFilterPageHeader *BloomFilterPageHeader

+ CompressedPageSize int32

+ Crc *int32

+ DataPageHeader *DataPageHeader

+ DataPageHeaderV2 *DataPageHeaderV2

+ DictionaryPageHeader *DictionaryPageHeader

+ IndexPageHeader *IndexPageHeader

+ Type PageType

+ UncompressedPageSize int32

+ func NewPageHeader() *PageHeader

+ func (p *PageHeader) GetBloomFilterPageHeader() *BloomFilterPageHeader

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

+ func (p *PageHeader) IsSetCrc() bool

+ func (p *PageHeader) IsSetDataPageHeader() bool

+ func (p *PageHeader) IsSetDataPageHeaderV2() bool

+ func (p *PageHeader) IsSetDictionaryPageHeader() bool

+ func (p *PageHeader) IsSetIndexPageHeader() bool

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

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

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

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

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

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

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

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

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

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

+ func (p *PageHeader) String() string

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

+ type PageLocation struct

+ CompressedPageSize int32

+ FirstRowIndex int64

+ Offset int64

+ func NewPageLocation() *PageLocation

+ func (p *PageLocation) GetCompressedPageSize() int32

+ func (p *PageLocation) GetFirstRowIndex() int64

+ func (p *PageLocation) GetOffset() int64

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

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

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

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

+ func (p *PageLocation) String() string

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

+ type PageType int64

+ const PageType_BLOOM_FILTER_PAGE

+ const PageType_DATA_PAGE

+ const PageType_DATA_PAGE_V2

+ const PageType_DICTIONARY_PAGE

+ const PageType_INDEX_PAGE

+ func PageTypeFromString(s string) (PageType, error)

+ func PageTypePtr(v PageType) *PageType

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

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

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

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

+ func (p PageType) String() string

+ type RowGroup struct

+ Columns []*ColumnChunk

+ NumRows int64

+ SortingColumns []*SortingColumn

+ TotalByteSize int64

+ func NewRowGroup() *RowGroup

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

+ func (p *RowGroup) GetNumRows() int64

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

+ func (p *RowGroup) GetTotalByteSize() int64

+ func (p *RowGroup) IsSetSortingColumns() bool

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

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

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

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

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

+ func (p *RowGroup) String() string

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

+ type SchemaElement struct

+ ConvertedType *ConvertedType

+ FieldID *int32

+ LogicalType *LogicalType

+ Name string

+ NumChildren *int32

+ Precision *int32

+ RepetitionType *FieldRepetitionType

+ Scale *int32

+ Type *Type

+ TypeLength *int32

+ func NewSchemaElement() *SchemaElement

+ func (p *SchemaElement) GetConvertedType() ConvertedType

+ func (p *SchemaElement) GetFieldID() int32

+ func (p *SchemaElement) GetLogicalType() *LogicalType

+ func (p *SchemaElement) GetName() string

+ func (p *SchemaElement) GetNumChildren() int32

+ func (p *SchemaElement) GetPrecision() int32

+ func (p *SchemaElement) GetRepetitionType() FieldRepetitionType

+ func (p *SchemaElement) GetScale() int32

+ func (p *SchemaElement) GetType() Type

+ func (p *SchemaElement) GetTypeLength() int32

+ func (p *SchemaElement) IsSetConvertedType() bool

+ func (p *SchemaElement) IsSetFieldID() bool

+ func (p *SchemaElement) IsSetLogicalType() bool

+ func (p *SchemaElement) IsSetNumChildren() bool

+ func (p *SchemaElement) IsSetPrecision() bool

+ func (p *SchemaElement) IsSetRepetitionType() bool

+ func (p *SchemaElement) IsSetScale() bool

+ func (p *SchemaElement) IsSetType() bool

+ func (p *SchemaElement) IsSetTypeLength() bool

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

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

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

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

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

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

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

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

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

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

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

+ func (p *SchemaElement) String() string

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

+ type SortingColumn struct

+ ColumnIdx int32

+ Descending bool

+ NullsFirst bool

+ func NewSortingColumn() *SortingColumn

+ func (p *SortingColumn) GetColumnIdx() int32

+ func (p *SortingColumn) GetDescending() bool

+ func (p *SortingColumn) GetNullsFirst() bool

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

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

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

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

+ func (p *SortingColumn) String() string

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

+ type SplitBlockAlgorithm struct

+ var BloomFilterAlgorithm_BLOCK_DEFAULT *SplitBlockAlgorithm

+ func NewSplitBlockAlgorithm() *SplitBlockAlgorithm

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

+ func (p *SplitBlockAlgorithm) String() string

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

+ type Statistics struct

+ DistinctCount *int64

+ Max []byte

+ MaxValue []byte

+ Min []byte

+ MinValue []byte

+ NullCount *int64

+ var ColumnMetaData_Statistics_DEFAULT *Statistics

+ var DataPageHeaderV2_Statistics_DEFAULT *Statistics

+ var DataPageHeader_Statistics_DEFAULT *Statistics

+ func NewStatistics() *Statistics

+ func (p *Statistics) GetDistinctCount() int64

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

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

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

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

+ func (p *Statistics) GetNullCount() int64

+ func (p *Statistics) IsSetDistinctCount() bool

+ func (p *Statistics) IsSetMax() bool

+ func (p *Statistics) IsSetMaxValue() bool

+ func (p *Statistics) IsSetMin() bool

+ func (p *Statistics) IsSetMinValue() bool

+ func (p *Statistics) IsSetNullCount() bool

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

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

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

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

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

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

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

+ func (p *Statistics) String() string

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

+ type StringType struct

+ var LogicalType_STRING_DEFAULT *StringType

+ func NewStringType() *StringType

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

+ func (p *StringType) String() string

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

+ type TimeType struct

+ IsAdjustedToUTC bool

+ Unit *TimeUnit

+ var LogicalType_TIME_DEFAULT *TimeType

+ func NewTimeType() *TimeType

+ func (p *TimeType) GetIsAdjustedToUTC() bool

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

+ func (p *TimeType) IsSetUnit() bool

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

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

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

+ func (p *TimeType) String() string

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

+ type TimeUnit struct

+ MICROS *MicroSeconds

+ MILLIS *MilliSeconds

+ NANOS *NanoSeconds

+ var TimeType_Unit_DEFAULT *TimeUnit

+ var TimestampType_Unit_DEFAULT *TimeUnit

+ func NewTimeUnit() *TimeUnit

+ func (p *TimeUnit) CountSetFieldsTimeUnit() int

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

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

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

+ func (p *TimeUnit) IsSetMICROS() bool

+ func (p *TimeUnit) IsSetMILLIS() bool

+ func (p *TimeUnit) IsSetNANOS() bool

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

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

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

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

+ func (p *TimeUnit) String() string

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

+ type TimestampType struct

+ IsAdjustedToUTC bool

+ Unit *TimeUnit

+ var LogicalType_TIMESTAMP_DEFAULT *TimestampType

+ func NewTimestampType() *TimestampType

+ func (p *TimestampType) GetIsAdjustedToUTC() bool

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

+ func (p *TimestampType) IsSetUnit() bool

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

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

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

+ func (p *TimestampType) String() string

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

+ type Type int64

+ const Type_BOOLEAN

+ const Type_BYTE_ARRAY

+ const Type_DOUBLE

+ const Type_FIXED_LEN_BYTE_ARRAY

+ const Type_FLOAT

+ const Type_INT32

+ const Type_INT64

+ const Type_INT96

+ var SchemaElement_Type_DEFAULT Type

+ func TypeFromString(s string) (Type, error)

+ func TypePtr(v Type) *Type

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

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

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

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

+ func (p Type) String() string

+ type TypeDefinedOrder struct

+ var ColumnOrder_TYPE_ORDER_DEFAULT *TypeDefinedOrder

+ func NewTypeDefinedOrder() *TypeDefinedOrder

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

+ func (p *TypeDefinedOrder) String() string

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

+ type UUIDType struct

+ var LogicalType_UUID_DEFAULT *UUIDType

+ func NewUUIDType() *UUIDType

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

+ func (p *UUIDType) String() string

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

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