executor

Documentation

Index

• Variables
• func Execute(executor Executor, ctx context.Context) (result []btuple.Modifier, ids []primitive.ObjectID, err error)
• func NewExecutorBuilder(ctx session.Context) *executorBuilder
• type Executor
  • func NewConstExecutor(ctx session.Context, constPlan plan.ConstPlan) Executor
  • func NewDeleteExecutor(ctx session.Context, deletePlan plan.DeletePlan, child Executor) (Executor, error)
  • func NewIndexScanExecutor(ctx session.Context, scanPlan plan.IndexScanPlan) (Executor, error)
  • func NewInsertExecutor(ctx session.Context, insertPlan plan.InsertPlan, child Executor) (Executor, error)
  • func NewLimitExecutor(ctx session.Context, limitPlan plan.LimitPlan, child Executor) Executor
  • func NewMultiIndexScanExecutor(ctx session.Context, scanPlan plan.MultiIndexScan, left, right Executor) (Executor, error)
  • func NewSchemaExec(ctx session.Context, plan plan.SchemaPlan) Executor
  • func NewSeqScanExecutor(ctx session.Context, scanPlan plan.SeqScanPlan) (Executor, error)
  • func NewTableRowIdScanExecutor(ctx session.Context, plan *plan.TableRowIdScan, child Executor) (Executor, error)
  • func NewUpdateExecutor(ctx session.Context, updatePlan plan.UpdatePlan, child Executor) (Executor, error)

Variables

var (
	ErrMissChildPlan = errors.New("miss child plan")
)

var (
	ErrUnknownEvaluationResult = errors.New("unknown evaluation value")
)

Functions

func Execute

func Execute(executor Executor, ctx context.Context) (result []btuple.Modifier, ids []primitive.ObjectID, err error)

func NewExecutorBuilder

func NewExecutorBuilder(ctx session.Context) *executorBuilder

Types

type Executor

type Executor interface {
	Init()
	Next(ctx context.Context, tuple *btuple.Modifier, rid *primitive.ObjectID) (bool, error)
	Close() error
}

func NewConstExecutor

func NewConstExecutor(ctx session.Context, constPlan plan.ConstPlan) Executor

func NewDeleteExecutor

func NewDeleteExecutor(ctx session.Context, deletePlan plan.DeletePlan, child Executor) (Executor, error)

func NewIndexScanExecutor

func NewIndexScanExecutor(ctx session.Context, scanPlan plan.IndexScanPlan) (Executor, error)

func NewInsertExecutor

func NewInsertExecutor(ctx session.Context, insertPlan plan.InsertPlan, child Executor) (Executor, error)

func NewLimitExecutor

func NewLimitExecutor(ctx session.Context, limitPlan plan.LimitPlan, child Executor) Executor

func NewMultiIndexScanExecutor

func NewMultiIndexScanExecutor(ctx session.Context, scanPlan plan.MultiIndexScan, left, right Executor) (Executor, error)

func NewSchemaExec

func NewSchemaExec(ctx session.Context, plan plan.SchemaPlan) Executor

func NewSeqScanExecutor

func NewSeqScanExecutor(ctx session.Context, scanPlan plan.SeqScanPlan) (Executor, error)

func NewTableRowIdScanExecutor

func NewTableRowIdScanExecutor(ctx session.Context, plan *plan.TableRowIdScan, child Executor) (Executor, error)

func NewUpdateExecutor

func NewUpdateExecutor(ctx session.Context, updatePlan plan.UpdatePlan, child Executor) (Executor, error)