datasetmd

package
v3.7.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 13, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthDatasetmd = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDatasetmd   = fmt.Errorf("proto: integer overflow")
)
View Source
var CompressionType_name = map[int32]string{
	0: "COMPRESSION_TYPE_UNSPECIFIED",
	1: "COMPRESSION_TYPE_NONE",
	2: "COMPRESSION_TYPE_SNAPPY",
	3: "COMPRESSION_TYPE_ZSTD",
}
View Source
var CompressionType_value = map[string]int32{
	"COMPRESSION_TYPE_UNSPECIFIED": 0,
	"COMPRESSION_TYPE_NONE":        1,
	"COMPRESSION_TYPE_SNAPPY":      2,
	"COMPRESSION_TYPE_ZSTD":        3,
}
View Source
var EncodingType_name = map[int32]string{
	0: "ENCODING_TYPE_UNSPECIFIED",
	1: "ENCODING_TYPE_PLAIN",
	2: "ENCODING_TYPE_DELTA",
	3: "ENCODING_TYPE_BITMAP",
}
View Source
var EncodingType_value = map[string]int32{
	"ENCODING_TYPE_UNSPECIFIED": 0,
	"ENCODING_TYPE_PLAIN":       1,
	"ENCODING_TYPE_DELTA":       2,
	"ENCODING_TYPE_BITMAP":      3,
}
View Source
var PhysicalType_name = map[int32]string{
	0: "PHYSICAL_TYPE_UNSPECIFIED",
	1: "PHYSICAL_TYPE_INT64",
	2: "PHYSICAL_TYPE_UINT64",
	3: "PHYSICAL_TYPE_BINARY",
}
View Source
var PhysicalType_value = map[string]int32{
	"PHYSICAL_TYPE_UNSPECIFIED": 0,
	"PHYSICAL_TYPE_INT64":       1,
	"PHYSICAL_TYPE_UINT64":      2,
	"PHYSICAL_TYPE_BINARY":      3,
}
View Source
var SortDirection_name = map[int32]string{
	0: "SORT_DIRECTION_UNSPECIFIED",
	1: "SORT_DIRECTION_ASCENDING",
	2: "SORT_DIRECTION_DESCENDING",
}
View Source
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) Descriptor() ([]byte, []int)

func (*PageDesc) Equal added in v3.6.0

func (this *PageDesc) Equal(that interface{}) bool

func (*PageDesc) GetCompressedSize added in v3.6.0

func (m *PageDesc) GetCompressedSize() uint64

func (*PageDesc) GetCrc32 added in v3.6.0

func (m *PageDesc) GetCrc32() uint32

func (*PageDesc) GetDataOffset added in v3.6.0

func (m *PageDesc) GetDataOffset() uint64

func (*PageDesc) GetDataSize added in v3.6.0

func (m *PageDesc) GetDataSize() uint64

func (*PageDesc) GetEncoding added in v3.6.0

func (m *PageDesc) GetEncoding() EncodingType

func (*PageDesc) GetRowsCount added in v3.6.0

func (m *PageDesc) GetRowsCount() uint64

func (*PageDesc) GetStatistics added in v3.6.0

func (m *PageDesc) GetStatistics() *Statistics

func (*PageDesc) GetUncompressedSize added in v3.6.0

func (m *PageDesc) GetUncompressedSize() uint64

func (*PageDesc) GetValuesCount added in v3.6.0

func (m *PageDesc) GetValuesCount() uint64

func (*PageDesc) GoString added in v3.6.0

func (this *PageDesc) GoString() string

func (*PageDesc) Marshal added in v3.6.0

func (m *PageDesc) Marshal() (dAtA []byte, err error)

func (*PageDesc) MarshalTo added in v3.6.0

func (m *PageDesc) MarshalTo(dAtA []byte) (int, error)

func (*PageDesc) MarshalToSizedBuffer added in v3.6.0

func (m *PageDesc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PageDesc) ProtoMessage added in v3.6.0

func (*PageDesc) ProtoMessage()

func (*PageDesc) Reset added in v3.6.0

func (m *PageDesc) Reset()

func (*PageDesc) Size added in v3.6.0

func (m *PageDesc) Size() (n int)

func (*PageDesc) String added in v3.6.0

func (this *PageDesc) String() string

func (*PageDesc) Unmarshal added in v3.6.0

func (m *PageDesc) Unmarshal(dAtA []byte) error

func (*PageDesc) XXX_DiscardUnknown added in v3.6.0

func (m *PageDesc) XXX_DiscardUnknown()

func (*PageDesc) XXX_Marshal added in v3.6.0

func (m *PageDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PageDesc) XXX_Merge added in v3.6.0

func (m *PageDesc) XXX_Merge(src proto.Message)

func (*PageDesc) XXX_Size added in v3.6.0

func (m *PageDesc) XXX_Size() int

func (*PageDesc) XXX_Unmarshal added in v3.6.0

func (m *PageDesc) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*SortInfo) Equal added in v3.6.0

func (this *SortInfo) Equal(that interface{}) bool

func (*SortInfo) GetColumnSorts added in v3.6.0

func (m *SortInfo) GetColumnSorts() []*SortInfo_ColumnSort

func (*SortInfo) GoString added in v3.6.0

func (this *SortInfo) GoString() string

func (*SortInfo) Marshal added in v3.6.0

func (m *SortInfo) Marshal() (dAtA []byte, err error)

func (*SortInfo) MarshalTo added in v3.6.0

func (m *SortInfo) MarshalTo(dAtA []byte) (int, error)

func (*SortInfo) MarshalToSizedBuffer added in v3.6.0

func (m *SortInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SortInfo) ProtoMessage added in v3.6.0

func (*SortInfo) ProtoMessage()

func (*SortInfo) Reset added in v3.6.0

func (m *SortInfo) Reset()

func (*SortInfo) Size added in v3.6.0

func (m *SortInfo) Size() (n int)

func (*SortInfo) String added in v3.6.0

func (this *SortInfo) String() string

func (*SortInfo) Unmarshal added in v3.6.0

func (m *SortInfo) Unmarshal(dAtA []byte) error

func (*SortInfo) XXX_DiscardUnknown added in v3.6.0

func (m *SortInfo) XXX_DiscardUnknown()

func (*SortInfo) XXX_Marshal added in v3.6.0

func (m *SortInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SortInfo) XXX_Merge added in v3.6.0

func (m *SortInfo) XXX_Merge(src proto.Message)

func (*SortInfo) XXX_Size added in v3.6.0

func (m *SortInfo) XXX_Size() int

func (*SortInfo) XXX_Unmarshal added in v3.6.0

func (m *SortInfo) XXX_Unmarshal(b []byte) error

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) MarshalTo

func (m *Statistics) MarshalTo(dAtA []byte) (int, 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

Jump to

Keyboard shortcuts

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