statsinfo

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: May 17, 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) 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

Jump to

Keyboard shortcuts

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