Documentation
¶
Index ¶
- Variables
- type ColumnDesc
- func (*ColumnDesc) Descriptor() ([]byte, []int)
- func (this *ColumnDesc) Equal(that interface{}) bool
- func (m *ColumnDesc) GetColumnMetadataLength() uint64
- func (m *ColumnDesc) GetColumnMetadataOffset() uint64
- func (m *ColumnDesc) GetCompressedSize() uint64
- func (m *ColumnDesc) GetCompression() CompressionType
- func (m *ColumnDesc) GetPagesCount() uint64
- func (m *ColumnDesc) GetRowsCount() uint64
- func (m *ColumnDesc) GetStatistics() *Statistics
- func (m *ColumnDesc) GetTagRef() uint32
- func (m *ColumnDesc) GetType() *ColumnType
- func (m *ColumnDesc) GetUncompressedSize() uint64
- func (m *ColumnDesc) GetValuesCount() uint64
- func (this *ColumnDesc) GoString() string
- func (m *ColumnDesc) Marshal() (dAtA []byte, err error)
- func (m *ColumnDesc) MarshalTo(dAtA []byte) (int, error)
- func (m *ColumnDesc) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ColumnDesc) ProtoMessage()
- func (m *ColumnDesc) Reset()
- func (m *ColumnDesc) Size() (n int)
- func (this *ColumnDesc) String() string
- func (m *ColumnDesc) Unmarshal(dAtA []byte) error
- func (m *ColumnDesc) XXX_DiscardUnknown()
- func (m *ColumnDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnDesc) XXX_Merge(src proto.Message)
- func (m *ColumnDesc) XXX_Size() int
- func (m *ColumnDesc) XXX_Unmarshal(b []byte) error
- type ColumnMetadata
- func (*ColumnMetadata) Descriptor() ([]byte, []int)
- func (this *ColumnMetadata) Equal(that interface{}) bool
- func (m *ColumnMetadata) GetPages() []*PageDesc
- func (this *ColumnMetadata) GoString() string
- func (m *ColumnMetadata) Marshal() (dAtA []byte, err error)
- func (m *ColumnMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *ColumnMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ColumnMetadata) ProtoMessage()
- func (m *ColumnMetadata) Reset()
- func (m *ColumnMetadata) Size() (n int)
- func (this *ColumnMetadata) String() string
- func (m *ColumnMetadata) Unmarshal(dAtA []byte) error
- func (m *ColumnMetadata) XXX_DiscardUnknown()
- func (m *ColumnMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnMetadata) XXX_Merge(src proto.Message)
- func (m *ColumnMetadata) XXX_Size() int
- func (m *ColumnMetadata) XXX_Unmarshal(b []byte) error
- type ColumnType
- func (*ColumnType) Descriptor() ([]byte, []int)
- func (this *ColumnType) Equal(that interface{}) bool
- func (m *ColumnType) GetLogicalRef() uint32
- func (m *ColumnType) GetPhysical() PhysicalType
- func (this *ColumnType) GoString() string
- func (m *ColumnType) Marshal() (dAtA []byte, err error)
- func (m *ColumnType) MarshalTo(dAtA []byte) (int, error)
- func (m *ColumnType) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ColumnType) ProtoMessage()
- func (m *ColumnType) Reset()
- func (m *ColumnType) Size() (n int)
- func (this *ColumnType) String() string
- func (m *ColumnType) Unmarshal(dAtA []byte) error
- func (m *ColumnType) XXX_DiscardUnknown()
- func (m *ColumnType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnType) XXX_Merge(src proto.Message)
- func (m *ColumnType) XXX_Size() int
- func (m *ColumnType) XXX_Unmarshal(b []byte) error
- type CompressionType
- type EncodingType
- type PageDesc
- func (*PageDesc) Descriptor() ([]byte, []int)
- func (this *PageDesc) Equal(that interface{}) bool
- func (m *PageDesc) GetCompressedSize() uint64
- func (m *PageDesc) GetCrc32() uint32
- func (m *PageDesc) GetDataOffset() uint64
- func (m *PageDesc) GetDataSize() uint64
- func (m *PageDesc) GetEncoding() EncodingType
- func (m *PageDesc) GetRowsCount() uint64
- func (m *PageDesc) GetStatistics() *Statistics
- func (m *PageDesc) GetUncompressedSize() uint64
- func (m *PageDesc) GetValuesCount() uint64
- func (this *PageDesc) GoString() string
- func (m *PageDesc) Marshal() (dAtA []byte, err error)
- func (m *PageDesc) MarshalTo(dAtA []byte) (int, error)
- func (m *PageDesc) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PageDesc) ProtoMessage()
- func (m *PageDesc) Reset()
- func (m *PageDesc) Size() (n int)
- func (this *PageDesc) String() string
- func (m *PageDesc) Unmarshal(dAtA []byte) error
- func (m *PageDesc) XXX_DiscardUnknown()
- func (m *PageDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PageDesc) XXX_Merge(src proto.Message)
- func (m *PageDesc) XXX_Size() int
- func (m *PageDesc) XXX_Unmarshal(b []byte) error
- type PhysicalType
- type SectionInfoExtension
- func (*SectionInfoExtension) Descriptor() ([]byte, []int)
- func (this *SectionInfoExtension) Equal(that interface{}) bool
- func (m *SectionInfoExtension) GetSectionMetadataLength() uint64
- func (m *SectionInfoExtension) GetSectionMetadataOffset() uint64
- func (this *SectionInfoExtension) GoString() string
- func (m *SectionInfoExtension) Marshal() (dAtA []byte, err error)
- func (m *SectionInfoExtension) MarshalTo(dAtA []byte) (int, error)
- func (m *SectionInfoExtension) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SectionInfoExtension) ProtoMessage()
- func (m *SectionInfoExtension) Reset()
- func (m *SectionInfoExtension) Size() (n int)
- func (this *SectionInfoExtension) String() string
- func (m *SectionInfoExtension) Unmarshal(dAtA []byte) error
- func (m *SectionInfoExtension) XXX_DiscardUnknown()
- func (m *SectionInfoExtension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SectionInfoExtension) XXX_Merge(src proto.Message)
- func (m *SectionInfoExtension) XXX_Size() int
- func (m *SectionInfoExtension) XXX_Unmarshal(b []byte) error
- type SectionMetadata
- func (*SectionMetadata) Descriptor() ([]byte, []int)
- func (this *SectionMetadata) Equal(that interface{}) bool
- func (m *SectionMetadata) GetColumns() []*ColumnDesc
- func (m *SectionMetadata) GetDictionary() []string
- func (m *SectionMetadata) GetSortInfo() *SortInfo
- func (this *SectionMetadata) GoString() string
- func (m *SectionMetadata) Marshal() (dAtA []byte, err error)
- func (m *SectionMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *SectionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SectionMetadata) ProtoMessage()
- func (m *SectionMetadata) Reset()
- func (m *SectionMetadata) Size() (n int)
- func (this *SectionMetadata) String() string
- func (m *SectionMetadata) Unmarshal(dAtA []byte) error
- func (m *SectionMetadata) XXX_DiscardUnknown()
- func (m *SectionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SectionMetadata) XXX_Merge(src proto.Message)
- func (m *SectionMetadata) XXX_Size() int
- func (m *SectionMetadata) XXX_Unmarshal(b []byte) error
- type SortDirection
- type SortInfo
- func (*SortInfo) Descriptor() ([]byte, []int)
- func (this *SortInfo) Equal(that interface{}) bool
- func (m *SortInfo) GetColumnSorts() []*SortInfo_ColumnSort
- func (this *SortInfo) GoString() string
- func (m *SortInfo) Marshal() (dAtA []byte, err error)
- func (m *SortInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *SortInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SortInfo) ProtoMessage()
- func (m *SortInfo) Reset()
- func (m *SortInfo) Size() (n int)
- func (this *SortInfo) String() string
- func (m *SortInfo) Unmarshal(dAtA []byte) error
- func (m *SortInfo) XXX_DiscardUnknown()
- func (m *SortInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SortInfo) XXX_Merge(src proto.Message)
- func (m *SortInfo) XXX_Size() int
- func (m *SortInfo) XXX_Unmarshal(b []byte) error
- type SortInfo_ColumnSort
- func (*SortInfo_ColumnSort) Descriptor() ([]byte, []int)
- func (this *SortInfo_ColumnSort) Equal(that interface{}) bool
- func (m *SortInfo_ColumnSort) GetColumnIndex() uint32
- func (m *SortInfo_ColumnSort) GetDirection() SortDirection
- func (this *SortInfo_ColumnSort) GoString() string
- func (m *SortInfo_ColumnSort) Marshal() (dAtA []byte, err error)
- func (m *SortInfo_ColumnSort) MarshalTo(dAtA []byte) (int, error)
- func (m *SortInfo_ColumnSort) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SortInfo_ColumnSort) ProtoMessage()
- func (m *SortInfo_ColumnSort) Reset()
- func (m *SortInfo_ColumnSort) Size() (n int)
- func (this *SortInfo_ColumnSort) String() string
- func (m *SortInfo_ColumnSort) Unmarshal(dAtA []byte) error
- func (m *SortInfo_ColumnSort) XXX_DiscardUnknown()
- func (m *SortInfo_ColumnSort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SortInfo_ColumnSort) XXX_Merge(src proto.Message)
- func (m *SortInfo_ColumnSort) XXX_Size() int
- func (m *SortInfo_ColumnSort) XXX_Unmarshal(b []byte) error
- type Statistics
- func (*Statistics) Descriptor() ([]byte, []int)
- func (this *Statistics) Equal(that interface{}) bool
- func (m *Statistics) GetCardinalityCount() uint64
- func (m *Statistics) GetMaxValue() []byte
- func (m *Statistics) GetMinValue() []byte
- func (this *Statistics) GoString() string
- func (m *Statistics) Marshal() (dAtA []byte, err error)
- func (m *Statistics) MarshalTo(dAtA []byte) (int, error)
- func (m *Statistics) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Statistics) ProtoMessage()
- func (m *Statistics) Reset()
- func (m *Statistics) Size() (n int)
- func (this *Statistics) String() string
- func (m *Statistics) Unmarshal(dAtA []byte) error
- func (m *Statistics) XXX_DiscardUnknown()
- func (m *Statistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Statistics) XXX_Merge(src proto.Message)
- func (m *Statistics) XXX_Size() int
- func (m *Statistics) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthDatasetmd = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDatasetmd = fmt.Errorf("proto: integer overflow") )
var CompressionType_name = map[int32]string{
0: "COMPRESSION_TYPE_UNSPECIFIED",
1: "COMPRESSION_TYPE_NONE",
2: "COMPRESSION_TYPE_SNAPPY",
3: "COMPRESSION_TYPE_ZSTD",
}
var CompressionType_value = map[string]int32{
"COMPRESSION_TYPE_UNSPECIFIED": 0,
"COMPRESSION_TYPE_NONE": 1,
"COMPRESSION_TYPE_SNAPPY": 2,
"COMPRESSION_TYPE_ZSTD": 3,
}
var EncodingType_name = map[int32]string{
0: "ENCODING_TYPE_UNSPECIFIED",
1: "ENCODING_TYPE_PLAIN",
2: "ENCODING_TYPE_DELTA",
3: "ENCODING_TYPE_BITMAP",
}
var EncodingType_value = map[string]int32{
"ENCODING_TYPE_UNSPECIFIED": 0,
"ENCODING_TYPE_PLAIN": 1,
"ENCODING_TYPE_DELTA": 2,
"ENCODING_TYPE_BITMAP": 3,
}
var PhysicalType_name = map[int32]string{
0: "PHYSICAL_TYPE_UNSPECIFIED",
1: "PHYSICAL_TYPE_INT64",
2: "PHYSICAL_TYPE_UINT64",
3: "PHYSICAL_TYPE_BINARY",
}
var PhysicalType_value = map[string]int32{
"PHYSICAL_TYPE_UNSPECIFIED": 0,
"PHYSICAL_TYPE_INT64": 1,
"PHYSICAL_TYPE_UINT64": 2,
"PHYSICAL_TYPE_BINARY": 3,
}
var SortDirection_name = map[int32]string{
0: "SORT_DIRECTION_UNSPECIFIED",
1: "SORT_DIRECTION_ASCENDING",
2: "SORT_DIRECTION_DESCENDING",
}
var SortDirection_value = map[string]int32{
"SORT_DIRECTION_UNSPECIFIED": 0,
"SORT_DIRECTION_ASCENDING": 1,
"SORT_DIRECTION_DESCENDING": 2,
}
Functions ¶
This section is empty.
Types ¶
type ColumnDesc ¶ added in v3.6.0
type ColumnDesc struct {
// Type holds the type of data in the column.
Type *ColumnType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
// Tag is an optional string that can be used to distinguish between
// different columns with the same type.
//
// For example, there may be two columns with the type (uint64.timestamp)
// but with different tags ("start_time" and "end_time").
//
// Columns are uniquely named based on the combination of their type and
// optional tag, separated by a "/" when a tag is present:
//
// - uint64.timestamp/start_time
// - uint64.timestamp/end_time
// - uint64.stream_id (no tag)
//
// The tag string can be retrieved from the dictionary field in
// SectionMetadata, using the tag_ref value as the index.
TagRef uint32 `protobuf:"varint,2,opt,name=tag_ref,json=tagRef,proto3" json:"tag_ref,omitempty"`
// Total number of pages in the column.
PagesCount uint64 `protobuf:"varint,3,opt,name=pages_count,json=pagesCount,proto3" json:"pages_count,omitempty"`
// Total number of rows (values + nulls) in the column across all pages.
RowsCount uint64 `protobuf:"varint,4,opt,name=rows_count,json=rowsCount,proto3" json:"rows_count,omitempty"`
// Total number of non-NULL values in this column across all pages. The
// number of NULL values is rows_count - values_count.
ValuesCount uint64 `protobuf:"varint,5,opt,name=values_count,json=valuesCount,proto3" json:"values_count,omitempty"`
// Compression type used for all pages.
Compression CompressionType `protobuf:"varint,6,opt,name=compression,proto3,enum=dataobj.metadata.dataset.v2.CompressionType" json:"compression,omitempty"`
// Total uncompressed size of all pages in the column in bytes.
UncompressedSize uint64 `protobuf:"varint,7,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"`
// Total compressed size of all pages in the column. If no compression is
// used, compressed_size matches uncompressed_size.
CompressedSize uint64 `protobuf:"varint,8,opt,name=compressed_size,json=compressedSize,proto3" json:"compressed_size,omitempty"`
// Byte offset relative to the start of the section's metadata region where
// ColumnMetadata for this column is stored.
ColumnMetadataOffset uint64 `protobuf:"varint,9,opt,name=column_metadata_offset,json=columnMetadataOffset,proto3" json:"column_metadata_offset,omitempty"`
// Length of the ColumnMetadata for this column in bytes.
ColumnMetadataLength uint64 `protobuf:"varint,10,opt,name=column_metadata_length,json=columnMetadataLength,proto3" json:"column_metadata_length,omitempty"`
// Statistics for this column.
Statistics *Statistics `protobuf:"bytes,11,opt,name=statistics,proto3" json:"statistics,omitempty"`
}
ColumnDesc describes an individual column within a data set.
func (*ColumnDesc) Descriptor ¶ added in v3.6.0
func (*ColumnDesc) Descriptor() ([]byte, []int)
func (*ColumnDesc) Equal ¶ added in v3.6.0
func (this *ColumnDesc) Equal(that interface{}) bool
func (*ColumnDesc) GetColumnMetadataLength ¶ added in v3.6.0
func (m *ColumnDesc) GetColumnMetadataLength() uint64
func (*ColumnDesc) GetColumnMetadataOffset ¶ added in v3.6.0
func (m *ColumnDesc) GetColumnMetadataOffset() uint64
func (*ColumnDesc) GetCompressedSize ¶ added in v3.6.0
func (m *ColumnDesc) GetCompressedSize() uint64
func (*ColumnDesc) GetCompression ¶ added in v3.6.0
func (m *ColumnDesc) GetCompression() CompressionType
func (*ColumnDesc) GetPagesCount ¶ added in v3.6.0
func (m *ColumnDesc) GetPagesCount() uint64
func (*ColumnDesc) GetRowsCount ¶ added in v3.6.0
func (m *ColumnDesc) GetRowsCount() uint64
func (*ColumnDesc) GetStatistics ¶ added in v3.6.0
func (m *ColumnDesc) GetStatistics() *Statistics
func (*ColumnDesc) GetTagRef ¶ added in v3.6.0
func (m *ColumnDesc) GetTagRef() uint32
func (*ColumnDesc) GetType ¶ added in v3.6.0
func (m *ColumnDesc) GetType() *ColumnType
func (*ColumnDesc) GetUncompressedSize ¶ added in v3.6.0
func (m *ColumnDesc) GetUncompressedSize() uint64
func (*ColumnDesc) GetValuesCount ¶ added in v3.6.0
func (m *ColumnDesc) GetValuesCount() uint64
func (*ColumnDesc) GoString ¶ added in v3.6.0
func (this *ColumnDesc) GoString() string
func (*ColumnDesc) Marshal ¶ added in v3.6.0
func (m *ColumnDesc) Marshal() (dAtA []byte, err error)
func (*ColumnDesc) MarshalTo ¶ added in v3.6.0
func (m *ColumnDesc) MarshalTo(dAtA []byte) (int, error)
func (*ColumnDesc) MarshalToSizedBuffer ¶ added in v3.6.0
func (m *ColumnDesc) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ColumnDesc) ProtoMessage ¶ added in v3.6.0
func (*ColumnDesc) ProtoMessage()
func (*ColumnDesc) Reset ¶ added in v3.6.0
func (m *ColumnDesc) Reset()
func (*ColumnDesc) Size ¶ added in v3.6.0
func (m *ColumnDesc) Size() (n int)
func (*ColumnDesc) String ¶ added in v3.6.0
func (this *ColumnDesc) String() string
func (*ColumnDesc) Unmarshal ¶ added in v3.6.0
func (m *ColumnDesc) Unmarshal(dAtA []byte) error
func (*ColumnDesc) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *ColumnDesc) XXX_DiscardUnknown()
func (*ColumnDesc) XXX_Marshal ¶ added in v3.6.0
func (m *ColumnDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnDesc) XXX_Merge ¶ added in v3.6.0
func (m *ColumnDesc) XXX_Merge(src proto.Message)
func (*ColumnDesc) XXX_Size ¶ added in v3.6.0
func (m *ColumnDesc) XXX_Size() int
func (*ColumnDesc) XXX_Unmarshal ¶ added in v3.6.0
func (m *ColumnDesc) XXX_Unmarshal(b []byte) error
type ColumnMetadata ¶ added in v3.6.0
type ColumnMetadata struct {
// Pages within the column.
Pages []*PageDesc `protobuf:"bytes,1,rep,name=pages,proto3" json:"pages,omitempty"`
}
ColumnMetadata holds additional metadata for an individual column. ColumnMetadata is stored within the metadata region of a section, and its offset and size is retrieved from within ColumnDesc.
func (*ColumnMetadata) Descriptor ¶ added in v3.6.0
func (*ColumnMetadata) Descriptor() ([]byte, []int)
func (*ColumnMetadata) Equal ¶ added in v3.6.0
func (this *ColumnMetadata) Equal(that interface{}) bool
func (*ColumnMetadata) GetPages ¶ added in v3.6.0
func (m *ColumnMetadata) GetPages() []*PageDesc
func (*ColumnMetadata) GoString ¶ added in v3.6.0
func (this *ColumnMetadata) GoString() string
func (*ColumnMetadata) Marshal ¶ added in v3.6.0
func (m *ColumnMetadata) Marshal() (dAtA []byte, err error)
func (*ColumnMetadata) MarshalTo ¶ added in v3.6.0
func (m *ColumnMetadata) MarshalTo(dAtA []byte) (int, error)
func (*ColumnMetadata) MarshalToSizedBuffer ¶ added in v3.6.0
func (m *ColumnMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ColumnMetadata) ProtoMessage ¶ added in v3.6.0
func (*ColumnMetadata) ProtoMessage()
func (*ColumnMetadata) Reset ¶ added in v3.6.0
func (m *ColumnMetadata) Reset()
func (*ColumnMetadata) Size ¶ added in v3.6.0
func (m *ColumnMetadata) Size() (n int)
func (*ColumnMetadata) String ¶ added in v3.6.0
func (this *ColumnMetadata) String() string
func (*ColumnMetadata) Unmarshal ¶ added in v3.6.0
func (m *ColumnMetadata) Unmarshal(dAtA []byte) error
func (*ColumnMetadata) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *ColumnMetadata) XXX_DiscardUnknown()
func (*ColumnMetadata) XXX_Marshal ¶ added in v3.6.0
func (m *ColumnMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnMetadata) XXX_Merge ¶ added in v3.6.0
func (m *ColumnMetadata) XXX_Merge(src proto.Message)
func (*ColumnMetadata) XXX_Size ¶ added in v3.6.0
func (m *ColumnMetadata) XXX_Size() int
func (*ColumnMetadata) XXX_Unmarshal ¶ added in v3.6.0
func (m *ColumnMetadata) XXX_Unmarshal(b []byte) error
type ColumnType ¶ added in v3.6.0
type ColumnType struct {
// Physical is the physical type of the column.
Physical PhysicalType `protobuf:"varint,1,opt,name=physical,proto3,enum=dataobj.metadata.dataset.v2.PhysicalType" json:"physical,omitempty"`
// Logical is a section-specified string indicating how to interpret the
// physical type. Section implementations are responsible for interpreting
// this value.
//
// The string can be retrieved from the dictionary field in SectionMetadata,
// using the logical_ref value as the index.
LogicalRef uint32 `protobuf:"varint,3,opt,name=logical_ref,json=logicalRef,proto3" json:"logical_ref,omitempty"`
}
ColumnType represents the type of data in a column, combined from its physical layout and logical interpretation.
A ColumnType is usually described by concatenating its physical and logical type with a ".", such as "uint64.timestamp" or "binary.label".
func (*ColumnType) Descriptor ¶ added in v3.6.0
func (*ColumnType) Descriptor() ([]byte, []int)
func (*ColumnType) Equal ¶ added in v3.6.0
func (this *ColumnType) Equal(that interface{}) bool
func (*ColumnType) GetLogicalRef ¶ added in v3.6.0
func (m *ColumnType) GetLogicalRef() uint32
func (*ColumnType) GetPhysical ¶ added in v3.6.0
func (m *ColumnType) GetPhysical() PhysicalType
func (*ColumnType) GoString ¶ added in v3.6.0
func (this *ColumnType) GoString() string
func (*ColumnType) Marshal ¶ added in v3.6.0
func (m *ColumnType) Marshal() (dAtA []byte, err error)
func (*ColumnType) MarshalTo ¶ added in v3.6.0
func (m *ColumnType) MarshalTo(dAtA []byte) (int, error)
func (*ColumnType) MarshalToSizedBuffer ¶ added in v3.6.0
func (m *ColumnType) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ColumnType) ProtoMessage ¶ added in v3.6.0
func (*ColumnType) ProtoMessage()
func (*ColumnType) Reset ¶ added in v3.6.0
func (m *ColumnType) Reset()
func (*ColumnType) Size ¶ added in v3.6.0
func (m *ColumnType) Size() (n int)
func (*ColumnType) String ¶ added in v3.6.0
func (this *ColumnType) String() string
func (*ColumnType) Unmarshal ¶ added in v3.6.0
func (m *ColumnType) Unmarshal(dAtA []byte) error
func (*ColumnType) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *ColumnType) XXX_DiscardUnknown()
func (*ColumnType) XXX_Marshal ¶ added in v3.6.0
func (m *ColumnType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnType) XXX_Merge ¶ added in v3.6.0
func (m *ColumnType) XXX_Merge(src proto.Message)
func (*ColumnType) XXX_Size ¶ added in v3.6.0
func (m *ColumnType) XXX_Size() int
func (*ColumnType) XXX_Unmarshal ¶ added in v3.6.0
func (m *ColumnType) XXX_Unmarshal(b []byte) error
type CompressionType ¶
type CompressionType int32
CompressionType represents valid compression types that can be used for compressing content within pages.
const ( // Invalid compression type. COMPRESSION_TYPE_UNSPECIFIED CompressionType = 0 // No compression. COMPRESSION_TYPE_NONE CompressionType = 1 // Snappy compression. COMPRESSION_TYPE_SNAPPY CompressionType = 2 // Zstd compression. COMPRESSION_TYPE_ZSTD CompressionType = 3 )
func (CompressionType) EnumDescriptor ¶
func (CompressionType) EnumDescriptor() ([]byte, []int)
func (CompressionType) String ¶
func (x CompressionType) String() string
type EncodingType ¶
type EncodingType int32
EncodingType represents the valid types that a sequence of values which a column can be encoded with.
const ( // Invalid encoding type. ENCODING_TYPE_UNSPECIFIED EncodingType = 0 // Plain encoding; data is stored as-is. ENCODING_TYPE_PLAIN EncodingType = 1 // Delta encoding. The first value within the page is stored as-is, and // subsequent values are stored as the delta from the previous value. ENCODING_TYPE_DELTA EncodingType = 2 // Bitmap encoding. Bitmaps efficiently store repeating sequences of unsigned // integers using a combination of run-length encoding and bitpacking. ENCODING_TYPE_BITMAP EncodingType = 3 )
func (EncodingType) EnumDescriptor ¶
func (EncodingType) EnumDescriptor() ([]byte, []int)
func (EncodingType) String ¶
func (x EncodingType) String() string
type PageDesc ¶ added in v3.6.0
type PageDesc struct {
// Uncompressed size of the page in bytes.
UncompressedSize uint64 `protobuf:"varint,1,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"`
// Compressed size of the page in bytes.
CompressedSize uint64 `protobuf:"varint,2,opt,name=compressed_size,json=compressedSize,proto3" json:"compressed_size,omitempty"`
// CRC32 checksum of the page data.
Crc32 uint32 `protobuf:"varint,3,opt,name=crc32,proto3" json:"crc32,omitempty"`
// Total number of rows (values + nulls) in the page.
RowsCount uint64 `protobuf:"varint,4,opt,name=rows_count,json=rowsCount,proto3" json:"rows_count,omitempty"`
// Total number of non-NULL values in the page. The number of NULL values is
// rows_count - values_count.
ValuesCount uint64 `protobuf:"varint,5,opt,name=values_count,json=valuesCount,proto3" json:"values_count,omitempty"`
// Encoding used for values in the page.
Encoding EncodingType `protobuf:"varint,6,opt,name=encoding,proto3,enum=dataobj.metadata.dataset.v2.EncodingType" json:"encoding,omitempty"`
// Byte offset relative to the start of the section's data region where the
// page is stored.
DataOffset uint64 `protobuf:"varint,7,opt,name=data_offset,json=dataOffset,proto3" json:"data_offset,omitempty"`
// Size of the page's data in bytes.
DataSize uint64 `protobuf:"varint,8,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
// Optional statistics for the page.
Statistics *Statistics `protobuf:"bytes,9,opt,name=statistics,proto3" json:"statistics,omitempty"`
}
PageDesc describes an individual page within a column.
func (*PageDesc) Descriptor ¶ added in v3.6.0
func (*PageDesc) GetCompressedSize ¶ added in v3.6.0
func (*PageDesc) GetDataOffset ¶ added in v3.6.0
func (*PageDesc) GetDataSize ¶ added in v3.6.0
func (*PageDesc) GetEncoding ¶ added in v3.6.0
func (m *PageDesc) GetEncoding() EncodingType
func (*PageDesc) GetRowsCount ¶ added in v3.6.0
func (*PageDesc) GetStatistics ¶ added in v3.6.0
func (m *PageDesc) GetStatistics() *Statistics
func (*PageDesc) GetUncompressedSize ¶ added in v3.6.0
func (*PageDesc) GetValuesCount ¶ added in v3.6.0
func (*PageDesc) MarshalToSizedBuffer ¶ added in v3.6.0
func (*PageDesc) ProtoMessage ¶ added in v3.6.0
func (*PageDesc) ProtoMessage()
func (*PageDesc) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *PageDesc) XXX_DiscardUnknown()
func (*PageDesc) XXX_Marshal ¶ added in v3.6.0
func (*PageDesc) XXX_Unmarshal ¶ added in v3.6.0
type PhysicalType ¶ added in v3.6.0
type PhysicalType int32
PhysicalType represents the type that the column is encoded as.
const ( // Invalid PhysicalType. PHYSICAL_TYPE_UNSPECIFIED PhysicalType = 0 // PHYSICAL_TYPE_INT64 holds 64-bit integer values. PHYSICAL_TYPE_INT64 PhysicalType = 1 // PHYSICAL_TYPE_UINT64 holds 64-bit unsigned integer values. PHYSICAL_TYPE_UINT64 PhysicalType = 2 // PHYSICAL_TYPE_BINARY holds binary data of variable length. PHYSICAL_TYPE_BINARY PhysicalType = 3 )
func (PhysicalType) EnumDescriptor ¶ added in v3.6.0
func (PhysicalType) EnumDescriptor() ([]byte, []int)
func (PhysicalType) String ¶ added in v3.6.0
func (x PhysicalType) String() string
type SectionInfoExtension ¶ added in v3.6.0
type SectionInfoExtension struct {
// Byte offset relative to the start of the section's metadata region where
// SectionMetadata for this section is stored.
SectionMetadataOffset uint64 `` /* 127-byte string literal not displayed */
// Length of the SectionMetadata for this column in bytes.
SectionMetadataLength uint64 `` /* 127-byte string literal not displayed */
}
SectionInfoExtension holds basic information about how to read this section. It is encoded into the extension data field of github.com/grafana/loki/v3/pkg/dataobj/internal/metadata/filemd.FileMetadata.
func (*SectionInfoExtension) Descriptor ¶ added in v3.6.0
func (*SectionInfoExtension) Descriptor() ([]byte, []int)
func (*SectionInfoExtension) Equal ¶ added in v3.6.0
func (this *SectionInfoExtension) Equal(that interface{}) bool
func (*SectionInfoExtension) GetSectionMetadataLength ¶ added in v3.6.0
func (m *SectionInfoExtension) GetSectionMetadataLength() uint64
func (*SectionInfoExtension) GetSectionMetadataOffset ¶ added in v3.6.0
func (m *SectionInfoExtension) GetSectionMetadataOffset() uint64
func (*SectionInfoExtension) GoString ¶ added in v3.6.0
func (this *SectionInfoExtension) GoString() string
func (*SectionInfoExtension) Marshal ¶ added in v3.6.0
func (m *SectionInfoExtension) Marshal() (dAtA []byte, err error)
func (*SectionInfoExtension) MarshalTo ¶ added in v3.6.0
func (m *SectionInfoExtension) MarshalTo(dAtA []byte) (int, error)
func (*SectionInfoExtension) MarshalToSizedBuffer ¶ added in v3.6.0
func (m *SectionInfoExtension) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SectionInfoExtension) ProtoMessage ¶ added in v3.6.0
func (*SectionInfoExtension) ProtoMessage()
func (*SectionInfoExtension) Reset ¶ added in v3.6.0
func (m *SectionInfoExtension) Reset()
func (*SectionInfoExtension) Size ¶ added in v3.6.0
func (m *SectionInfoExtension) Size() (n int)
func (*SectionInfoExtension) String ¶ added in v3.6.0
func (this *SectionInfoExtension) String() string
func (*SectionInfoExtension) Unmarshal ¶ added in v3.6.0
func (m *SectionInfoExtension) Unmarshal(dAtA []byte) error
func (*SectionInfoExtension) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *SectionInfoExtension) XXX_DiscardUnknown()
func (*SectionInfoExtension) XXX_Marshal ¶ added in v3.6.0
func (m *SectionInfoExtension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SectionInfoExtension) XXX_Merge ¶ added in v3.6.0
func (m *SectionInfoExtension) XXX_Merge(src proto.Message)
func (*SectionInfoExtension) XXX_Size ¶ added in v3.6.0
func (m *SectionInfoExtension) XXX_Size() int
func (*SectionInfoExtension) XXX_Unmarshal ¶ added in v3.6.0
func (m *SectionInfoExtension) XXX_Unmarshal(b []byte) error
type SectionMetadata ¶ added in v3.6.0
type SectionMetadata struct {
// The list of columns in the dataset.
Columns []*ColumnDesc `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
// Dictionary for deduplicating logical types and column tags. The first
// element (index zero) is reserved for invalid strings ("").
Dictionary []string `protobuf:"bytes,2,rep,name=dictionary,proto3" json:"dictionary,omitempty"`
// Sort information about the columns.
SortInfo *SortInfo `protobuf:"bytes,3,opt,name=sort_info,json=sortInfo,proto3" json:"sort_info,omitempty"`
}
SectionMetadata holds the entrypoint metadata for the overall section. SectionMetadata points to the offset of per-column ColumnMetadata which can be retrieved on demand.
func (*SectionMetadata) Descriptor ¶ added in v3.6.0
func (*SectionMetadata) Descriptor() ([]byte, []int)
func (*SectionMetadata) Equal ¶ added in v3.6.0
func (this *SectionMetadata) Equal(that interface{}) bool
func (*SectionMetadata) GetColumns ¶ added in v3.6.0
func (m *SectionMetadata) GetColumns() []*ColumnDesc
func (*SectionMetadata) GetDictionary ¶ added in v3.6.0
func (m *SectionMetadata) GetDictionary() []string
func (*SectionMetadata) GetSortInfo ¶ added in v3.6.0
func (m *SectionMetadata) GetSortInfo() *SortInfo
func (*SectionMetadata) GoString ¶ added in v3.6.0
func (this *SectionMetadata) GoString() string
func (*SectionMetadata) Marshal ¶ added in v3.6.0
func (m *SectionMetadata) Marshal() (dAtA []byte, err error)
func (*SectionMetadata) MarshalTo ¶ added in v3.6.0
func (m *SectionMetadata) MarshalTo(dAtA []byte) (int, error)
func (*SectionMetadata) MarshalToSizedBuffer ¶ added in v3.6.0
func (m *SectionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SectionMetadata) ProtoMessage ¶ added in v3.6.0
func (*SectionMetadata) ProtoMessage()
func (*SectionMetadata) Reset ¶ added in v3.6.0
func (m *SectionMetadata) Reset()
func (*SectionMetadata) Size ¶ added in v3.6.0
func (m *SectionMetadata) Size() (n int)
func (*SectionMetadata) String ¶ added in v3.6.0
func (this *SectionMetadata) String() string
func (*SectionMetadata) Unmarshal ¶ added in v3.6.0
func (m *SectionMetadata) Unmarshal(dAtA []byte) error
func (*SectionMetadata) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *SectionMetadata) XXX_DiscardUnknown()
func (*SectionMetadata) XXX_Marshal ¶ added in v3.6.0
func (m *SectionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SectionMetadata) XXX_Merge ¶ added in v3.6.0
func (m *SectionMetadata) XXX_Merge(src proto.Message)
func (*SectionMetadata) XXX_Size ¶ added in v3.6.0
func (m *SectionMetadata) XXX_Size() int
func (*SectionMetadata) XXX_Unmarshal ¶ added in v3.6.0
func (m *SectionMetadata) XXX_Unmarshal(b []byte) error
type SortDirection ¶ added in v3.6.0
type SortDirection int32
SortDirection represents sort direction of a column.
const ( // Sort direction is unspecified. SORT_DIRECTION_UNSPECIFIED SortDirection = 0 // SORT_DIRECTION_ASCENDING represents ascending sort order (smallest values first). SORT_DIRECTION_ASCENDING SortDirection = 1 // SORT_DIRECTION_DESCENDING represents descending sort order (largest values first). SORT_DIRECTION_DESCENDING SortDirection = 2 )
func (SortDirection) EnumDescriptor ¶ added in v3.6.0
func (SortDirection) EnumDescriptor() ([]byte, []int)
func (SortDirection) String ¶ added in v3.6.0
func (x SortDirection) String() string
type SortInfo ¶ added in v3.6.0
type SortInfo struct {
// The list of column sorts. The length of this depends on how many columns
// are used for sorting.
//
// If the section has no sorting at all, this field will be empty. If the
// section is sorted based on the value of a single column, this field will
// contain a single element. Otherwise, this field will contain multiple
// elements when compound sorting is used.
ColumnSorts []*SortInfo_ColumnSort `protobuf:"bytes,1,rep,name=column_sorts,json=columnSorts,proto3" json:"column_sorts,omitempty"`
}
SortInfo holds sort order information for rows in the section.
func (*SortInfo) Descriptor ¶ added in v3.6.0
func (*SortInfo) GetColumnSorts ¶ added in v3.6.0
func (m *SortInfo) GetColumnSorts() []*SortInfo_ColumnSort
func (*SortInfo) MarshalToSizedBuffer ¶ added in v3.6.0
func (*SortInfo) ProtoMessage ¶ added in v3.6.0
func (*SortInfo) ProtoMessage()
func (*SortInfo) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *SortInfo) XXX_DiscardUnknown()
func (*SortInfo) XXX_Marshal ¶ added in v3.6.0
func (*SortInfo) XXX_Unmarshal ¶ added in v3.6.0
type SortInfo_ColumnSort ¶ added in v3.6.0
type SortInfo_ColumnSort struct {
// Index of the column in the columns list.
ColumnIndex uint32 `protobuf:"varint,1,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"`
// Sort direction of the column.
Direction SortDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=dataobj.metadata.dataset.v2.SortDirection" json:"direction,omitempty"`
}
func (*SortInfo_ColumnSort) Descriptor ¶ added in v3.6.0
func (*SortInfo_ColumnSort) Descriptor() ([]byte, []int)
func (*SortInfo_ColumnSort) Equal ¶ added in v3.6.0
func (this *SortInfo_ColumnSort) Equal(that interface{}) bool
func (*SortInfo_ColumnSort) GetColumnIndex ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) GetColumnIndex() uint32
func (*SortInfo_ColumnSort) GetDirection ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) GetDirection() SortDirection
func (*SortInfo_ColumnSort) GoString ¶ added in v3.6.0
func (this *SortInfo_ColumnSort) GoString() string
func (*SortInfo_ColumnSort) Marshal ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) Marshal() (dAtA []byte, err error)
func (*SortInfo_ColumnSort) MarshalTo ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) MarshalTo(dAtA []byte) (int, error)
func (*SortInfo_ColumnSort) MarshalToSizedBuffer ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SortInfo_ColumnSort) ProtoMessage ¶ added in v3.6.0
func (*SortInfo_ColumnSort) ProtoMessage()
func (*SortInfo_ColumnSort) Reset ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) Reset()
func (*SortInfo_ColumnSort) Size ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) Size() (n int)
func (*SortInfo_ColumnSort) String ¶ added in v3.6.0
func (this *SortInfo_ColumnSort) String() string
func (*SortInfo_ColumnSort) Unmarshal ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) Unmarshal(dAtA []byte) error
func (*SortInfo_ColumnSort) XXX_DiscardUnknown ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) XXX_DiscardUnknown()
func (*SortInfo_ColumnSort) XXX_Marshal ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SortInfo_ColumnSort) XXX_Merge ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) XXX_Merge(src proto.Message)
func (*SortInfo_ColumnSort) XXX_Size ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) XXX_Size() int
func (*SortInfo_ColumnSort) XXX_Unmarshal ¶ added in v3.6.0
func (m *SortInfo_ColumnSort) XXX_Unmarshal(b []byte) error
type Statistics ¶
type Statistics struct {
// Minimum value. Applications should only set min_value to an encoding of a
// non-NULL value. If there is no non-NULL value, min_value should be unset.
//
// Applications must not assume that an unset min_value means that the column
// is empty; check for values_count == 0 instead.
MinValue []byte `protobuf:"bytes,1,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`
// Maximum value. Applications should only set max_value to an encoding of a
// non-NULL value. If there is no non-NULL value, max_value should be unset.
//
// Applications must not assume that an unset max_value means that the column
// is empty; check for values_count == 0 instead.
MaxValue []byte `protobuf:"bytes,2,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`
// Estimated number of distinct values in the column.
//
// Applications must not assume that an unset cardinality_count means that
// the column has no distinct values; check for values_count == 0 instead.
CardinalityCount uint64 `protobuf:"varint,3,opt,name=cardinality_count,json=cardinalityCount,proto3" json:"cardinality_count,omitempty"`
}
Statistics about a column or a page. All statistics are optional and are conditionally set depending on the column type.
func (*Statistics) Descriptor ¶
func (*Statistics) Descriptor() ([]byte, []int)
func (*Statistics) Equal ¶
func (this *Statistics) Equal(that interface{}) bool
func (*Statistics) GetCardinalityCount ¶ added in v3.5.0
func (m *Statistics) GetCardinalityCount() uint64
func (*Statistics) GetMaxValue ¶
func (m *Statistics) GetMaxValue() []byte
func (*Statistics) GetMinValue ¶
func (m *Statistics) GetMinValue() []byte
func (*Statistics) GoString ¶
func (this *Statistics) GoString() string
func (*Statistics) Marshal ¶
func (m *Statistics) Marshal() (dAtA []byte, err error)
func (*Statistics) MarshalToSizedBuffer ¶
func (m *Statistics) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Statistics) ProtoMessage ¶
func (*Statistics) ProtoMessage()
func (*Statistics) Reset ¶
func (m *Statistics) Reset()
func (*Statistics) Size ¶
func (m *Statistics) Size() (n int)
func (*Statistics) String ¶
func (this *Statistics) String() string
func (*Statistics) Unmarshal ¶
func (m *Statistics) Unmarshal(dAtA []byte) error
func (*Statistics) XXX_DiscardUnknown ¶
func (m *Statistics) XXX_DiscardUnknown()
func (*Statistics) XXX_Marshal ¶
func (m *Statistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Statistics) XXX_Merge ¶
func (m *Statistics) XXX_Merge(src proto.Message)
func (*Statistics) XXX_Size ¶
func (m *Statistics) XXX_Size() int
func (*Statistics) XXX_Unmarshal ¶
func (m *Statistics) XXX_Unmarshal(b []byte) error