vm

Documentation

Index

• func Prepare(ins Instructions, proc *process.Process) error
• func Run(ins Instructions, proc *process.Process) (end bool, err error)
• func String(ins Instructions, buf *bytes.Buffer)
• type Instruction
  • func (ins *Instruction) CannotRemote() bool
  • func (ins *Instruction) IsBrokenNode() bool
  • func (ins Instruction) MarshalBinary() ([]byte, error)
  • func (ins Instruction) UnmarshalBinary(_ []byte) error
• type InstructionArgument
• type Instructions
• type ModificationArgument
• type OpType

Functions

func Prepare

func Prepare(ins Instructions, proc *process.Process) error

Prepare range instructions and do init work for each operator's argument by calling its prepare function

func Run

func Run(ins Instructions, proc *process.Process) (end bool, err error)

func String

func String(ins Instructions, buf *bytes.Buffer)

String range instructions and call each operator's string function to show a query plan

Types

type Instruction

type Instruction struct {
	// Op specified the operator code of an instruction.
	Op OpType
	// Idx specified the analysis information index.
	Idx int
	// Arg contains the operand of this instruction.
	Arg InstructionArgument

	// flag for analyzeInfo record the row information
	IsFirst bool
	IsLast  bool
}

Instruction contains relational algebra

func (*Instruction) CannotRemote

func (ins *Instruction) CannotRemote() bool

func (*Instruction) IsBrokenNode

func (ins *Instruction) IsBrokenNode() bool

func (Instruction) MarshalBinary

func (ins Instruction) MarshalBinary() ([]byte, error)

func (Instruction) UnmarshalBinary

func (ins Instruction) UnmarshalBinary(_ []byte) error

type InstructionArgument

type InstructionArgument interface {
	// Free release all the memory allocated from mPool in an operator.
	// pipelineFailed marks the process status of the pipeline when the method is called.
	Free(proc *process.Process, pipelineFailed bool, err error)
}

type Instructions

type Instructions []Instruction

type ModificationArgument

type ModificationArgument interface {
	AffectedRows() uint64
}

type OpType

type OpType int

const (
	Top OpType = iota
	Limit
	Order
	Group
	Window
	Output
	Offset
	Product
	Restrict
	Dispatch
	Connector
	Projection

	Join
	LoopJoin
	Left
	LoopLeft
	Single
	LoopSingle
	Semi
	RightSemi
	LoopSemi
	Anti
	RightAnti
	LoopAnti
	Mark
	LoopMark

	Merge
	MergeTop
	MergeLimit
	MergeOrder
	MergeGroup
	MergeOffset
	MergeRecursive
	MergeCTE

	Deletion
	Insert
	External
	Stream

	Minus
	Intersect
	IntersectAll

	HashBuild

	TableFunction
	// MergeBlock is used to recieve S3 block metLoc Info, and write
	// them to S3
	MergeBlock
	// MergeDelete is used to recieve S3 Blcok Delete Info from remote Cn
	MergeDelete
	Right
	OnDuplicateKey
	PreInsert
	PreInsertUnique
	// LastInstructionOp is not a true operator and must set at last.
	// It was used by unit testing to ensure that
	// all functions related to instructions can reach 100% coverage.
	LastInstructionOp

	// LockOp is used to add locks to lockservice for pessimistic transactions.
	// Operator that encounters a write conflict will block until the previous
	// transaction has released the lock
	LockOp

	Shuffle
)