vector

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 5, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrVecNotRo          = errors.New("should only be called in read-only mode")
	ErrVecWriteRo        = errors.New("write on readonly vector")
	ErrVecInvalidOffset  = errors.New("invalid offset error")
	ErrVecTypeNotSupport = errors.New("type not supported yet")
)

Functions

func NewStdVectorNode 

func NewStdVectorNode(vf common.IVFile, useCompress bool, freeFunc buf.MemoryFreeFunc) buf.IMemoryNode

func NewStrVectorNode 

func NewStrVectorNode(vf common.IVFile, useCompress bool, freeFunc buf.MemoryFreeFunc) buf.IMemoryNode

func NewVectorWrapperNode 

func NewVectorWrapperNode(vf common.IVFile, useCompress bool, freeFunc buf.MemoryFreeFunc) buf.IMemoryNode

func StdVectorConstructor 

func StdVectorConstructor(vf common.IVFile, useCompress bool, freeFunc buf.MemoryFreeFunc) buf.IMemoryNode

func StrVectorConstructor 

func StrVectorConstructor(vf common.IVFile, useCompress bool, freeFunc buf.MemoryFreeFunc) buf.IMemoryNode

func VectorWrapperConstructor 

func VectorWrapperConstructor(vf common.IVFile, useCompress bool, freeFunc buf.MemoryFreeFunc) buf.IMemoryNode

Types

type BaseVector 

type BaseVector struct {
	sync.RWMutex
	Type     types.Type
	StatMask container.Mask
	VMask    *nulls.Nulls
}

func (*BaseVector) HasNull 

func (v *BaseVector) HasNull() bool

func (*BaseVector) IsNull 

func (v *BaseVector) IsNull(idx int) (bool, error)

func (*BaseVector) IsReadonly 

func (v *BaseVector) IsReadonly() bool

func (*BaseVector) Length 

func (v *BaseVector) Length() int

func (*BaseVector) NullCnt 

func (v *BaseVector) NullCnt() int

func (*BaseVector) ResetReadonly 

func (v *BaseVector) ResetReadonly()

type IVector 

type IVector interface {
	IsReadonly() bool
	dbi.IVectorReader
	IVectorWriter
	GetLatestView() IVector
	PlacementNew(t types.Type)
}

func MockVector 

func MockVector(t types.Type, rows uint64) IVector

func NewVector 

func NewVector(t types.Type, capacity uint64) IVector

type IVectorNode 

type IVectorNode interface {
	buf.IMemoryNode
	IVector
}

type IVectorWriter 

type IVectorWriter interface {
	io.Closer
	SetValue(int, interface{}) error
	Append(int, interface{}) error
	AppendVector(*ro.Vector, int) (int, error)
}

type StdVector 

type StdVector struct {
	BaseVector
	MNode        *common.MemNode
	Data         []byte
	FreeFunc     buf.MemoryFreeFunc
	NodeCapacity uint64
	File         common.IVFile
	UseCompress  bool
}

func NewEmptyStdVector 

func NewEmptyStdVector() *StdVector

func NewStdVector 

func NewStdVector(t types.Type, capacity uint64) *StdVector

func (*StdVector) Append 

func (v *StdVector) Append(n int, vals interface{}) error

func (*StdVector) AppendVector 

func (v *StdVector) AppendVector(vec *ro.Vector, offset int) (n int, err error)

func (*StdVector) Capacity 

func (v *StdVector) Capacity() int

func (*StdVector) Close 

func (v *StdVector) Close() error

func (*StdVector) CopyToVector 

func (v *StdVector) CopyToVector() (*ro.Vector, error)

func (*StdVector) CopyToVectorWithBuffer 

func (v *StdVector) CopyToVectorWithBuffer(compressed *bytes.Buffer, deCompressed *bytes.Buffer) (*ro.Vector, error)

func (*StdVector) FreeMemory 

func (v *StdVector) FreeMemory()

func (*StdVector) GetLatestView 

func (v *StdVector) GetLatestView() IVector

func (*StdVector) GetMemoryCapacity 

func (v *StdVector) GetMemoryCapacity() uint64

func (*StdVector) GetMemorySize 

func (v *StdVector) GetMemorySize() uint64

func (*StdVector) GetType 

func (v *StdVector) GetType() dbi.VectorType

func (*StdVector) GetValue 

func (v *StdVector) GetValue(idx int) (interface{}, error)

func (*StdVector) Marshal 

func (v *StdVector) Marshal() ([]byte, error)

func (*StdVector) PlacementNew 

func (v *StdVector) PlacementNew(t types.Type)

func (*StdVector) ReadFrom 

func (v *StdVector) ReadFrom(r io.Reader) (n int64, err error)

func (*StdVector) Reset 

func (v *StdVector) Reset()

func (*StdVector) SetValue 

func (v *StdVector) SetValue(idx int, val interface{}) error

func (*StdVector) SliceReference 

func (v *StdVector) SliceReference(start, end int) (dbi.IVectorReader, error)

func (*StdVector) Unmarshal 

func (v *StdVector) Unmarshal(data []byte) error

func (*StdVector) WriteTo 

func (v *StdVector) WriteTo(w io.Writer) (n int64, err error)

type StrVector 

type StrVector struct {
	BaseVector
	MNodes       []*common.MemNode
	Data         *types.Bytes
	FreeFunc     buf.MemoryFreeFunc
	NodeCapacity uint64
	File         common.IVFile
	UseCompress  bool
}

func NewEmptyStrVector 

func NewEmptyStrVector() *StrVector

func NewStrVector 

func NewStrVector(t types.Type, capacity uint64) *StrVector

func (*StrVector) Append 

func (v *StrVector) Append(n int, vals interface{}) error

func (*StrVector) AppendVector 

func (v *StrVector) AppendVector(vec *ro.Vector, offset int) (n int, err error)

func (*StrVector) Capacity 

func (v *StrVector) Capacity() int

func (*StrVector) Close 

func (v *StrVector) Close() error

func (*StrVector) CopyToVector 

func (v *StrVector) CopyToVector() (*ro.Vector, error)

func (*StrVector) CopyToVectorWithBuffer 

func (v *StrVector) CopyToVectorWithBuffer(compressed *bytes.Buffer, deCompressed *bytes.Buffer) (*ro.Vector, error)

func (*StrVector) FreeMemory 

func (v *StrVector) FreeMemory()

func (*StrVector) GetLatestView 

func (v *StrVector) GetLatestView() IVector

func (*StrVector) GetMemoryCapacity 

func (v *StrVector) GetMemoryCapacity() uint64

func (*StrVector) GetMemorySize 

func (v *StrVector) GetMemorySize() uint64

func (*StrVector) GetType 

func (v *StrVector) GetType() dbi.VectorType

func (*StrVector) GetValue 

func (v *StrVector) GetValue(idx int) (interface{}, error)

func (*StrVector) Marshal 

func (v *StrVector) Marshal() ([]byte, error)

func (*StrVector) PlacementNew 

func (v *StrVector) PlacementNew(t types.Type)

func (*StrVector) ReadFrom 

func (v *StrVector) ReadFrom(r io.Reader) (n int64, err error)

func (*StrVector) Reset 

func (v *StrVector) Reset()

func (*StrVector) SetValue 

func (v *StrVector) SetValue(idx int, val interface{}) error

func (*StrVector) SliceReference 

func (v *StrVector) SliceReference(start, end int) (dbi.IVectorReader, error)

func (*StrVector) Unmarshal 

func (v *StrVector) Unmarshal(data []byte) error

func (*StrVector) WriteTo 

func (v *StrVector) WriteTo(w io.Writer) (n int64, err error)

type VectorWrapper 

type VectorWrapper struct {
	MNode *common.MemNode
	base.Vector
	FreeFunc    buf.MemoryFreeFunc
	File        common.IVFile
	UseCompress bool
}

func NewEmptyWrapper 

func NewEmptyWrapper(t types.Type) *VectorWrapper

func NewVectorWrapper 

func NewVectorWrapper(vec *base.Vector) *VectorWrapper

func (*VectorWrapper) Append 

func (vec *VectorWrapper) Append(n int, vals interface{}) error

func (*VectorWrapper) AppendVector 

func (vec *VectorWrapper) AppendVector(v *base.Vector, offset int) (n int, err error)

func (*VectorWrapper) Capacity 

func (vec *VectorWrapper) Capacity() int

func (*VectorWrapper) Clean 

func (vec *VectorWrapper) Clean(p *process.Process)

func (*VectorWrapper) Close 

func (vec *VectorWrapper) Close() error

func (*VectorWrapper) CopyToVector 

func (vec *VectorWrapper) CopyToVector() (*base.Vector, error)

func (*VectorWrapper) CopyToVectorWithBuffer 

func (vec *VectorWrapper) CopyToVectorWithBuffer(compressed *bytes.Buffer, deCompressed *bytes.Buffer) (*base.Vector, error)

func (*VectorWrapper) Free 

func (vec *VectorWrapper) Free(p *process.Process)

func (*VectorWrapper) FreeMemory 

func (vec *VectorWrapper) FreeMemory()

func (*VectorWrapper) GetLatestView 

func (vec *VectorWrapper) GetLatestView() IVector

func (*VectorWrapper) GetMemoryCapacity 

func (vec *VectorWrapper) GetMemoryCapacity() uint64

func (*VectorWrapper) GetMemorySize 

func (vec *VectorWrapper) GetMemorySize() uint64

func (*VectorWrapper) GetType 

func (vec *VectorWrapper) GetType() dbi.VectorType

func (*VectorWrapper) GetValue 

func (vec *VectorWrapper) GetValue(idx int) (interface{}, error)

func (*VectorWrapper) HasNull 

func (vec *VectorWrapper) HasNull() bool

func (*VectorWrapper) IsNull 

func (vec *VectorWrapper) IsNull(idx int) (bool, error)

func (*VectorWrapper) IsReadonly 

func (vec *VectorWrapper) IsReadonly() bool

func (*VectorWrapper) Length 

func (vec *VectorWrapper) Length() int

func (*VectorWrapper) Marshal 

func (vec *VectorWrapper) Marshal() ([]byte, error)

func (*VectorWrapper) NullCnt 

func (vec *VectorWrapper) NullCnt() int

func (*VectorWrapper) PlacementNew 

func (vec *VectorWrapper) PlacementNew(t types.Type)

func (*VectorWrapper) ReadFrom 

func (vec *VectorWrapper) ReadFrom(r io.Reader) (n int64, err error)

func (*VectorWrapper) ReadWithBuffer 

func (vec *VectorWrapper) ReadWithBuffer(r io.Reader, compressed *bytes.Buffer, deCompressed *bytes.Buffer) (n int64, err error)

func (*VectorWrapper) Reset 

func (vec *VectorWrapper) Reset()

func (*VectorWrapper) SetCol 

func (vec *VectorWrapper) SetCol(col interface{})

func (*VectorWrapper) SetValue 

func (vec *VectorWrapper) SetValue(idx int, val interface{}) error

func (*VectorWrapper) SliceReference 

func (vec *VectorWrapper) SliceReference(start, end int) (dbi.IVectorReader, error)

func (*VectorWrapper) Unmarshal 

func (vec *VectorWrapper) Unmarshal(data []byte) error

func (*VectorWrapper) WriteTo 

func (vec *VectorWrapper) WriteTo(w io.Writer) (n int64, err 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.