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
Constants ¶
This section is empty.
Variables ¶
View Source
var AUTO_INCR_TABLE = "%!%mo_increment_columns"
View Source
var AUTO_INCR_TABLE_COLNAME []string = []string{catalog.Row_ID, "name", "offset", "step"}
Functions ¶
func CreateAutoIncrCol ¶ added in v0.6.0
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 ¶ added in v0.6.0
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 ¶ added in v0.6.0
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 EvalExprByZonemapBat ¶ added in v0.6.0
func GetDeleteBatch ¶ added in v0.6.0
func GetNewRelation ¶ added in v0.6.0
func JoinFilterEvalExpr ¶
func JoinFilterEvalExprInBucket ¶ added in v0.6.0
func MoveAutoIncrCol ¶ added in v0.6.0
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 ResetAutoInsrCol ¶ added in v0.6.0
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 ¶
RewriteFilterExprList will convert an expression list to be an AndExpr
func RolllbackTxn ¶ added in v0.6.0
func UpdateInsertBatch ¶ added in v0.6.0
Types ¶
type AutoIncrParam ¶ added in v0.6.0
type AutoIncrParam struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.