Versions in this module Expand all Collapse all v1 v1.2.4 Sep 20, 2024 v1.2.3 Sep 10, 2024 v1.2.3-hotfix-20241101 Oct 31, 2024 v1.2.3-hotfix-20241016 Oct 16, 2024 v1.2.3-hotfix-20241010 Oct 11, 2024 v1.2.3-hotfix-20240916 Sep 14, 2024 v1.2.2 Jul 11, 2024 Changes in this version type ShuffleRange + func (s *ShuffleRange) ReleaseUnused() v1.2.2-20240715 Jul 15, 2024 v1.2.1 Jun 28, 2024 v1.2.1-20240709 Jul 9, 2024 v1.2.0 May 17, 2024 Changes in this version + const DefaultEvalSize type ShuffleHeap + func (t *ShuffleHeap) Merge(s *ShuffleHeap) *ShuffleHeap + func (t *ShuffleHeap) Pop() (*ShuffleHeap, *ShuffleHeap) + type ShuffleList struct + Next *ShuffleList + Size int64 + Tree *ShuffleHeap + Value float64 type ShuffleRange + func (s *ShuffleRange) Eval() + func (s *ShuffleRange) Update(zmmin float64, zmmax float64, rowCount int64, nullCount int64) + func (s *ShuffleRange) UpdateString(zmmin []byte, zmmax []byte, rowCount int64, nullCount int64) type StatsInfo + func (sc *StatsInfo) NeedUpdate(currentApproxObjNum int64) bool v1.1.3 Apr 15, 2024 v1.1.2 Apr 2, 2024 Changes in this version + var ErrIntOverflowStatsinfo = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthStatsinfo = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupStatsinfo = fmt.Errorf("proto: unexpected end of group") + type ShuffleHeap struct + Height int64 + Key float64 + Left *ShuffleHeap + Nulls int64 + Reverse bool + Right *ShuffleHeap + Sz int64 + Value float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShuffleHeap) Descriptor() ([]byte, []int) + func (*ShuffleHeap) ProtoMessage() + func (m *ShuffleHeap) GetHeight() int64 + func (m *ShuffleHeap) GetKey() float64 + func (m *ShuffleHeap) GetLeft() *ShuffleHeap + func (m *ShuffleHeap) GetNulls() int64 + func (m *ShuffleHeap) GetReverse() bool + func (m *ShuffleHeap) GetRight() *ShuffleHeap + func (m *ShuffleHeap) GetSz() int64 + func (m *ShuffleHeap) GetValue() float64 + func (m *ShuffleHeap) Marshal() (dAtA []byte, err error) + func (m *ShuffleHeap) MarshalTo(dAtA []byte) (int, error) + func (m *ShuffleHeap) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShuffleHeap) Reset() + func (m *ShuffleHeap) Size() (n int) + func (m *ShuffleHeap) String() string + func (m *ShuffleHeap) Unmarshal(dAtA []byte) error + func (m *ShuffleHeap) XXX_DiscardUnknown() + func (m *ShuffleHeap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShuffleHeap) XXX_Merge(src proto.Message) + func (m *ShuffleHeap) XXX_Size() int + func (m *ShuffleHeap) XXX_Unmarshal(b []byte) error + type ShuffleRange struct + Flags []bool + IsStrType bool + Max float64 + MaxLen int64 + Maxs [][]byte + Min float64 + Mins [][]byte + Nulls []int64 + Overlap float64 + Result []float64 + Rows []int64 + Sz int64 + Tree *ShuffleHeap + Uniform float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShuffleRange) Descriptor() ([]byte, []int) + func (*ShuffleRange) ProtoMessage() + func (m *ShuffleRange) GetFlags() []bool + func (m *ShuffleRange) GetIsStrType() bool + func (m *ShuffleRange) GetMax() float64 + func (m *ShuffleRange) GetMaxLen() int64 + func (m *ShuffleRange) GetMaxs() [][]byte + func (m *ShuffleRange) GetMin() float64 + func (m *ShuffleRange) GetMins() [][]byte + func (m *ShuffleRange) GetNulls() []int64 + func (m *ShuffleRange) GetOverlap() float64 + func (m *ShuffleRange) GetResult() []float64 + func (m *ShuffleRange) GetRows() []int64 + func (m *ShuffleRange) GetSz() int64 + func (m *ShuffleRange) GetTree() *ShuffleHeap + func (m *ShuffleRange) GetUniform() float64 + func (m *ShuffleRange) Marshal() (dAtA []byte, err error) + func (m *ShuffleRange) MarshalTo(dAtA []byte) (int, error) + func (m *ShuffleRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShuffleRange) Reset() + func (m *ShuffleRange) Size() (n int) + func (m *ShuffleRange) String() string + func (m *ShuffleRange) Unmarshal(dAtA []byte) error + func (m *ShuffleRange) XXX_DiscardUnknown() + func (m *ShuffleRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShuffleRange) XXX_Merge(src proto.Message) + func (m *ShuffleRange) XXX_Size() int + func (m *ShuffleRange) XXX_Unmarshal(b []byte) error + type StatsInfo struct + AccurateObjectNumber int64 + ApproxObjectNumber int64 + BlockNumber int64 + DataTypeMap map[string]uint64 + MaxValMap map[string]float64 + MinValMap map[string]float64 + NdvMap map[string]float64 + NullCntMap map[string]uint64 + ShuffleRangeMap map[string]*ShuffleRange + SizeMap map[string]uint64 + TableCnt float64 + TableName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatsInfo) Descriptor() ([]byte, []int) + func (*StatsInfo) ProtoMessage() + func (m *StatsInfo) GetAccurateObjectNumber() int64 + func (m *StatsInfo) GetApproxObjectNumber() int64 + func (m *StatsInfo) GetBlockNumber() int64 + func (m *StatsInfo) GetDataTypeMap() map[string]uint64 + func (m *StatsInfo) GetMaxValMap() map[string]float64 + func (m *StatsInfo) GetMinValMap() map[string]float64 + func (m *StatsInfo) GetNdvMap() map[string]float64 + func (m *StatsInfo) GetNullCntMap() map[string]uint64 + func (m *StatsInfo) GetShuffleRangeMap() map[string]*ShuffleRange + func (m *StatsInfo) GetSizeMap() map[string]uint64 + func (m *StatsInfo) GetTableCnt() float64 + func (m *StatsInfo) GetTableName() string + func (m *StatsInfo) Marshal() (dAtA []byte, err error) + func (m *StatsInfo) MarshalTo(dAtA []byte) (int, error) + func (m *StatsInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatsInfo) Reset() + func (m *StatsInfo) Size() (n int) + func (m *StatsInfo) String() string + func (m *StatsInfo) Unmarshal(dAtA []byte) error + func (m *StatsInfo) XXX_DiscardUnknown() + func (m *StatsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatsInfo) XXX_Merge(src proto.Message) + func (m *StatsInfo) XXX_Size() int + func (m *StatsInfo) XXX_Unmarshal(b []byte) error + type StatsInfoKey struct + DatabaseID uint64 + TableID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatsInfoKey) Descriptor() ([]byte, []int) + func (*StatsInfoKey) ProtoMessage() + func (m *StatsInfoKey) GetDatabaseID() uint64 + func (m *StatsInfoKey) GetTableID() uint64 + func (m *StatsInfoKey) Marshal() (dAtA []byte, err error) + func (m *StatsInfoKey) MarshalTo(dAtA []byte) (int, error) + func (m *StatsInfoKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatsInfoKey) Reset() + func (m *StatsInfoKey) Size() (n int) + func (m *StatsInfoKey) String() string + func (m *StatsInfoKey) Unmarshal(dAtA []byte) error + func (m *StatsInfoKey) XXX_DiscardUnknown() + func (m *StatsInfoKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatsInfoKey) XXX_Merge(src proto.Message) + func (m *StatsInfoKey) XXX_Size() int + func (m *StatsInfoKey) XXX_Unmarshal(b []byte) error + type StatsInfoKeys struct + Keys []StatsInfoKey + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatsInfoKeys) Descriptor() ([]byte, []int) + func (*StatsInfoKeys) ProtoMessage() + func (m *StatsInfoKeys) GetKeys() []StatsInfoKey + func (m *StatsInfoKeys) Marshal() (dAtA []byte, err error) + func (m *StatsInfoKeys) MarshalTo(dAtA []byte) (int, error) + func (m *StatsInfoKeys) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatsInfoKeys) Reset() + func (m *StatsInfoKeys) Size() (n int) + func (m *StatsInfoKeys) String() string + func (m *StatsInfoKeys) Unmarshal(dAtA []byte) error + func (m *StatsInfoKeys) XXX_DiscardUnknown() + func (m *StatsInfoKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatsInfoKeys) XXX_Merge(src proto.Message) + func (m *StatsInfoKeys) XXX_Size() int + func (m *StatsInfoKeys) XXX_Unmarshal(b []byte) error
Go to main page