colexec

Jun 28, 2024

Changes in this version

type ReceiverOperator

+ func (r *ReceiverOperator) ReceiveBitmapFromChannel(ch chan *bitmap.Bitmap) *bitmap.Bitmap

+ type RunningPipelineMapForRemoteNode struct

type Server

+ func (srv *Server) CancelRunningPipeline(session morpc.ClientSession, id uint64)

+ func (srv *Server) RecordRunningPipeline(session morpc.ClientSession, id uint64, proc *process.Process) (queryCancel bool)

+ func (srv *Server) RemoveRunningPipeline(session morpc.ClientSession, id uint64)

May 17, 2024

Changes in this version

+ func Set(s *Server)

type ColumnExpressionExecutor

+ func NewColumnExpressionExecutor() *ColumnExpressionExecutor

+ func (expr ColumnExpressionExecutor) TypeName() string

type FixedVectorExpressionExecutor

+ func NewFixedVectorExpressionExecutor(m *mpool.MPool, fixed bool, resultVector *vector.Vector) *FixedVectorExpressionExecutor

+ func (expr FixedVectorExpressionExecutor) TypeName() string

type FunctionExpressionExecutor

+ func NewFunctionExpressionExecutor() *FunctionExpressionExecutor

+ func (expr FunctionExpressionExecutor) TypeName() string

type ParamExpressionExecutor

+ func NewParamExpressionExecutor(mp *mpool.MPool, pos int, typ types.Type) *ParamExpressionExecutor

+ func (expr ParamExpressionExecutor) TypeName() string

type Server

+ func Get() *Server

type VarExpressionExecutor

+ func NewVarExpressionExecutor() *VarExpressionExecutor

+ func (expr VarExpressionExecutor) TypeName() string

Dec 29, 2023

Changes in this version

+ const DefaultBatchSize

+ const MO_INDEX_ALGORITHM

+ const MO_INDEX_ALGORITHM_PARAMS

+ const MO_INDEX_ALGORITHM_TABLE_TYPE

Nov 13, 2023

Changes in this version

+ func GenerateConstListExpressionExecutor(proc *process.Process, exprs []*plan.Expr) (*vector.Vector, error)

type ColumnExpressionExecutor

+ func (expr *ColumnExpressionExecutor) GetColIndex() int

+ func (expr *ColumnExpressionExecutor) GetRelIndex() int

type ReceiverOperator

+ func (r *ReceiverOperator) DisableChosen(idx int)

+ func (r *ReceiverOperator) ReceiveFromSingleRegNonBlock(regIdx int, analyze process.Analyze) (*batch.Batch, bool, error)

+ func (r *ReceiverOperator) RemoveChosen(idx int)

type S3Writer

+ func (w *S3Writer) GetBlockInfoBat() *batch.Batch

+ func (w *S3Writer) ResetBlockInfoBat(proc *process.Process)

+ func (w *S3Writer) SetSchemaVer(ver uint32)

+ func (w *S3Writer) SetSeqnums(seqnums []uint16)

+ func (w *S3Writer) SetTableName(name string)

type Server

+ func (srv *Server) DeleteUuids(uuids []uuid.UUID)

+ func (srv *Server) GenerateObject() objectio.ObjectName

+ func (srv *Server) GetProcByUuid(u uuid.UUID, forcedDelete bool) (*process.Process, bool)

+ func (srv *Server) PutProcIntoUuidMap(u uuid.UUID, p *process.Process) error

Jun 30, 2023

Changes in this version

+ const ALLOCID_INDEX_KEY

+ const CnBlockIdType

+ const INDEX_TYPE_MULTIPLE

+ const INDEX_TYPE_PRIMARY

+ const INDEX_TYPE_UNIQUE

+ const MO_INDEX_COLUMN_NAME

+ const MO_INDEX_COMMENT

+ const MO_INDEX_DATABASE_ID

+ const MO_INDEX_HIDDEN

+ const MO_INDEX_ID

+ const MO_INDEX_IS_VISIBLE

+ const MO_INDEX_NAME

+ const MO_INDEX_OPTIONS

+ const MO_INDEX_ORDINAL_POSITION

+ const MO_INDEX_PRIKEY

+ const MO_INDEX_TABLE_ID

+ const MO_INDEX_TABLE_NAME

+ const MO_INDEX_TYPE

+ const TagS3Size

+ const TagS3SizeForMOLogger

+ const TxnWorkSpaceIdType

+ const WriteS3Threshold

+ var MO_INDEX_COLTYPE = map[string]types.T

+ func BatchDataNotNullCheck(tmpBat *batch.Batch, tableDef *plan.TableDef, ctx context.Context) error

+ func EvalExpressionOnce(proc *process.Process, planExpr *plan.Expr, batches []*batch.Batch) (*vector.Vector, error)

+ func EvaluateFilterByZoneMap(ctx context.Context, proc *process.Process, expr *plan.Expr, ...) (selected bool)

+ func FilterRowIdForDel(proc *process.Process, bat *batch.Batch, idx int) (*batch.Batch, error)

+ func FixProjectionResult(proc *process.Process, executors []ExpressionExecutor, rbat *batch.Batch, ...) (dupSize int, err error)

+ func GetExprZoneMap(ctx context.Context, proc *process.Process, expr *plan.Expr, ...) (v objectio.ZoneMap)

+ func GroupByPartitionForDelete(proc *process.Process, bat *batch.Batch, idx int, pIdx int, partitionNum int) ([]*batch.Batch, error)

+ func GroupByPartitionForInsert(proc *process.Process, bat *batch.Batch, attrs []string, pIdx int, ...) ([]*batch.Batch, error)

+ func InsertIndexMetadata(eg engine.Engine, ctx context.Context, db engine.Database, ...) error

+ func InsertOneIndexMetadata(eg engine.Engine, ctx context.Context, db engine.Database, ...) error

+ func NewJoinBatch(bat *batch.Batch, mp *mpool.MPool) (*batch.Batch, []func(*vector.Vector, *vector.Vector, int64, int) error)

+ func SafeGetResult(proc *process.Process, vec *vector.Vector, executor ExpressionExecutor) (*vector.Vector, error)

+ func SetJoinBatchValues(joinBat, bat *batch.Batch, sel int64, length int, ...) error

+ func SortInFilter(vec *vector.Vector)

+ type CnSegmentMap struct

+ type ColumnExpressionExecutor struct

+ func (expr *ColumnExpressionExecutor) Eval(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *ColumnExpressionExecutor) EvalWithoutResultReusing(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *ColumnExpressionExecutor) Free()

+ func (expr *ColumnExpressionExecutor) IsColumnExpr() bool

+ type ExpressionExecutor interface

+ Eval func(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ EvalWithoutResultReusing func(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ Free func()

+ IsColumnExpr func() bool

+ func NewExpressionExecutor(proc *process.Process, planExpr *plan.Expr) (ExpressionExecutor, error)

+ func NewExpressionExecutorsFromPlanExpressions(proc *process.Process, planExprs []*plan.Expr) (executors []ExpressionExecutor, err error)

+ type FixedVectorExpressionExecutor struct

+ func (expr *FixedVectorExpressionExecutor) Eval(_ *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *FixedVectorExpressionExecutor) EvalWithoutResultReusing(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *FixedVectorExpressionExecutor) Free()

+ func (expr *FixedVectorExpressionExecutor) IsColumnExpr() bool

+ type FunctionExpressionExecutor struct

+ func (expr *FunctionExpressionExecutor) Eval(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *FunctionExpressionExecutor) EvalWithoutResultReusing(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *FunctionExpressionExecutor) Free()

+ func (expr *FunctionExpressionExecutor) Init(proc *process.Process, parameterNum int, retType types.Type, ...) (err error)

+ func (expr *FunctionExpressionExecutor) IsColumnExpr() bool

+ func (expr *FunctionExpressionExecutor) SetParameter(index int, executor ExpressionExecutor)

+ type Merge struct

+ func NewMerge(size int, compLess func([]T, int64, int64) bool, cols [][]T, ...) (merge *Merge[T])

+ func (merge *Merge[T]) GetNextPos() (batchIndex, rowIndex, size int)

+ func (merge *Merge[T]) InitHeap()

+ func (merge *Merge[T]) Len() int

+ func (merge *Merge[T]) Less(i, j int) bool

+ type MergeHeap struct

+ func NewMergeHeap(cap_size uint64, cmp func([]T, int64, int64) bool) *MergeHeap[T]

+ func (heap *MergeHeap[T]) Pop() (data *MixData[T])

+ func (heap *MergeHeap[T]) Push(data *MixData[T])

+ type MergeInterface interface

+ GetNextPos func() (int, int, int)

+ type MixData struct

+ type ParamExpressionExecutor struct

+ func (expr *ParamExpressionExecutor) Eval(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *ParamExpressionExecutor) EvalWithoutResultReusing(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *ParamExpressionExecutor) Free()

+ func (expr *ParamExpressionExecutor) IsColumnExpr() bool

+ type ReceiverOperator struct

+ func (r *ReceiverOperator) FreeAllReg()

+ func (r *ReceiverOperator) FreeMergeTypeOperator(failed bool)

+ func (r *ReceiverOperator) FreeSingleReg(regIdx int)

+ func (r *ReceiverOperator) InitReceiver(proc *process.Process, isMergeType bool)

+ func (r *ReceiverOperator) ReceiveFromAllRegs(analyze process.Analyze) (*batch.Batch, bool, error)

+ func (r *ReceiverOperator) ReceiveFromSingleReg(regIdx int, analyze process.Analyze) (*batch.Batch, bool, error)

+ type RuntimeFilterChan struct

+ Chan chan *pipeline.RuntimeFilter

+ Spec *plan.RuntimeFilterSpec

+ type S3Writer struct

+ Bats []*batch.Batch

+ func AllocPartitionS3Writer(proc *process.Process, tableDef *plan.TableDef) ([]*S3Writer, error)

+ func AllocS3Writer(proc *process.Process, tableDef *plan.TableDef) (*S3Writer, error)

+ func (w *S3Writer) Free(proc *process.Process)

+ func (w *S3Writer) GenerateWriter(proc *process.Process) (objectio.ObjectName, error)

+ func (w *S3Writer) GetMetaLocBat() *batch.Batch

+ func (w *S3Writer) Init(proc *process.Process)

+ func (w *S3Writer) InitBuffers(proc *process.Process, bat *batch.Batch)

+ func (w *S3Writer) Output(proc *process.Process) error

+ func (w *S3Writer) Put(bat *batch.Batch, proc *process.Process) bool

+ func (w *S3Writer) ResetMetaLocBat(proc *process.Process)

+ func (w *S3Writer) SetMp(attrs []*engine.Attribute)

+ func (w *S3Writer) SetSortIdx(sortIdx int)

+ func (w *S3Writer) SortAndFlush(proc *process.Process) error

+ func (w *S3Writer) WriteBlock(bat *batch.Batch) error

+ func (w *S3Writer) WriteEndBlocks(proc *process.Process) ([]catalog.BlockInfo, error)

+ func (w *S3Writer) WriteS3Batch(proc *process.Process, bat *batch.Batch) error

+ func (w *S3Writer) WriteS3CacheBatch(proc *process.Process) error

type Server

+ func (srv *Server) DeleteTxnSegmentIds(sids []objectio.Segmentid)

+ func (srv *Server) GetCnSegmentMap() map[string]int32

+ func (srv *Server) GetCnSegmentType(sid *objectio.Segmentid) int32

+ func (srv *Server) PutCnSegment(sid *objectio.Segmentid, segmentType int32)

+ type UuidProcMap struct

+ type VarExpressionExecutor struct

+ func (expr *VarExpressionExecutor) Eval(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *VarExpressionExecutor) EvalWithoutResultReusing(proc *process.Process, batches []*batch.Batch) (*vector.Vector, error)

+ func (expr *VarExpressionExecutor) Free()

+ func (expr *VarExpressionExecutor) IsColumnExpr() bool

Feb 18, 2023

Changes in this version

+ var CnAddr string

+ func FilterAndDelByRowId(proc *process.Process, bat *batch.Batch, idxList []int32, ...) (uint64, error)

+ func FilterAndUpdateByRowId(eg engine.Engine, proc *process.Process, bat *batch.Batch, idxList [][]int32, ...) (uint64, error)

+ func GenerateIndex(container *WriteS3Container, fd objectio.BlockObject, ...) error

+ func GenerateWriter(container *WriteS3Container, proc *process.Process) error

+ func GetBlockMeta(bats []*batch.Batch, container *WriteS3Container, proc *process.Process, ...) error

+ func GetUpdateBatch(proc *process.Process, bat *batch.Batch, idxList []int32, batLen int, ...) (*batch.Batch, error)

+ func InsertBatch(container *WriteS3Container, eg engine.Engine, proc *process.Process, ...) (uint64, error)

+ func SortByPrimaryKey(proc *process.Process, bat *batch.Batch, pkIdx []int, m *mpool.MPool) error

+ func WriteBlock(container *WriteS3Container, bat *batch.Batch, proc *process.Process) error

+ func WriteEndBlocks(container *WriteS3Container, proc *process.Process, idx int) error

type AutoIncrParam

+ func (aip *AutoIncrParam) SetLastInsertID(id uint64)

+ type ReceiveInfo struct

+ NodeAddr string

+ Uuid uuid.UUID

+ type Server struct

+ CNSegmentId [12]byte

+ InitSegmentId bool

+ var Srv *Server

+ func NewServer(client logservice.CNHAKeeperClient) *Server

+ func (srv *Server) GenerateSegment() (string, error)

+ func (srv *Server) GetConnector(id uint64) *process.WaitRegister

+ func (srv *Server) GetNotifyChByUuid(u uuid.UUID) (chan process.WrapCs, bool)

+ func (srv *Server) HandleRequest(ctx context.Context, req morpc.Message, _ uint64, cs morpc.ClientSession) error

+ func (srv *Server) PutNotifyChIntoUuidMap(u uuid.UUID, ch chan process.WrapCs) error

+ func (srv *Server) RegistConnector(reg *process.WaitRegister) uint64

+ type UuidCsChanMap struct

+ type WriteS3Container struct

+ UniqueRels []engine.Relation

+ func NewWriteS3Container(tableDef *plan.TableDef) *WriteS3Container

+ func (container *WriteS3Container) WriteEnd(proc *process.Process)

+ func (container *WriteS3Container) WriteS3Batch(bat *batch.Batch, proc *process.Process, idx int) error

+ func (container *WriteS3Container) WriteS3CacheBatch(proc *process.Process) error

Nov 29, 2022

Changes in this version

+ var AUTO_INCR_TABLE = "%!%mo_increment_columns"

+ var AUTO_INCR_TABLE_COLNAME []string = []string

+ func CommitTxn(eg engine.Engine, txn client.TxnOperator, ctx context.Context) error

+ func CreateAutoIncrCol(eg engine.Engine, ctx context.Context, db engine.Database, ...) error

+ func CreateAutoIncrTable(e engine.Engine, ctx context.Context, proc *process.Process, dbName string) error

+ func DeleteAutoIncrCol(eg engine.Engine, ctx context.Context, rel engine.Relation, ...) error

+ func EvalExprByZonemapBat(bat *batch.Batch, proc *process.Process, expr *plan.Expr) (*vector.Vector, error)

+ func GetDeleteBatch(rel engine.Relation, ctx context.Context, colName string, mp *mpool.MPool) (*batch.Batch, uint64)

+ func GetNewRelation(eg engine.Engine, dbName, tbleName string, txn client.TxnOperator, ...) (engine.Relation, error)

+ func JoinFilterEvalExprInBucket(r, s *batch.Batch, rRow, sRow int, proc *process.Process, expr *plan.Expr) (*vector.Vector, error)

+ func MoveAutoIncrCol(eg engine.Engine, ctx context.Context, tblName string, db engine.Database, ...) error

+ func NewTxn(eg engine.Engine, proc *process.Process, ctx context.Context) (txn client.TxnOperator, err error)

+ func ResetAutoInsrCol(eg engine.Engine, ctx context.Context, tblName string, db engine.Database, ...) error

+ func RolllbackTxn(eg engine.Engine, txn client.TxnOperator, ctx context.Context) error

+ func SplitAndExprs(list []*plan.Expr) []*plan.Expr

+ func UpdateInsertBatch(e engine.Engine, ctx context.Context, proc *process.Process, ...) error

+ func UpdateInsertValueBatch(e engine.Engine, ctx context.Context, proc *process.Process, ...) error

+ type AutoIncrParam struct

+ type ResultPos struct

+ Pos int32

+ Rel int32

+ func NewResultPos(rel int32, pos int32) ResultPos

Jul 14, 2022

Changes in this version

+ func EvalExpr(bat *batch.Batch, proc *process.Process, expr *plan.Expr) (*vector.Vector, error)

+ func JoinFilterEvalExpr(r, s *batch.Batch, rRow int, proc *process.Process, expr *plan.Expr) (*vector.Vector, error)

+ func RewriteFilterExprList(list []*plan.Expr) *plan.Expr