colexec

Documentation

Index

• Variables
• 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 EvalExpr(bat *batch.Batch, proc *process.Process, expr *plan.Expr) (*vector.Vector, 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 JoinFilterEvalExpr(r, s *batch.Batch, rRow int, proc *process.Process, expr *plan.Expr) (*vector.Vector, 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 RewriteFilterExprList(list []*plan.Expr) *plan.Expr
• 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
• type ResultPos
  • func NewResultPos(rel int32, pos int32) ResultPos

Variables

var AUTO_INCR_TABLE = "%!%mo_increment_columns"

var AUTO_INCR_TABLE_COLNAME []string = []string{catalog.Row_ID, "name", "offset", "step"}

Functions

func CommitTxn

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

func CreateAutoIncrCol

func CreateAutoIncrCol(eg engine.Engine, ctx context.Context, db engine.Database, proc *process.Process, cols []*plan.ColDef, dbName, tblName string) error

for create table operation, add col in mo_increment_columns table

func CreateAutoIncrTable

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

for create database operation, add col in mo_increment_columns table

func DeleteAutoIncrCol

func DeleteAutoIncrCol(eg engine.Engine, ctx context.Context, rel engine.Relation, proc *process.Process, dbName, tableID string) error

for delete table operation, delete col in mo_increment_columns table

func EvalExpr

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

func EvalExprByZonemapBat

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

func GetDeleteBatch

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

func GetNewRelation

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

func JoinFilterEvalExpr

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

func JoinFilterEvalExprInBucket

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

func MoveAutoIncrCol

func MoveAutoIncrCol(eg engine.Engine, ctx context.Context, tblName string, db engine.Database, proc *process.Process, oldTableID, dbName string) error

for delete table operation, move old col as new col in mo_increment_columns table

func NewTxn

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

func ResetAutoInsrCol

func ResetAutoInsrCol(eg engine.Engine, ctx context.Context, tblName string, db engine.Database, proc *process.Process, tableID, dbName string) error

for truncate table operation, reset col in mo_increment_columns table

func RewriteFilterExprList

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

RewriteFilterExprList will convert an expression list to be an AndExpr

func RolllbackTxn

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

func SplitAndExprs

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

func UpdateInsertBatch

func UpdateInsertBatch(e engine.Engine, ctx context.Context, proc *process.Process, ColDefs []*plan.ColDef, bat *batch.Batch, tableID, dbName, tblName string) error

func UpdateInsertValueBatch

func UpdateInsertValueBatch(e engine.Engine, ctx context.Context, proc *process.Process, p *plan.InsertValues, bat *batch.Batch, dbName, tblName string) error

Types

type AutoIncrParam

type AutoIncrParam struct {
	// contains filtered or unexported fields
}

type ResultPos

type ResultPos struct {
	Rel int32
	Pos int32
}

func NewResultPos

func NewResultPos(rel int32, pos int32) ResultPos