vector

Documentation

Index

• func Append(v *Vector, arg interface{}) error
• func Clean(v *Vector, m *mheap.Mheap)
• func Copy(v, w *Vector, vi, wi int64, m *mheap.Mheap) error
• func DecodeFixedCol[T any](v *Vector, sz int) []T
• func Free(v *Vector, m *mheap.Mheap)
• func GenericVectorValues[T any](v *Vector) []T
• func GetColumn[T any](v *Vector) []T
• func GetFixedVectorValues[T any](v *Vector, sz int) []T
• func GetStrVectorValues(v *Vector) ([]byte, []uint32, []uint32)
• func Length(v *Vector) int
• func MustBytesCols(v *Vector) *types.Bytes
• func MustTCols[T ref](v *Vector) []T
• func PreAlloc(v, w *Vector, rows int, m *mheap.Mheap)
• func Reset(v *Vector)
• func SetCol(v *Vector, col interface{})
• func SetLength(v *Vector, n int)
• func SetScalarLength(v *Vector, n int)
• func SetVectorLength(v *Vector, n int)
• func Shrink(v *Vector, sels []int64)
• func Shuffle(v *Vector, sels []int64, m *mheap.Mheap) error
• func Union(v, w *Vector, sels []int64, m *mheap.Mheap) error
• func UnionBatch(v, w *Vector, offset int64, cnt int, flags []uint8, m *mheap.Mheap) error
• func UnionNull(v, _ *Vector, m *mheap.Mheap) error
• func UnionOne(v, w *Vector, sel int64, m *mheap.Mheap) error
• type Vector
  • func Dup(v *Vector, m *mheap.Mheap) (*Vector, error)
  • func New(typ types.Type) *Vector
  • func NewConst(typ types.Type, length int) *Vector
  • func NewConstNull(typ types.Type, length int) *Vector
  • func NewWithData(typ types.Type, data []byte, col interface{}, nsp *nulls.Nulls) *Vector
  • func Window(v *Vector, start, end int, w *Vector) *Vector
  • func (v *Vector) Append(w any, m *mheap.Mheap) error
  • func (v *Vector) ConstExpand(m *mheap.Mheap) *Vector
  • func (v *Vector) ConstVectorIsNull() bool
  • func (v *Vector) Count() int
  • func (v *Vector) FillDefaultValue()
  • func (v *Vector) Free(m *mheap.Mheap)
  • func (v *Vector) GetColumnData(selectIndexs []int64, occurCounts []int64, rs []string) error
  • func (v *Vector) GetNulls() *nulls.Nulls
  • func (v *Vector) GetString(i int64) []byte
  • func (v *Vector) GetType() types.Type
  • func (v *Vector) IsScalar() bool
  • func (v *Vector) IsScalarNull() bool
  • func (v *Vector) Read(data []byte) error
  • func (v *Vector) Realloc(size int, m *mheap.Mheap) error
  • func (v *Vector) Show() ([]byte, error)
  • func (v *Vector) String() string
  • func (v *Vector) ToConst(row int) *Vector
  • func (v *Vector) TryExpandNulls(n int)

Functions

func Append

func Append(v *Vector, arg interface{}) error

func Clean

func Clean(v *Vector, m *mheap.Mheap)

func Copy

func Copy(v, w *Vector, vi, wi int64, m *mheap.Mheap) error

v[vi] = w[wi]

func DecodeFixedCol

func DecodeFixedCol[T any](v *Vector, sz int) []T

func Free

func Free(v *Vector, m *mheap.Mheap)

func GenericVectorValues

func GenericVectorValues[T any](v *Vector) []T

func GetColumn

func GetColumn[T any](v *Vector) []T

func GetFixedVectorValues

func GetFixedVectorValues[T any](v *Vector, sz int) []T

func GetStrVectorValues

func GetStrVectorValues(v *Vector) ([]byte, []uint32, []uint32)

func Length

func Length(v *Vector) int

func MustBytesCols

func MustBytesCols(v *Vector) *types.Bytes

func MustTCols

func MustTCols[T ref](v *Vector) []T

func PreAlloc

func PreAlloc(v, w *Vector, rows int, m *mheap.Mheap)

func Reset

func Reset(v *Vector)

func SetCol

func SetCol(v *Vector, col interface{})

func SetLength

func SetLength(v *Vector, n int)

func SetScalarLength

func SetScalarLength(v *Vector, n int)

func SetVectorLength

func SetVectorLength(v *Vector, n int)

func Shrink

func Shrink(v *Vector, sels []int64)

func Shuffle

func Shuffle(v *Vector, sels []int64, m *mheap.Mheap) error

func Union

func Union(v, w *Vector, sels []int64, m *mheap.Mheap) error

func UnionBatch

func UnionBatch(v, w *Vector, offset int64, cnt int, flags []uint8, m *mheap.Mheap) error

func UnionNull

func UnionNull(v, _ *Vector, m *mheap.Mheap) error

func UnionOne

func UnionOne(v, w *Vector, sel int64, m *mheap.Mheap) error

Types

type Vector

type Vector struct {
	Or   bool   // true: origin
	Ref  uint64 // reference count
	Link uint64 // link count
	Data []byte // raw data
	Typ  types.Type
	Col  interface{}  // column data, encoded Data
	Nsp  *nulls.Nulls // nulls list

	// some attributes for const vector (a vector with a lot of rows of a same const value)
	IsConst bool
	Length  int
}

* origin true: * count || type || bitmap size || bitmap || vector * origin false: * count || vector

func Dup

func Dup(v *Vector, m *mheap.Mheap) (*Vector, error)

func New

func New(typ types.Type) *Vector

func NewConst

func NewConst(typ types.Type, length int) *Vector

func NewConstNull

func NewConstNull(typ types.Type, length int) *Vector

func NewWithData

func NewWithData(typ types.Type, data []byte, col interface{}, nsp *nulls.Nulls) *Vector

func Window

func Window(v *Vector, start, end int, w *Vector) *Vector

func (*Vector) Append

func (v *Vector) Append(w any, m *mheap.Mheap) error

func (*Vector) ConstExpand

func (v *Vector) ConstExpand(m *mheap.Mheap) *Vector

func (*Vector) ConstVectorIsNull

func (v *Vector) ConstVectorIsNull() bool

ConstVectorIsNull checks whether a const vector is null

func (*Vector) Count

func (v *Vector) Count() int

return the number of rows in the vector

func (*Vector) FillDefaultValue

func (v *Vector) FillDefaultValue()

func (*Vector) Free

func (v *Vector) Free(m *mheap.Mheap)

func (*Vector) GetColumnData

func (v *Vector) GetColumnData(selectIndexs []int64, occurCounts []int64, rs []string) error

GetColumnData get whole column from a vector

func (*Vector) GetNulls

func (v *Vector) GetNulls() *nulls.Nulls

func (*Vector) GetString

func (v *Vector) GetString(i int64) []byte

func (*Vector) GetType

func (v *Vector) GetType() types.Type

func (*Vector) IsScalar

func (v *Vector) IsScalar() bool

IsScalar return true if the vector means a scalar value. e.g.

a + 1, and 1's vector will return true

func (*Vector) IsScalarNull

func (v *Vector) IsScalarNull() bool

IsScalarNull return true if the vector means a scalar Null. e.g.

a + Null, and the vector of right part will return true

func (*Vector) Read

func (v *Vector) Read(data []byte) error

func (*Vector) Realloc

func (v *Vector) Realloc(size int, m *mheap.Mheap) error

func (*Vector) Show

func (v *Vector) Show() ([]byte, error)

func (*Vector) String

func (v *Vector) String() string

func (*Vector) ToConst

func (v *Vector) ToConst(row int) *Vector

func (*Vector) TryExpandNulls

func (v *Vector) TryExpandNulls(n int)