parquet

package

Go to main page

Versions in this module

v1

v1.4.0

Sep 17, 2019

Changes in this version

+ var ColumnChunk_ColumnIndexLength_DEFAULT int32

+ var ColumnChunk_ColumnIndexOffset_DEFAULT int64

+ var ColumnChunk_OffsetIndexLength_DEFAULT int32

+ var ColumnChunk_OffsetIndexOffset_DEFAULT int64

+ var ColumnIndex_NullCounts_DEFAULT []int64

+ var FileMetaData_ColumnOrders_DEFAULT []*ColumnOrder

+ var Statistics_MaxValue_DEFAULT []byte

+ var Statistics_MinValue_DEFAULT []byte

+ 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

+ ColumnIndexLength *int32

+ ColumnIndexOffset *int64

+ OffsetIndexLength *int32

+ OffsetIndexOffset *int64

+ func (p *ColumnChunk) GetColumnIndexLength() int32

+ func (p *ColumnChunk) GetColumnIndexOffset() int64

+ func (p *ColumnChunk) GetOffsetIndexLength() int32

+ func (p *ColumnChunk) GetOffsetIndexOffset() int64

+ func (p *ColumnChunk) IsSetColumnIndexLength() bool

+ func (p *ColumnChunk) IsSetColumnIndexOffset() bool

+ func (p *ColumnChunk) IsSetOffsetIndexLength() bool

+ func (p *ColumnChunk) IsSetOffsetIndexOffset() bool

+ 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

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

+ const CompressionCodec_BROTLI

+ const CompressionCodec_LZ4

+ const CompressionCodec_ZSTD

+ 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 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 FileMetaData

+ ColumnOrders []*ColumnOrder

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

+ func (p *FileMetaData) IsSetColumnOrders() bool

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

+ var LogicalType_LIST_DEFAULT *ListType

+ func NewListType() *ListType

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

+ func (p *ListType) String() string

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

+ type LogicalType struct

+ BSON *BsonType

+ DATE *DateType

+ DECIMAL *DecimalType

+ ENUM *EnumType

+ INTEGER *IntType

+ JSON *JsonType

+ LIST *ListType

+ MAP *MapType

+ STRING *StringType

+ TIME *TimeType

+ TIMESTAMP *TimestampType

+ UNKNOWN *NullType

+ UUID *UUIDType

+ var SchemaElement_LogicalType_DEFAULT *LogicalType

+ func NewLogicalType() *LogicalType

+ func (p *LogicalType) CountSetFieldsLogicalType() int

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *LogicalType) IsSetBSON() bool

+ func (p *LogicalType) IsSetDATE() bool

+ func (p *LogicalType) IsSetDECIMAL() bool

+ func (p *LogicalType) IsSetENUM() bool

+ func (p *LogicalType) IsSetINTEGER() bool

+ func (p *LogicalType) IsSetJSON() bool

+ func (p *LogicalType) IsSetLIST() bool

+ func (p *LogicalType) IsSetMAP() bool

+ func (p *LogicalType) IsSetSTRING() bool

+ func (p *LogicalType) IsSetTIME() bool

+ func (p *LogicalType) IsSetTIMESTAMP() bool

+ func (p *LogicalType) IsSetUNKNOWN() bool

+ func (p *LogicalType) IsSetUUID() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *LogicalType) String() string

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

+ type MapType struct

+ var LogicalType_MAP_DEFAULT *MapType

+ func NewMapType() *MapType

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

+ func (p *MapType) String() string

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

+ type MicroSeconds struct

+ var TimeUnit_MICROS_DEFAULT *MicroSeconds

+ func NewMicroSeconds() *MicroSeconds

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

+ func (p *MicroSeconds) String() string

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

+ type MilliSeconds struct

+ var TimeUnit_MILLIS_DEFAULT *MilliSeconds

+ func NewMilliSeconds() *MilliSeconds

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

+ func (p *MilliSeconds) String() string

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

+ type NanoSeconds struct

+ var TimeUnit_NANOS_DEFAULT *NanoSeconds

+ func NewNanoSeconds() *NanoSeconds

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

+ func (p *NanoSeconds) String() string

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

+ type NullType struct

+ var LogicalType_UNKNOWN_DEFAULT *NullType

+ func NewNullType() *NullType

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

+ func (p *NullType) String() string

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

+ type OffsetIndex struct

+ PageLocations []*PageLocation

+ func NewOffsetIndex() *OffsetIndex

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

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

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

+ func (p *OffsetIndex) String() string

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

+ type 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 SchemaElement

+ LogicalType *LogicalType

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

+ func (p *SchemaElement) IsSetLogicalType() bool

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

type Statistics

+ MaxValue []byte

+ MinValue []byte

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

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

+ func (p *Statistics) IsSetMaxValue() bool

+ func (p *Statistics) IsSetMinValue() bool

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

+ func (p *Statistics) ReadField6(iprot 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 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

v1.3.5

Sep 2, 2019

v1.3.0

May 24, 2019

Changes in this version

+ var ColumnChunk_FilePath_DEFAULT string

+ var ColumnMetaData_DictionaryPageOffset_DEFAULT int64

+ var ColumnMetaData_EncodingStats_DEFAULT []*PageEncodingStats

+ var ColumnMetaData_IndexPageOffset_DEFAULT int64

+ var ColumnMetaData_KeyValueMetadata_DEFAULT []*KeyValue

+ var DataPageHeaderV2_IsCompressed_DEFAULT bool = true

+ var DictionaryPageHeader_IsSorted_DEFAULT bool

+ var FileMetaData_CreatedBy_DEFAULT string

+ var FileMetaData_KeyValueMetadata_DEFAULT []*KeyValue

+ var GoUnusedProtection__ int

+ var KeyValue_Value_DEFAULT string

+ var PageHeader_Crc_DEFAULT int32

+ var RowGroup_SortingColumns_DEFAULT []*SortingColumn

+ var SchemaElement_FieldID_DEFAULT int32

+ var SchemaElement_NumChildren_DEFAULT int32

+ var SchemaElement_Precision_DEFAULT int32

+ var SchemaElement_Scale_DEFAULT int32

+ var SchemaElement_TypeLength_DEFAULT int32

+ var Statistics_DistinctCount_DEFAULT int64

+ var Statistics_Max_DEFAULT []byte

+ var Statistics_Min_DEFAULT []byte

+ var Statistics_NullCount_DEFAULT int64

+ type ColumnChunk struct

+ FileOffset int64

+ FilePath *string

+ MetaData *ColumnMetaData

+ func NewColumnChunk() *ColumnChunk

+ func (p *ColumnChunk) GetFileOffset() int64

+ func (p *ColumnChunk) GetFilePath() string

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

+ func (p *ColumnChunk) IsSetFilePath() bool

+ func (p *ColumnChunk) IsSetMetaData() bool

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

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

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

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

+ func (p *ColumnChunk) String() string

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

+ type ColumnMetaData struct

+ Codec CompressionCodec

+ DataPageOffset int64

+ DictionaryPageOffset *int64

+ EncodingStats []*PageEncodingStats

+ Encodings []Encoding

+ IndexPageOffset *int64

+ KeyValueMetadata []*KeyValue

+ NumValues int64

+ PathInSchema []string

+ Statistics *Statistics

+ TotalCompressedSize int64

+ TotalUncompressedSize int64

+ Type Type

+ var ColumnChunk_MetaData_DEFAULT *ColumnMetaData

+ func NewColumnMetaData() *ColumnMetaData

+ func (p *ColumnMetaData) GetCodec() CompressionCodec

+ func (p *ColumnMetaData) GetDataPageOffset() int64

+ func (p *ColumnMetaData) GetDictionaryPageOffset() int64

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

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

+ func (p *ColumnMetaData) GetIndexPageOffset() int64

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

+ func (p *ColumnMetaData) GetNumValues() int64

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

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

+ func (p *ColumnMetaData) GetTotalCompressedSize() int64

+ func (p *ColumnMetaData) GetTotalUncompressedSize() int64

+ func (p *ColumnMetaData) GetType() Type

+ func (p *ColumnMetaData) IsSetDictionaryPageOffset() bool

+ func (p *ColumnMetaData) IsSetEncodingStats() bool

+ func (p *ColumnMetaData) IsSetIndexPageOffset() bool

+ func (p *ColumnMetaData) IsSetKeyValueMetadata() bool

+ func (p *ColumnMetaData) IsSetStatistics() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *ColumnMetaData) String() string

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

+ type CompressionCodec int64

+ const CompressionCodec_GZIP

+ const CompressionCodec_LZO

+ const CompressionCodec_SNAPPY

+ const CompressionCodec_UNCOMPRESSED

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

+ func CompressionCodecPtr(v CompressionCodec) *CompressionCodec

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

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

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

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

+ func (p CompressionCodec) String() string

+ type ConvertedType int64

+ const ConvertedType_BSON

+ const ConvertedType_DATE

+ const ConvertedType_DECIMAL

+ const ConvertedType_ENUM

+ const ConvertedType_INTERVAL

+ const ConvertedType_INT_16

+ const ConvertedType_INT_32

+ const ConvertedType_INT_64

+ const ConvertedType_INT_8

+ const ConvertedType_JSON

+ const ConvertedType_LIST

+ const ConvertedType_MAP

+ const ConvertedType_MAP_KEY_VALUE

+ const ConvertedType_TIMESTAMP_MICROS

+ const ConvertedType_TIMESTAMP_MILLIS

+ const ConvertedType_TIME_MICROS

+ const ConvertedType_TIME_MILLIS

+ const ConvertedType_UINT_16

+ const ConvertedType_UINT_32

+ const ConvertedType_UINT_64

+ const ConvertedType_UINT_8

+ const ConvertedType_UTF8

+ var SchemaElement_ConvertedType_DEFAULT ConvertedType

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

+ func ConvertedTypePtr(v ConvertedType) *ConvertedType

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

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

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

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

+ func (p ConvertedType) String() string

+ type DataPageHeader struct

+ DefinitionLevelEncoding Encoding

+ Encoding Encoding

+ NumValues int32

+ RepetitionLevelEncoding Encoding

+ Statistics *Statistics

+ var PageHeader_DataPageHeader_DEFAULT *DataPageHeader

+ func NewDataPageHeader() *DataPageHeader

+ func (p *DataPageHeader) GetDefinitionLevelEncoding() Encoding

+ func (p *DataPageHeader) GetEncoding() Encoding

+ func (p *DataPageHeader) GetNumValues() int32

+ func (p *DataPageHeader) GetRepetitionLevelEncoding() Encoding

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

+ func (p *DataPageHeader) IsSetStatistics() bool

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

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

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

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

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

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

+ func (p *DataPageHeader) String() string

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

+ type DataPageHeaderV2 struct

+ DefinitionLevelsByteLength int32

+ Encoding Encoding

+ IsCompressed bool

+ NumNulls int32

+ NumRows int32

+ NumValues int32

+ RepetitionLevelsByteLength int32

+ Statistics *Statistics

+ var PageHeader_DataPageHeaderV2_DEFAULT *DataPageHeaderV2

+ func NewDataPageHeaderV2() *DataPageHeaderV2

+ func (p *DataPageHeaderV2) GetDefinitionLevelsByteLength() int32

+ func (p *DataPageHeaderV2) GetEncoding() Encoding

+ func (p *DataPageHeaderV2) GetIsCompressed() bool

+ func (p *DataPageHeaderV2) GetNumNulls() int32

+ func (p *DataPageHeaderV2) GetNumRows() int32

+ func (p *DataPageHeaderV2) GetNumValues() int32

+ func (p *DataPageHeaderV2) GetRepetitionLevelsByteLength() int32

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

+ func (p *DataPageHeaderV2) IsSetIsCompressed() bool

+ func (p *DataPageHeaderV2) IsSetStatistics() bool

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

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

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

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

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

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

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

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

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

+ func (p *DataPageHeaderV2) String() string

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

+ type DictionaryPageHeader struct

+ Encoding Encoding

+ IsSorted *bool

+ NumValues int32

+ var PageHeader_DictionaryPageHeader_DEFAULT *DictionaryPageHeader

+ func NewDictionaryPageHeader() *DictionaryPageHeader

+ func (p *DictionaryPageHeader) GetEncoding() Encoding

+ func (p *DictionaryPageHeader) GetIsSorted() bool

+ func (p *DictionaryPageHeader) GetNumValues() int32

+ func (p *DictionaryPageHeader) IsSetIsSorted() bool

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

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

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

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

+ func (p *DictionaryPageHeader) String() string

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

+ type Encoding int64

+ const Encoding_BIT_PACKED

+ const Encoding_DELTA_BINARY_PACKED

+ const Encoding_DELTA_BYTE_ARRAY

+ const Encoding_DELTA_LENGTH_BYTE_ARRAY

+ const Encoding_PLAIN

+ const Encoding_PLAIN_DICTIONARY

+ const Encoding_RLE

+ const Encoding_RLE_DICTIONARY

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

+ func EncodingPtr(v Encoding) *Encoding

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

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

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

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

+ func (p Encoding) String() string

+ type FieldRepetitionType int64

+ const FieldRepetitionType_OPTIONAL

+ const FieldRepetitionType_REPEATED

+ const FieldRepetitionType_REQUIRED

+ var SchemaElement_RepetitionType_DEFAULT FieldRepetitionType

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

+ func FieldRepetitionTypePtr(v FieldRepetitionType) *FieldRepetitionType

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

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

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

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

+ func (p FieldRepetitionType) String() string

+ type FileMetaData struct

+ CreatedBy *string

+ KeyValueMetadata []*KeyValue

+ NumRows int64

+ RowGroups []*RowGroup

+ Schema []*SchemaElement

+ Version int32

+ func NewFileMetaData() *FileMetaData

+ func (p *FileMetaData) GetCreatedBy() string

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

+ func (p *FileMetaData) GetNumRows() int64

+ func (p *FileMetaData) GetRowGroups() []*RowGroup

+ func (p *FileMetaData) GetSchema() []*SchemaElement

+ func (p *FileMetaData) GetVersion() int32

+ func (p *FileMetaData) IsSetCreatedBy() bool

+ func (p *FileMetaData) IsSetKeyValueMetadata() bool

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

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

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

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

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

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

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

+ func (p *FileMetaData) String() string

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

+ type IndexPageHeader struct

+ var PageHeader_IndexPageHeader_DEFAULT *IndexPageHeader

+ func NewIndexPageHeader() *IndexPageHeader

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

+ func (p *IndexPageHeader) String() string

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

+ type KeyValue struct

+ Key string

+ Value *string

+ func NewKeyValue() *KeyValue

+ func (p *KeyValue) GetKey() string

+ func (p *KeyValue) GetValue() string

+ func (p *KeyValue) IsSetValue() bool

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

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

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

+ func (p *KeyValue) String() string

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

+ type PageEncodingStats struct

+ Count int32

+ Encoding Encoding

+ PageType PageType

+ func NewPageEncodingStats() *PageEncodingStats

+ func (p *PageEncodingStats) GetCount() int32

+ func (p *PageEncodingStats) GetEncoding() Encoding

+ func (p *PageEncodingStats) GetPageType() PageType

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

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

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

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

+ func (p *PageEncodingStats) String() string

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

+ type PageHeader struct

+ CompressedPageSize int32

+ Crc *int32

+ DataPageHeader *DataPageHeader

+ DataPageHeaderV2 *DataPageHeaderV2

+ DictionaryPageHeader *DictionaryPageHeader

+ IndexPageHeader *IndexPageHeader

+ Type PageType

+ UncompressedPageSize int32

+ func NewPageHeader() *PageHeader

+ func (p *PageHeader) GetCompressedPageSize() int32

+ func (p *PageHeader) GetCrc() int32

+ func (p *PageHeader) GetDataPageHeader() *DataPageHeader

+ func (p *PageHeader) GetDataPageHeaderV2() *DataPageHeaderV2

+ func (p *PageHeader) GetDictionaryPageHeader() *DictionaryPageHeader

+ func (p *PageHeader) GetIndexPageHeader() *IndexPageHeader

+ func (p *PageHeader) GetType() PageType

+ func (p *PageHeader) GetUncompressedPageSize() int32

+ func (p *PageHeader) IsSetCrc() bool

+ func (p *PageHeader) IsSetDataPageHeader() bool

+ func (p *PageHeader) IsSetDataPageHeaderV2() bool

+ func (p *PageHeader) IsSetDictionaryPageHeader() bool

+ func (p *PageHeader) IsSetIndexPageHeader() bool

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

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

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

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

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

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

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

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

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

+ func (p *PageHeader) String() string

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

+ type PageType int64

+ const PageType_DATA_PAGE

+ const PageType_DATA_PAGE_V2

+ const PageType_DICTIONARY_PAGE

+ const PageType_INDEX_PAGE

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

+ func PageTypePtr(v PageType) *PageType

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

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

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

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

+ func (p PageType) String() string

+ type RowGroup struct

+ Columns []*ColumnChunk

+ NumRows int64

+ SortingColumns []*SortingColumn

+ TotalByteSize int64

+ func NewRowGroup() *RowGroup

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

+ func (p *RowGroup) GetNumRows() int64

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

+ func (p *RowGroup) GetTotalByteSize() int64

+ func (p *RowGroup) IsSetSortingColumns() bool

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

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

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

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

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

+ func (p *RowGroup) String() string

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

+ type SchemaElement struct

+ ConvertedType *ConvertedType

+ FieldID *int32

+ Name string

+ NumChildren *int32

+ Precision *int32

+ RepetitionType *FieldRepetitionType

+ Scale *int32

+ Type *Type

+ TypeLength *int32

+ func NewSchemaElement() *SchemaElement

+ func (p *SchemaElement) GetConvertedType() ConvertedType

+ func (p *SchemaElement) GetFieldID() int32

+ func (p *SchemaElement) GetName() string

+ func (p *SchemaElement) GetNumChildren() int32

+ func (p *SchemaElement) GetPrecision() int32

+ func (p *SchemaElement) GetRepetitionType() FieldRepetitionType

+ func (p *SchemaElement) GetScale() int32

+ func (p *SchemaElement) GetType() Type

+ func (p *SchemaElement) GetTypeLength() int32

+ func (p *SchemaElement) IsSetConvertedType() bool

+ func (p *SchemaElement) IsSetFieldID() bool

+ func (p *SchemaElement) IsSetNumChildren() bool

+ func (p *SchemaElement) IsSetPrecision() bool

+ func (p *SchemaElement) IsSetRepetitionType() bool

+ func (p *SchemaElement) IsSetScale() bool

+ func (p *SchemaElement) IsSetType() bool

+ func (p *SchemaElement) IsSetTypeLength() bool

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

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

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

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

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

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

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

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

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

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

+ func (p *SchemaElement) String() string

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

+ type SortingColumn struct

+ ColumnIdx int32

+ Descending bool

+ NullsFirst bool

+ func NewSortingColumn() *SortingColumn

+ func (p *SortingColumn) GetColumnIdx() int32

+ func (p *SortingColumn) GetDescending() bool

+ func (p *SortingColumn) GetNullsFirst() bool

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

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

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

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

+ func (p *SortingColumn) String() string

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

+ type Statistics struct

+ DistinctCount *int64

+ Max []byte

+ Min []byte

+ NullCount *int64

+ var ColumnMetaData_Statistics_DEFAULT *Statistics

+ var DataPageHeaderV2_Statistics_DEFAULT *Statistics

+ var DataPageHeader_Statistics_DEFAULT *Statistics

+ func NewStatistics() *Statistics

+ func (p *Statistics) GetDistinctCount() int64

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

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

+ func (p *Statistics) GetNullCount() int64

+ func (p *Statistics) IsSetDistinctCount() bool

+ func (p *Statistics) IsSetMax() bool

+ func (p *Statistics) IsSetMin() bool

+ func (p *Statistics) IsSetNullCount() bool

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

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

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

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

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

+ func (p *Statistics) String() string

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

+ type Type int64

+ const Type_BOOLEAN

+ const Type_BYTE_ARRAY

+ const Type_DOUBLE

+ const Type_FIXED_LEN_BYTE_ARRAY

+ const Type_FLOAT

+ const Type_INT32

+ const Type_INT64

+ const Type_INT96

+ var SchemaElement_Type_DEFAULT Type

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

+ func TypePtr(v Type) *Type

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

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

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

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

+ func (p Type) String() string

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