statsinfo

package
v1.2.3-hotfix-20241016 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultEvalSize = 1024

Variables

View Source 
var (
	ErrInvalidLengthStatsinfo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatsinfo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStatsinfo = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ShuffleHeap 

type ShuffleHeap struct {
	Left    *ShuffleHeap `protobuf:"bytes,1,opt,name=Left,proto3" json:"Left,omitempty"`
	Right   *ShuffleHeap `protobuf:"bytes,2,opt,name=Right,proto3" json:"Right,omitempty"`
	Key     float64      `protobuf:"fixed64,3,opt,name=Key,proto3" json:"Key,omitempty"`
	Value   float64      `protobuf:"fixed64,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Height  int64        `protobuf:"varint,5,opt,name=Height,proto3" json:"Height,omitempty"`
	Sz      int64        `protobuf:"varint,6,opt,name=Sz,proto3" json:"Sz,omitempty"`
	Nulls   int64        `protobuf:"varint,7,opt,name=Nulls,proto3" json:"Nulls,omitempty"`
	Reverse bool         `protobuf:"varint,8,opt,name=Reverse,proto3" json:"Reverse,omitempty"`
}

func (*ShuffleHeap) Descriptor 

func (*ShuffleHeap) Descriptor() ([]byte, []int)

func (*ShuffleHeap) GetHeight 

func (m *ShuffleHeap) GetHeight() int64

func (*ShuffleHeap) GetKey 

func (m *ShuffleHeap) GetKey() float64

func (*ShuffleHeap) GetLeft 

func (m *ShuffleHeap) GetLeft() *ShuffleHeap

func (*ShuffleHeap) GetNulls 

func (m *ShuffleHeap) GetNulls() int64

func (*ShuffleHeap) GetReverse 

func (m *ShuffleHeap) GetReverse() bool

func (*ShuffleHeap) GetRight 

func (m *ShuffleHeap) GetRight() *ShuffleHeap

func (*ShuffleHeap) GetSz 

func (m *ShuffleHeap) GetSz() int64

func (*ShuffleHeap) GetValue 

func (m *ShuffleHeap) GetValue() float64

func (*ShuffleHeap) Marshal 

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

func (*ShuffleHeap) MarshalTo 

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

func (*ShuffleHeap) MarshalToSizedBuffer 

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

func (*ShuffleHeap) Merge added in v1.2.0 

func (t *ShuffleHeap) Merge(s *ShuffleHeap) *ShuffleHeap

func (*ShuffleHeap) Pop added in v1.2.0 

func (t *ShuffleHeap) Pop() (*ShuffleHeap, *ShuffleHeap)

func (*ShuffleHeap) ProtoMessage 

func (*ShuffleHeap) ProtoMessage()

func (*ShuffleHeap) Reset 

func (m *ShuffleHeap) Reset()

func (*ShuffleHeap) Size 

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

func (*ShuffleHeap) String 

func (m *ShuffleHeap) String() string

func (*ShuffleHeap) Unmarshal 

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

func (*ShuffleHeap) XXX_DiscardUnknown 

func (m *ShuffleHeap) XXX_DiscardUnknown()

func (*ShuffleHeap) XXX_Marshal 

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

func (*ShuffleHeap) XXX_Merge 

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

func (*ShuffleHeap) XXX_Size 

func (m *ShuffleHeap) XXX_Size() int

func (*ShuffleHeap) XXX_Unmarshal 

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

type ShuffleList added in v1.2.0 

type ShuffleList struct {
	Size  int64
	Value float64
	Next  *ShuffleList
	Tree  *ShuffleHeap
}

type ShuffleRange 

type ShuffleRange struct {
	IsStrType bool         `protobuf:"varint,1,opt,name=IsStrType,proto3" json:"IsStrType,omitempty"`
	Sz        int64        `protobuf:"varint,2,opt,name=Sz,proto3" json:"Sz,omitempty"`
	Tree      *ShuffleHeap `protobuf:"bytes,3,opt,name=Tree,proto3" json:"Tree,omitempty"`
	Min       float64      `protobuf:"fixed64,4,opt,name=Min,proto3" json:"Min,omitempty"`
	Max       float64      `protobuf:"fixed64,5,opt,name=Max,proto3" json:"Max,omitempty"`
	Mins      [][]byte     `protobuf:"bytes,6,rep,name=Mins,proto3" json:"Mins,omitempty"`
	Maxs      [][]byte     `protobuf:"bytes,7,rep,name=Maxs,proto3" json:"Maxs,omitempty"`
	Rows      []int64      `protobuf:"varint,8,rep,packed,name=Rows,proto3" json:"Rows,omitempty"`
	Nulls     []int64      `protobuf:"varint,9,rep,packed,name=Nulls,proto3" json:"Nulls,omitempty"`
	MaxLen    int64        `protobuf:"varint,10,opt,name=MaxLen,proto3" json:"MaxLen,omitempty"`
	Flags     []bool       `protobuf:"varint,11,rep,packed,name=Flags,proto3" json:"Flags,omitempty"`
	Overlap   float64      `protobuf:"fixed64,12,opt,name=Overlap,proto3" json:"Overlap,omitempty"`
	Uniform   float64      `protobuf:"fixed64,13,opt,name=Uniform,proto3" json:"Uniform,omitempty"`
	Result    []float64    `protobuf:"fixed64,14,rep,packed,name=Result,proto3" json:"Result,omitempty"`
}

func (*ShuffleRange) Descriptor 

func (*ShuffleRange) Descriptor() ([]byte, []int)

func (*ShuffleRange) Eval added in v1.2.0 

func (s *ShuffleRange) Eval()

func (*ShuffleRange) GetFlags 

func (m *ShuffleRange) GetFlags() []bool

func (*ShuffleRange) GetIsStrType 

func (m *ShuffleRange) GetIsStrType() bool

func (*ShuffleRange) GetMax 

func (m *ShuffleRange) GetMax() float64

func (*ShuffleRange) GetMaxLen 

func (m *ShuffleRange) GetMaxLen() int64

func (*ShuffleRange) GetMaxs 

func (m *ShuffleRange) GetMaxs() [][]byte

func (*ShuffleRange) GetMin 

func (m *ShuffleRange) GetMin() float64

func (*ShuffleRange) GetMins 

func (m *ShuffleRange) GetMins() [][]byte

func (*ShuffleRange) GetNulls 

func (m *ShuffleRange) GetNulls() []int64

func (*ShuffleRange) GetOverlap 

func (m *ShuffleRange) GetOverlap() float64

func (*ShuffleRange) GetResult 

func (m *ShuffleRange) GetResult() []float64

func (*ShuffleRange) GetRows 

func (m *ShuffleRange) GetRows() []int64

func (*ShuffleRange) GetSz 

func (m *ShuffleRange) GetSz() int64

func (*ShuffleRange) GetTree 

func (m *ShuffleRange) GetTree() *ShuffleHeap

func (*ShuffleRange) GetUniform 

func (m *ShuffleRange) GetUniform() float64

func (*ShuffleRange) Marshal 

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

func (*ShuffleRange) MarshalTo 

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

func (*ShuffleRange) MarshalToSizedBuffer 

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

func (*ShuffleRange) ProtoMessage 

func (*ShuffleRange) ProtoMessage()

func (*ShuffleRange) ReleaseUnused added in v1.2.2 

func (s *ShuffleRange) ReleaseUnused()

func (*ShuffleRange) Reset 

func (m *ShuffleRange) Reset()

func (*ShuffleRange) Size 

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

func (*ShuffleRange) String 

func (m *ShuffleRange) String() string

func (*ShuffleRange) Unmarshal 

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

func (*ShuffleRange) Update added in v1.2.0 

func (s *ShuffleRange) Update(zmmin float64, zmmax float64, rowCount int64, nullCount int64)

func (*ShuffleRange) UpdateString added in v1.2.0 

func (s *ShuffleRange) UpdateString(zmmin []byte, zmmax []byte, rowCount int64, nullCount int64)

func (*ShuffleRange) XXX_DiscardUnknown 

func (m *ShuffleRange) XXX_DiscardUnknown()

func (*ShuffleRange) XXX_Marshal 

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

func (*ShuffleRange) XXX_Merge 

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

func (*ShuffleRange) XXX_Size 

func (m *ShuffleRange) XXX_Size() int

func (*ShuffleRange) XXX_Unmarshal 

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

type StatsInfo 

type StatsInfo struct {
	NdvMap               map[string]float64       `` /* 155-byte string literal not displayed */
	MinValMap            map[string]float64       `` /* 161-byte string literal not displayed */
	MaxValMap            map[string]float64       `` /* 161-byte string literal not displayed */
	DataTypeMap          map[string]uint64        `` /* 164-byte string literal not displayed */
	NullCntMap           map[string]uint64        `` /* 162-byte string literal not displayed */
	SizeMap              map[string]uint64        `` /* 156-byte string literal not displayed */
	ShuffleRangeMap      map[string]*ShuffleRange `` /* 171-byte string literal not displayed */
	BlockNumber          int64                    `protobuf:"varint,8,opt,name=BlockNumber,proto3" json:"BlockNumber,omitempty"`
	AccurateObjectNumber int64                    `protobuf:"varint,9,opt,name=AccurateObjectNumber,proto3" json:"AccurateObjectNumber,omitempty"`
	ApproxObjectNumber   int64                    `protobuf:"varint,10,opt,name=ApproxObjectNumber,proto3" json:"ApproxObjectNumber,omitempty"`
	TableCnt             float64                  `protobuf:"fixed64,11,opt,name=TableCnt,proto3" json:"TableCnt,omitempty"`
	TableName            string                   `protobuf:"bytes,12,opt,name=TableName,proto3" json:"TableName,omitempty"`
}

func (*StatsInfo) Descriptor 

func (*StatsInfo) Descriptor() ([]byte, []int)

func (*StatsInfo) GetAccurateObjectNumber 

func (m *StatsInfo) GetAccurateObjectNumber() int64

func (*StatsInfo) GetApproxObjectNumber 

func (m *StatsInfo) GetApproxObjectNumber() int64

func (*StatsInfo) GetBlockNumber 

func (m *StatsInfo) GetBlockNumber() int64

func (*StatsInfo) GetDataTypeMap 

func (m *StatsInfo) GetDataTypeMap() map[string]uint64

func (*StatsInfo) GetMaxValMap 

func (m *StatsInfo) GetMaxValMap() map[string]float64

func (*StatsInfo) GetMinValMap 

func (m *StatsInfo) GetMinValMap() map[string]float64

func (*StatsInfo) GetNdvMap 

func (m *StatsInfo) GetNdvMap() map[string]float64

func (*StatsInfo) GetNullCntMap 

func (m *StatsInfo) GetNullCntMap() map[string]uint64

func (*StatsInfo) GetShuffleRangeMap 

func (m *StatsInfo) GetShuffleRangeMap() map[string]*ShuffleRange

func (*StatsInfo) GetSizeMap 

func (m *StatsInfo) GetSizeMap() map[string]uint64

func (*StatsInfo) GetTableCnt 

func (m *StatsInfo) GetTableCnt() float64

func (*StatsInfo) GetTableName 

func (m *StatsInfo) GetTableName() string

func (*StatsInfo) Marshal 

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

func (*StatsInfo) MarshalTo 

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

func (*StatsInfo) MarshalToSizedBuffer 

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

func (*StatsInfo) NeedUpdate added in v1.2.0 

func (sc *StatsInfo) NeedUpdate(currentApproxObjNum int64) bool

func (*StatsInfo) ProtoMessage 

func (*StatsInfo) ProtoMessage()

func (*StatsInfo) Reset 

func (m *StatsInfo) Reset()

func (*StatsInfo) Size 

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

func (*StatsInfo) String 

func (m *StatsInfo) String() string

func (*StatsInfo) Unmarshal 

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

func (*StatsInfo) XXX_DiscardUnknown 

func (m *StatsInfo) XXX_DiscardUnknown()

func (*StatsInfo) XXX_Marshal 

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

func (*StatsInfo) XXX_Merge 

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

func (*StatsInfo) XXX_Size 

func (m *StatsInfo) XXX_Size() int

func (*StatsInfo) XXX_Unmarshal 

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

type StatsInfoKey 

type StatsInfoKey struct {
	DatabaseID uint64 `protobuf:"varint,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	TableID    uint64 `protobuf:"varint,2,opt,name=TableID,proto3" json:"TableID,omitempty"`
}

func (*StatsInfoKey) Descriptor 

func (*StatsInfoKey) Descriptor() ([]byte, []int)

func (*StatsInfoKey) GetDatabaseID 

func (m *StatsInfoKey) GetDatabaseID() uint64

func (*StatsInfoKey) GetTableID 

func (m *StatsInfoKey) GetTableID() uint64

func (*StatsInfoKey) Marshal 

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

func (*StatsInfoKey) MarshalTo 

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

func (*StatsInfoKey) MarshalToSizedBuffer 

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

func (*StatsInfoKey) ProtoMessage 

func (*StatsInfoKey) ProtoMessage()

func (*StatsInfoKey) Reset 

func (m *StatsInfoKey) Reset()

func (*StatsInfoKey) Size 

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

func (*StatsInfoKey) String 

func (m *StatsInfoKey) String() string

func (*StatsInfoKey) Unmarshal 

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

func (*StatsInfoKey) XXX_DiscardUnknown 

func (m *StatsInfoKey) XXX_DiscardUnknown()

func (*StatsInfoKey) XXX_Marshal 

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

func (*StatsInfoKey) XXX_Merge 

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

func (*StatsInfoKey) XXX_Size 

func (m *StatsInfoKey) XXX_Size() int

func (*StatsInfoKey) XXX_Unmarshal 

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

type StatsInfoKeys 

type StatsInfoKeys struct {
	Keys []StatsInfoKey `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys"`
}

func (*StatsInfoKeys) Descriptor 

func (*StatsInfoKeys) Descriptor() ([]byte, []int)

func (*StatsInfoKeys) GetKeys 

func (m *StatsInfoKeys) GetKeys() []StatsInfoKey

func (*StatsInfoKeys) Marshal 

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

func (*StatsInfoKeys) MarshalTo 

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

func (*StatsInfoKeys) MarshalToSizedBuffer 

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

func (*StatsInfoKeys) ProtoMessage 

func (*StatsInfoKeys) ProtoMessage()

func (*StatsInfoKeys) Reset 

func (m *StatsInfoKeys) Reset()

func (*StatsInfoKeys) Size 

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

func (*StatsInfoKeys) String 

func (m *StatsInfoKeys) String() string

func (*StatsInfoKeys) Unmarshal 

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

func (*StatsInfoKeys) XXX_DiscardUnknown 

func (m *StatsInfoKeys) XXX_DiscardUnknown()

func (*StatsInfoKeys) XXX_Marshal 

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

func (*StatsInfoKeys) XXX_Merge 

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

func (*StatsInfoKeys) XXX_Size 

func (m *StatsInfoKeys) XXX_Size() int

func (*StatsInfoKeys) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.