plan

package
v0.0.0-...-6dbff61 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2017 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

View Source 
const (
	// TypeSel is the type of Selection.
	TypeSel = "Selection"
	// TypeSet is the type of Set.
	TypeSet = "Set"
	// TypeProj is the type of Projection.
	TypeProj = "Projection"
	// TypeAgg is the type of Aggregation.
	TypeAgg = "Aggregation"
	// TypeStreamAgg is the type of StreamAgg.
	TypeStreamAgg = "StreamAgg"
	// TypeHashAgg is the type of HashAgg.
	TypeHashAgg = "HashAgg"
	// TypeCache is the type of cache.
	TypeCache = "Cache"
	// TypeShow is the type of show.
	TypeShow = "Show"
	// TypeJoin is the type of Join.
	TypeJoin = "Join"
	// TypeUnion is the type of Union.
	TypeUnion = "Union"
	// TypeTableScan is the type of TableScan.
	TypeTableScan = "TableScan"
	// TypeMemTableScan is the type of TableScan.
	TypeMemTableScan = "MemTableScan"
	// TypeUnionScan is the type of UnionScan.
	TypeUnionScan = "UnionScan"
	// TypeIdxScan is the type of IndexScan.
	TypeIdxScan = "IndexScan"
	// TypeSort is the type of Sort.
	TypeSort = "Sort"
	// TypeTopN is the type of TopN.
	TypeTopN = "TopN"
	// TypeLimit is the type of Limit.
	TypeLimit = "Limit"
	// TypeHashSemiJoin is the type of hash semi join.
	TypeHashSemiJoin = "HashSemiJoin"
	// TypeHashLeftJoin is the type of left hash join.
	TypeHashLeftJoin = "HashLeftJoin"
	// TypeHashRightJoin is the type of right hash join.
	TypeHashRightJoin = "HashRightJoin"
	// TypeMergeJoin is the type of merge join.
	TypeMergeJoin = "MergeJoin"
	// TypeIndexJoin is the type of index look up join.
	TypeIndexJoin = "IndexJoin"
	// TypeApply is the type of Apply.
	TypeApply = "Apply"
	// TypeMaxOneRow is the type of MaxOneRow.
	TypeMaxOneRow = "MaxOneRow"
	// TypeExists is the type of Exists.
	TypeExists = "Exists"
	// TypeDual is the type of TableDual.
	TypeDual = "TableDual"
	// TypeLock is the type of SelectLock.
	TypeLock = "SelectLock"
	// TypeInsert is the type of Insert
	TypeInsert = "Insert"
	// TypeUpate is the type of Update.
	TypeUpate = "Update"
	// TypeDelete is the type of Delete.
	TypeDelete = "Delete"
	// TypeIndexLookUp is the type of IndexLookUp.
	TypeIndexLookUp = "IndexLookUp"
	// TypeTableReader is the type of TableReader.
	TypeTableReader = "TableReader"
	// TypeIndexReader is the type of IndexReader.
	TypeIndexReader = "IndexReader"
)
View Source 
const (
	// TiDBMergeJoin is hint enforce merge join.
	TiDBMergeJoin = "tidb_smj"
	// TiDBIndexNestedLoopJoin is hint enforce index nested loop join.
	TiDBIndexNestedLoopJoin = "tidb_inlj"
)
View Source 
const (
	CodeOperandColumns      terror.ErrCode = 1
	CodeInvalidWildCard     terror.ErrCode = 3
	CodeUnsupported         terror.ErrCode = 4
	CodeInvalidGroupFuncUse terror.ErrCode = 5
	CodeIllegalReference    terror.ErrCode = 6
)

Optimizer error codes.

View Source 
const (
	CodeUnsupportedType  terror.ErrCode = 1
	SystemInternalError  terror.ErrCode = 2
	CodeAlterAutoID      terror.ErrCode = 3
	CodeAnalyzeMissIndex terror.ErrCode = 4
	CodeAmbiguous        terror.ErrCode = 1052
	CodeUnknownColumn    terror.ErrCode = 1054
	CodeWrongArguments   terror.ErrCode = 1210
)

Error codes.

Variables ¶

View Source 
var (
	ErrOperandColumns              = terror.ClassOptimizer.New(CodeOperandColumns, "Operand should contain %d column(s)")
	ErrInvalidWildCard             = terror.ClassOptimizer.New(CodeInvalidWildCard, "Wildcard fields without any table name appears in wrong place")
	ErrCartesianProductUnsupported = terror.ClassOptimizer.New(CodeUnsupported, "Cartesian product is unsupported")
	ErrInvalidGroupFuncUse         = terror.ClassOptimizer.New(CodeInvalidGroupFuncUse, "Invalid use of group function")
	ErrIllegalReference            = terror.ClassOptimizer.New(CodeIllegalReference, "Illegal reference")
)

Optimizer base errors.

View Source 
var (
	ErrUnsupportedType      = terror.ClassOptimizerPlan.New(CodeUnsupportedType, "Unsupported type")
	SystemInternalErrorType = terror.ClassOptimizerPlan.New(SystemInternalError, "System internal error")
	ErrUnknownColumn        = terror.ClassOptimizerPlan.New(CodeUnknownColumn, "Unknown column '%s' in '%s'")
	ErrWrongArguments       = terror.ClassOptimizerPlan.New(CodeWrongArguments, "Incorrect arguments to EXECUTE")
	ErrAmbiguous            = terror.ClassOptimizerPlan.New(CodeAmbiguous, "Column '%s' in field list is ambiguous")
	ErrAnalyzeMissIndex     = terror.ClassOptimizerPlan.New(CodeAnalyzeMissIndex, "Index '%s' in field list does not exist in table '%s'")
	ErrAlterAutoID          = terror.ClassAutoid.New(CodeAlterAutoID, "No support for setting auto_increment using alter_table")
)

Error instances.

View Source 
var AllowCartesianProduct = true

AllowCartesianProduct means whether tidb allows cartesian join without equal conditions.

View Source 
var EvalSubquery func(p PhysicalPlan, is infoschema.InfoSchema, ctx context.Context) ([][]types.Datum, error)

EvalSubquery evaluates incorrelated subqueries once.

View Source 
var JoinConcurrency = 5

JoinConcurrency means the number of goroutines that participate in joining.

Functions ¶

func InsertPlan ¶ 

func InsertPlan(parent Plan, child Plan, insert Plan) error

InsertPlan means inserting plan between two plans.

func MockResolveName ¶ 

func MockResolveName(node ast.Node, info infoschema.InfoSchema, defaultSchema string, ctx context.Context) error

MockResolveName only serves for test.

func PrepareStmt ¶ 

func PrepareStmt(is infoschema.InfoSchema, ctx context.Context, node ast.Node) error

PrepareStmt prepares a raw statement parsed from parser. The statement must be prepared before it can be passed to optimize function. We pass InfoSchema instead of getting from Context in case it is changed after resolving name.

func Preprocess ¶ 

func Preprocess(node ast.Node, info infoschema.InfoSchema, ctx context.Context) error

Preprocess does preprocess work for optimizer.

func RemovePlan ¶ 

func RemovePlan(p Plan) error

RemovePlan means removing a plan.

func ResolveName ¶ 

func ResolveName(node ast.Node, info infoschema.InfoSchema, ctx context.Context) error

ResolveName resolves table name and column name. It generates ResultFields for ResultSetNode and resolves ColumnNameExpr to a ResultField.

func ToString ¶ 

func ToString(p Plan) string

ToString explains a Plan, returns description string.

func Validate ¶ 

func Validate(node ast.Node, inPrepare bool) error

Validate checkes whether the node is valid.

Types ¶

type AggregateFuncExtractor ¶ 

type AggregateFuncExtractor struct {

	// AggFuncs is the collected AggregateFuncExprs.
	AggFuncs []*ast.AggregateFuncExpr
	// contains filtered or unexported fields
}

AggregateFuncExtractor visits Expr tree. It converts ColunmNameExpr to AggregateFuncExpr and collects AggregateFuncExpr.

func (*AggregateFuncExtractor) Enter ¶ 

func (a *AggregateFuncExtractor) Enter(n ast.Node) (ast.Node, bool)

Enter implements Visitor interface.

func (*AggregateFuncExtractor) Leave ¶ 

func (a *AggregateFuncExtractor) Leave(n ast.Node) (ast.Node, bool)

Leave implements Visitor interface.

type AggregationType ¶ 

type AggregationType int

AggregationType stands for the mode of aggregation plan. 

const (
	// StreamedAgg supposes its input is sorted by group by key.
	StreamedAgg AggregationType = iota
	// FinalAgg supposes its input is partial results.
	FinalAgg
	// CompleteAgg supposes its input is original results.
	CompleteAgg
)

type Analyze ¶ 

type Analyze struct {
	PkTasks  []AnalyzePKTask
	ColTasks []AnalyzeColumnsTask
	IdxTasks []AnalyzeIndexTask
	// contains filtered or unexported fields
}

Analyze represents an analyze plan

func (*Analyze) AddChild ¶ 

func (p *Analyze) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Analyze) AddParent ¶ 

func (p *Analyze) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Analyze) Allocator ¶ 

func (p *Analyze) Allocator() *idAllocator

func (*Analyze) Children ¶ 

func (p *Analyze) Children() []Plan

Children implements Plan Children interface.

func (*Analyze) ID ¶ 

func (p *Analyze) ID() string

ID implements Plan ID interface.

func (*Analyze) MarshalJSON ¶ 

func (p *Analyze) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Analyze) Parents ¶ 

func (p *Analyze) Parents() []Plan

Parents implements Plan Parents interface.

func (*Analyze) PruneColumns ¶ 

func (p *Analyze) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface. We should not prune columns for Analyze.

func (*Analyze) ReplaceChild ¶ 

func (p *Analyze) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Analyze) ReplaceParent ¶ 

func (p *Analyze) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Analyze) ResolveIndices ¶ 

func (p *Analyze) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Analyze) Schema ¶ 

func (p *Analyze) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Analyze) SetChildren ¶ 

func (p *Analyze) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Analyze) SetParents ¶ 

func (p *Analyze) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Analyze) SetSchema ¶ 

func (p *Analyze) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type AnalyzeColumnsTask ¶ 

type AnalyzeColumnsTask struct {
	TableInfo *model.TableInfo
	ColsInfo  []*model.ColumnInfo
}

AnalyzeColumnsTask is used for analyze columns.

type AnalyzeIndexTask ¶ 

type AnalyzeIndexTask struct {
	TableInfo *model.TableInfo
	IndexInfo *model.IndexInfo
}

AnalyzeIndexTask is used for analyze index.

type AnalyzePKTask ¶ 

type AnalyzePKTask struct {
	TableInfo *model.TableInfo
	PKInfo    *model.ColumnInfo
}

AnalyzePKTask is used for analyze pk. Used only when pk is handle.

type ApplyConditionChecker ¶ 

type ApplyConditionChecker struct {
	Condition expression.Expression
	All       bool
}

ApplyConditionChecker checks whether all or any output of apply matches a condition.

type ByItems ¶ 

type ByItems struct {
	Expr expression.Expression
	Desc bool
}

ByItems wraps a "by" item.

func (*ByItems) String ¶ 

func (by *ByItems) String() string

String implements fmt.Stringer interface.

type Cache ¶ 

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

Cache plan is a physical plan which stores the result of its child node.

func (Cache) AddChild ¶ 

func (p Cache) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Cache) AddParent ¶ 

func (p Cache) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Cache) Allocator ¶ 

func (p Cache) Allocator() *idAllocator

func (Cache) Children ¶ 

func (p Cache) Children() []Plan

Children implements Plan Children interface.

func (*Cache) Copy ¶ 

func (p *Cache) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Cache) ID ¶ 

func (p Cache) ID() string

ID implements Plan ID interface.

func (Cache) MarshalJSON ¶ 

func (p Cache) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Cache) Parents ¶ 

func (p Cache) Parents() []Plan

Parents implements Plan Parents interface.

func (Cache) ReplaceChild ¶ 

func (p Cache) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Cache) ReplaceParent ¶ 

func (p Cache) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (Cache) ResolveIndices ¶ 

func (p Cache) ResolveIndices()

ResolveIndices implements Plan interface.

func (Cache) Schema ¶ 

func (p Cache) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Cache) SetChildren ¶ 

func (p Cache) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Cache) SetParents ¶ 

func (p Cache) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Cache) SetSchema ¶ 

func (p Cache) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Cache) ToPB ¶ 

func (p *Cache) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type CheckTable ¶ 

type CheckTable struct {
	Tables []*ast.TableName
	// contains filtered or unexported fields
}

CheckTable is used for checking table data, built from the 'admin check table' statement.

func (*CheckTable) AddChild ¶ 

func (p *CheckTable) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*CheckTable) AddParent ¶ 

func (p *CheckTable) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*CheckTable) Allocator ¶ 

func (p *CheckTable) Allocator() *idAllocator

func (*CheckTable) Children ¶ 

func (p *CheckTable) Children() []Plan

Children implements Plan Children interface.

func (*CheckTable) ID ¶ 

func (p *CheckTable) ID() string

ID implements Plan ID interface.

func (*CheckTable) MarshalJSON ¶ 

func (p *CheckTable) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*CheckTable) Parents ¶ 

func (p *CheckTable) Parents() []Plan

Parents implements Plan Parents interface.

func (*CheckTable) ReplaceChild ¶ 

func (p *CheckTable) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*CheckTable) ReplaceParent ¶ 

func (p *CheckTable) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*CheckTable) ResolveIndices ¶ 

func (p *CheckTable) ResolveIndices()

ResolveIndices implements Plan interface.

func (*CheckTable) Schema ¶ 

func (p *CheckTable) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*CheckTable) SetChildren ¶ 

func (p *CheckTable) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*CheckTable) SetParents ¶ 

func (p *CheckTable) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*CheckTable) SetSchema ¶ 

func (p *CheckTable) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type DDL ¶ 

type DDL struct {
	Statement ast.DDLNode
	// contains filtered or unexported fields
}

DDL represents a DDL statement plan.

func (*DDL) AddChild ¶ 

func (p *DDL) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*DDL) AddParent ¶ 

func (p *DDL) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*DDL) Allocator ¶ 

func (p *DDL) Allocator() *idAllocator

func (*DDL) Children ¶ 

func (p *DDL) Children() []Plan

Children implements Plan Children interface.

func (*DDL) ID ¶ 

func (p *DDL) ID() string

ID implements Plan ID interface.

func (*DDL) MarshalJSON ¶ 

func (p *DDL) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*DDL) Parents ¶ 

func (p *DDL) Parents() []Plan

Parents implements Plan Parents interface.

func (*DDL) ReplaceChild ¶ 

func (p *DDL) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*DDL) ReplaceParent ¶ 

func (p *DDL) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*DDL) ResolveIndices ¶ 

func (p *DDL) ResolveIndices()

ResolveIndices implements Plan interface.

func (*DDL) Schema ¶ 

func (p *DDL) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*DDL) SetChildren ¶ 

func (p *DDL) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*DDL) SetParents ¶ 

func (p *DDL) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*DDL) SetSchema ¶ 

func (p *DDL) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type DataSource ¶ 

type DataSource struct {
	Columns []*model.ColumnInfo
	DBName  model.CIStr

	TableAsName *model.CIStr

	LimitCount *int64
	// contains filtered or unexported fields
}

DataSource represents a tablescan without condition push down.

func (DataSource) AddChild ¶ 

func (p DataSource) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (DataSource) AddParent ¶ 

func (p DataSource) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (DataSource) Allocator ¶ 

func (p DataSource) Allocator() *idAllocator

func (DataSource) Children ¶ 

func (p DataSource) Children() []Plan

Children implements Plan Children interface.

func (DataSource) ID ¶ 

func (p DataSource) ID() string

ID implements Plan ID interface.

func (DataSource) MarshalJSON ¶ 

func (p DataSource) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (DataSource) Parents ¶ 

func (p DataSource) Parents() []Plan

Parents implements Plan Parents interface.

func (*DataSource) PredicatePushDown ¶ 

func (p *DataSource) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*DataSource) PruneColumns ¶ 

func (p *DataSource) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (DataSource) ReplaceChild ¶ 

func (p DataSource) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (DataSource) ReplaceParent ¶ 

func (p DataSource) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (DataSource) ResolveIndices ¶ 

func (p DataSource) ResolveIndices()

ResolveIndices implements Plan interface.

func (DataSource) Schema ¶ 

func (p DataSource) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (DataSource) SetChildren ¶ 

func (p DataSource) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (DataSource) SetParents ¶ 

func (p DataSource) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (DataSource) SetSchema ¶ 

func (p DataSource) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*DataSource) TableInfo ¶ 

func (p *DataSource) TableInfo() *model.TableInfo

TableInfo returns the *TableInfo of data source.

type Deallocate ¶ 

type Deallocate struct {
	Name string
	// contains filtered or unexported fields
}

Deallocate represents deallocate plan.

func (*Deallocate) AddChild ¶ 

func (p *Deallocate) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Deallocate) AddParent ¶ 

func (p *Deallocate) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Deallocate) Allocator ¶ 

func (p *Deallocate) Allocator() *idAllocator

func (*Deallocate) Children ¶ 

func (p *Deallocate) Children() []Plan

Children implements Plan Children interface.

func (*Deallocate) ID ¶ 

func (p *Deallocate) ID() string

ID implements Plan ID interface.

func (*Deallocate) MarshalJSON ¶ 

func (p *Deallocate) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Deallocate) Parents ¶ 

func (p *Deallocate) Parents() []Plan

Parents implements Plan Parents interface.

func (*Deallocate) ReplaceChild ¶ 

func (p *Deallocate) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Deallocate) ReplaceParent ¶ 

func (p *Deallocate) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Deallocate) ResolveIndices ¶ 

func (p *Deallocate) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Deallocate) Schema ¶ 

func (p *Deallocate) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Deallocate) SetChildren ¶ 

func (p *Deallocate) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Deallocate) SetParents ¶ 

func (p *Deallocate) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Deallocate) SetSchema ¶ 

func (p *Deallocate) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Delete ¶ 

type Delete struct {
	Tables       []*ast.TableName
	IsMultiTable bool
	// contains filtered or unexported fields
}

Delete represents a delete plan.

func (Delete) AddChild ¶ 

func (p Delete) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Delete) AddParent ¶ 

func (p Delete) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Delete) Allocator ¶ 

func (p Delete) Allocator() *idAllocator

func (Delete) Children ¶ 

func (p Delete) Children() []Plan

Children implements Plan Children interface.

func (*Delete) Copy ¶ 

func (p *Delete) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Delete) ID ¶ 

func (p Delete) ID() string

ID implements Plan ID interface.

func (Delete) MarshalJSON ¶ 

func (p Delete) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Delete) Parents ¶ 

func (p Delete) Parents() []Plan

Parents implements Plan Parents interface.

func (*Delete) PredicatePushDown ¶ 

func (p *Delete) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*Delete) PruneColumns ¶ 

func (p *Delete) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Delete) ReplaceChild ¶ 

func (p Delete) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Delete) ReplaceParent ¶ 

func (p Delete) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (Delete) ResolveIndices ¶ 

func (p Delete) ResolveIndices()

ResolveIndices implements Plan interface.

func (Delete) Schema ¶ 

func (p Delete) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Delete) SetChildren ¶ 

func (p Delete) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Delete) SetParents ¶ 

func (p Delete) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Delete) SetSchema ¶ 

func (p Delete) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Delete) ToPB ¶ 

func (p *Delete) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Execute ¶ 

type Execute struct {
	Name      string
	UsingVars []expression.Expression
	ExecID    uint32
	// contains filtered or unexported fields
}

Execute represents prepare plan.

func (*Execute) AddChild ¶ 

func (p *Execute) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Execute) AddParent ¶ 

func (p *Execute) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Execute) Allocator ¶ 

func (p *Execute) Allocator() *idAllocator

func (*Execute) Children ¶ 

func (p *Execute) Children() []Plan

Children implements Plan Children interface.

func (*Execute) ID ¶ 

func (p *Execute) ID() string

ID implements Plan ID interface.

func (*Execute) MarshalJSON ¶ 

func (p *Execute) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Execute) Parents ¶ 

func (p *Execute) Parents() []Plan

Parents implements Plan Parents interface.

func (*Execute) ReplaceChild ¶ 

func (p *Execute) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Execute) ReplaceParent ¶ 

func (p *Execute) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Execute) ResolveIndices ¶ 

func (p *Execute) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Execute) Schema ¶ 

func (p *Execute) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Execute) SetChildren ¶ 

func (p *Execute) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Execute) SetParents ¶ 

func (p *Execute) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Execute) SetSchema ¶ 

func (p *Execute) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Exists ¶ 

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

Exists checks if a query returns result.

func (Exists) AddChild ¶ 

func (p Exists) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Exists) AddParent ¶ 

func (p Exists) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Exists) Allocator ¶ 

func (p Exists) Allocator() *idAllocator

func (Exists) Children ¶ 

func (p Exists) Children() []Plan

Children implements Plan Children interface.

func (*Exists) Copy ¶ 

func (p *Exists) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Exists) ID ¶ 

func (p Exists) ID() string

ID implements Plan ID interface.

func (Exists) MarshalJSON ¶ 

func (p Exists) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Exists) Parents ¶ 

func (p Exists) Parents() []Plan

Parents implements Plan Parents interface.

func (*Exists) PredicatePushDown ¶ 

func (p *Exists) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*Exists) PruneColumns ¶ 

func (p *Exists) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Exists) ReplaceChild ¶ 

func (p Exists) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Exists) ReplaceParent ¶ 

func (p Exists) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (Exists) ResolveIndices ¶ 

func (p Exists) ResolveIndices()

ResolveIndices implements Plan interface.

func (Exists) Schema ¶ 

func (p Exists) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Exists) SetChildren ¶ 

func (p Exists) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Exists) SetParents ¶ 

func (p Exists) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Exists) SetSchema ¶ 

func (p Exists) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Exists) ToPB ¶ 

func (p *Exists) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Explain ¶ 

type Explain struct {
	StmtPlan Plan
	// contains filtered or unexported fields
}

Explain represents a explain plan.

func (*Explain) AddChild ¶ 

func (p *Explain) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Explain) AddParent ¶ 

func (p *Explain) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Explain) Allocator ¶ 

func (p *Explain) Allocator() *idAllocator

func (*Explain) Children ¶ 

func (p *Explain) Children() []Plan

Children implements Plan Children interface.

func (*Explain) ID ¶ 

func (p *Explain) ID() string

ID implements Plan ID interface.

func (*Explain) MarshalJSON ¶ 

func (p *Explain) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Explain) Parents ¶ 

func (p *Explain) Parents() []Plan

Parents implements Plan Parents interface.

func (*Explain) ReplaceChild ¶ 

func (p *Explain) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Explain) ReplaceParent ¶ 

func (p *Explain) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Explain) ResolveIndices ¶ 

func (p *Explain) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Explain) Schema ¶ 

func (p *Explain) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Explain) SetChildren ¶ 

func (p *Explain) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Explain) SetParents ¶ 

func (p *Explain) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Explain) SetSchema ¶ 

func (p *Explain) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Insert ¶ 

type Insert struct {
	Table table.Table

	Columns     []*ast.ColumnName
	Lists       [][]expression.Expression
	Setlist     []*expression.Assignment
	OnDuplicate []*expression.Assignment

	IsReplace bool
	Priority  int
	Ignore    bool
	// contains filtered or unexported fields
}

Insert represents an insert plan.

func (Insert) AddChild ¶ 

func (p Insert) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Insert) AddParent ¶ 

func (p Insert) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Insert) Allocator ¶ 

func (p Insert) Allocator() *idAllocator

func (Insert) Children ¶ 

func (p Insert) Children() []Plan

Children implements Plan Children interface.

func (*Insert) Copy ¶ 

func (p *Insert) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Insert) ID ¶ 

func (p Insert) ID() string

ID implements Plan ID interface.

func (Insert) MarshalJSON ¶ 

func (p Insert) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Insert) Parents ¶ 

func (p Insert) Parents() []Plan

Parents implements Plan Parents interface.

func (*Insert) PredicatePushDown ¶ 

func (p *Insert) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*Insert) PruneColumns ¶ 

func (p *Insert) PruneColumns(_ []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Insert) ReplaceChild ¶ 

func (p Insert) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Insert) ReplaceParent ¶ 

func (p Insert) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Insert) ResolveIndices ¶ 

func (p *Insert) ResolveIndices()

ResolveIndices implements Plan interface.

func (Insert) Schema ¶ 

func (p Insert) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Insert) SetChildren ¶ 

func (p Insert) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Insert) SetParents ¶ 

func (p Insert) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Insert) SetSchema ¶ 

func (p Insert) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Insert) ToPB ¶ 

func (p *Insert) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type JoinType ¶ 

type JoinType int

JoinType contains CrossJoin, InnerJoin, LeftOuterJoin, RightOuterJoin, FullOuterJoin, SemiJoin. 

const (
	// InnerJoin means inner join.
	InnerJoin JoinType = iota
	// LeftOuterJoin means left join.
	LeftOuterJoin
	// RightOuterJoin means right join.
	RightOuterJoin
	// SemiJoin means if row a in table A matches some rows in B, just output a.
	SemiJoin
	// LeftOuterSemiJoin means if row a in table A matches some rows in B, output (a, true), otherwise, output (a, false).
	LeftOuterSemiJoin
)

type Limit ¶ 

type Limit struct {
	Offset uint64
	Count  uint64
	// contains filtered or unexported fields
}

Limit represents offset and limit plan.

func (Limit) AddChild ¶ 

func (p Limit) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Limit) AddParent ¶ 

func (p Limit) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Limit) Allocator ¶ 

func (p Limit) Allocator() *idAllocator

func (Limit) Children ¶ 

func (p Limit) Children() []Plan

Children implements Plan Children interface.

func (*Limit) Copy ¶ 

func (p *Limit) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Limit) ID ¶ 

func (p Limit) ID() string

ID implements Plan ID interface.

func (*Limit) MarshalJSON ¶ 

func (p *Limit) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Limit) Parents ¶ 

func (p Limit) Parents() []Plan

Parents implements Plan Parents interface.

func (*Limit) PredicatePushDown ¶ 

func (p *Limit) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*Limit) PruneColumns ¶ 

func (p *Limit) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Limit) ReplaceChild ¶ 

func (p Limit) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Limit) ReplaceParent ¶ 

func (p Limit) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (Limit) ResolveIndices ¶ 

func (p Limit) ResolveIndices()

ResolveIndices implements Plan interface.

func (Limit) Schema ¶ 

func (p Limit) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Limit) SetChildren ¶ 

func (p Limit) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Limit) SetParents ¶ 

func (p Limit) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Limit) SetSchema ¶ 

func (p Limit) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Limit) ToPB ¶ 

func (p *Limit) ToPB(ctx context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type LoadData ¶ 

type LoadData struct {
	IsLocal    bool
	Path       string
	Table      *ast.TableName
	Columns    []*ast.ColumnName
	FieldsInfo *ast.FieldsClause
	LinesInfo  *ast.LinesClause
	// contains filtered or unexported fields
}

LoadData represents a loaddata plan.

func (*LoadData) AddChild ¶ 

func (p *LoadData) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*LoadData) AddParent ¶ 

func (p *LoadData) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*LoadData) Allocator ¶ 

func (p *LoadData) Allocator() *idAllocator

func (*LoadData) Children ¶ 

func (p *LoadData) Children() []Plan

Children implements Plan Children interface.

func (*LoadData) ID ¶ 

func (p *LoadData) ID() string

ID implements Plan ID interface.

func (*LoadData) MarshalJSON ¶ 

func (p *LoadData) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*LoadData) Parents ¶ 

func (p *LoadData) Parents() []Plan

Parents implements Plan Parents interface.

func (*LoadData) ReplaceChild ¶ 

func (p *LoadData) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*LoadData) ReplaceParent ¶ 

func (p *LoadData) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*LoadData) ResolveIndices ¶ 

func (p *LoadData) ResolveIndices()

ResolveIndices implements Plan interface.

func (*LoadData) Schema ¶ 

func (p *LoadData) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*LoadData) SetChildren ¶ 

func (p *LoadData) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*LoadData) SetParents ¶ 

func (p *LoadData) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*LoadData) SetSchema ¶ 

func (p *LoadData) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type LogicalAggregation ¶ 

type LogicalAggregation struct {
	AggFuncs     []expression.AggregationFunction
	GroupByItems []expression.Expression
	// contains filtered or unexported fields
}

LogicalAggregation represents an aggregate plan.

func (LogicalAggregation) AddChild ¶ 

func (p LogicalAggregation) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (LogicalAggregation) AddParent ¶ 

func (p LogicalAggregation) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (LogicalAggregation) Allocator ¶ 

func (p LogicalAggregation) Allocator() *idAllocator

func (LogicalAggregation) Children ¶ 

func (p LogicalAggregation) Children() []Plan

Children implements Plan Children interface.

func (LogicalAggregation) ID ¶ 

func (p LogicalAggregation) ID() string

ID implements Plan ID interface.

func (LogicalAggregation) MarshalJSON ¶ 

func (p LogicalAggregation) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (LogicalAggregation) Parents ¶ 

func (p LogicalAggregation) Parents() []Plan

Parents implements Plan Parents interface.

func (*LogicalAggregation) PredicatePushDown ¶ 

func (p *LogicalAggregation) PredicatePushDown(predicates []expression.Expression) (ret []expression.Expression, retPlan LogicalPlan, err error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*LogicalAggregation) PruneColumns ¶ 

func (p *LogicalAggregation) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (LogicalAggregation) ReplaceChild ¶ 

func (p LogicalAggregation) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (LogicalAggregation) ReplaceParent ¶ 

func (p LogicalAggregation) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*LogicalAggregation) ResolveIndices ¶ 

func (p *LogicalAggregation) ResolveIndices()

ResolveIndices implements Plan interface.

func (LogicalAggregation) Schema ¶ 

func (p LogicalAggregation) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (LogicalAggregation) SetChildren ¶ 

func (p LogicalAggregation) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (LogicalAggregation) SetParents ¶ 

func (p LogicalAggregation) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (LogicalAggregation) SetSchema ¶ 

func (p LogicalAggregation) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type LogicalApply ¶ 

type LogicalApply struct {
	LogicalJoin
	// contains filtered or unexported fields
}

LogicalApply gets one row from outer executor and gets one row from inner executor according to outer row.

func (LogicalApply) AddChild ¶ 

func (p LogicalApply) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (LogicalApply) AddParent ¶ 

func (p LogicalApply) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (LogicalApply) Allocator ¶ 

func (p LogicalApply) Allocator() *idAllocator

func (LogicalApply) Children ¶ 

func (p LogicalApply) Children() []Plan

Children implements Plan Children interface.

func (LogicalApply) ID ¶ 

func (p LogicalApply) ID() string

ID implements Plan ID interface.

func (LogicalApply) MarshalJSON ¶ 

func (p LogicalApply) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (LogicalApply) Parents ¶ 

func (p LogicalApply) Parents() []Plan

Parents implements Plan Parents interface.

func (*LogicalApply) PruneColumns ¶ 

func (p *LogicalApply) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (LogicalApply) ReplaceChild ¶ 

func (p LogicalApply) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (LogicalApply) ReplaceParent ¶ 

func (p LogicalApply) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*LogicalApply) ResolveIndices ¶ 

func (p *LogicalApply) ResolveIndices()

ResolveIndices implements Plan interface.

func (LogicalApply) Schema ¶ 

func (p LogicalApply) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (LogicalApply) SetChildren ¶ 

func (p LogicalApply) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (LogicalApply) SetParents ¶ 

func (p LogicalApply) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (LogicalApply) SetSchema ¶ 

func (p LogicalApply) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type LogicalJoin ¶ 

type LogicalJoin struct {
	JoinType JoinType

	EqualConditions []*expression.ScalarFunction
	LeftConditions  expression.CNFExprs
	RightConditions expression.CNFExprs
	OtherConditions expression.CNFExprs

	// DefaultValues is only used for outer join, which stands for the default values when the outer table cannot find join partner
	// instead of null padding.
	DefaultValues []types.Datum
	// contains filtered or unexported fields
}

LogicalJoin is the logical join plan.

func (LogicalJoin) AddChild ¶ 

func (p LogicalJoin) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (LogicalJoin) AddParent ¶ 

func (p LogicalJoin) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (LogicalJoin) Allocator ¶ 

func (p LogicalJoin) Allocator() *idAllocator

func (LogicalJoin) Children ¶ 

func (p LogicalJoin) Children() []Plan

Children implements Plan Children interface.

func (LogicalJoin) ID ¶ 

func (p LogicalJoin) ID() string

ID implements Plan ID interface.

func (LogicalJoin) MarshalJSON ¶ 

func (p LogicalJoin) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (LogicalJoin) Parents ¶ 

func (p LogicalJoin) Parents() []Plan

Parents implements Plan Parents interface.

func (*LogicalJoin) PredicatePushDown ¶ 

func (p *LogicalJoin) PredicatePushDown(predicates []expression.Expression) (ret []expression.Expression, retPlan LogicalPlan, err error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*LogicalJoin) PruneColumns ¶ 

func (p *LogicalJoin) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (LogicalJoin) ReplaceChild ¶ 

func (p LogicalJoin) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (LogicalJoin) ReplaceParent ¶ 

func (p LogicalJoin) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*LogicalJoin) ResolveIndices ¶ 

func (p *LogicalJoin) ResolveIndices()

ResolveIndices implements Plan interface.

func (LogicalJoin) Schema ¶ 

func (p LogicalJoin) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (LogicalJoin) SetChildren ¶ 

func (p LogicalJoin) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (LogicalJoin) SetParents ¶ 

func (p LogicalJoin) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (LogicalJoin) SetSchema ¶ 

func (p LogicalJoin) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type LogicalPlan ¶ 

type LogicalPlan interface {
	Plan

	// PredicatePushDown pushes down the predicates in the where/on/having clauses as deeply as possible.
	// It will accept a predicate that is an expression slice, and return the expressions that can't be pushed.
	// Because it might change the root if the having clause exists, we need to return a plan that represents a new root.
	PredicatePushDown([]expression.Expression) ([]expression.Expression, LogicalPlan, error)

	// PruneColumns prunes the unused columns.
	PruneColumns([]*expression.Column)
	// contains filtered or unexported methods
}

LogicalPlan is a tree of logical operators. We can do a lot of logical optimizations to it, like predicate pushdown and column pruning.

type MaxOneRow ¶ 

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

MaxOneRow checks if a query returns no more than one row.

func (MaxOneRow) AddChild ¶ 

func (p MaxOneRow) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (MaxOneRow) AddParent ¶ 

func (p MaxOneRow) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (MaxOneRow) Allocator ¶ 

func (p MaxOneRow) Allocator() *idAllocator

func (MaxOneRow) Children ¶ 

func (p MaxOneRow) Children() []Plan

Children implements Plan Children interface.

func (*MaxOneRow) Copy ¶ 

func (p *MaxOneRow) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (MaxOneRow) ID ¶ 

func (p MaxOneRow) ID() string

ID implements Plan ID interface.

func (MaxOneRow) MarshalJSON ¶ 

func (p MaxOneRow) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (MaxOneRow) Parents ¶ 

func (p MaxOneRow) Parents() []Plan

Parents implements Plan Parents interface.

func (*MaxOneRow) PredicatePushDown ¶ 

func (p *MaxOneRow) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*MaxOneRow) PruneColumns ¶ 

func (p *MaxOneRow) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (MaxOneRow) ReplaceChild ¶ 

func (p MaxOneRow) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (MaxOneRow) ReplaceParent ¶ 

func (p MaxOneRow) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (MaxOneRow) ResolveIndices ¶ 

func (p MaxOneRow) ResolveIndices()

ResolveIndices implements Plan interface.

func (MaxOneRow) Schema ¶ 

func (p MaxOneRow) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (MaxOneRow) SetChildren ¶ 

func (p MaxOneRow) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (MaxOneRow) SetParents ¶ 

func (p MaxOneRow) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (MaxOneRow) SetSchema ¶ 

func (p MaxOneRow) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*MaxOneRow) ToPB ¶ 

func (p *MaxOneRow) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalAggregation ¶ 

type PhysicalAggregation struct {
	HasGby       bool
	AggType      AggregationType
	AggFuncs     []expression.AggregationFunction
	GroupByItems []expression.Expression
	// contains filtered or unexported fields
}

PhysicalAggregation is Aggregation's physical plan.

func (PhysicalAggregation) AddChild ¶ 

func (p PhysicalAggregation) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalAggregation) AddParent ¶ 

func (p PhysicalAggregation) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalAggregation) Allocator ¶ 

func (p PhysicalAggregation) Allocator() *idAllocator

func (PhysicalAggregation) Children ¶ 

func (p PhysicalAggregation) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalAggregation) Copy ¶ 

func (p *PhysicalAggregation) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalAggregation) ID ¶ 

func (p PhysicalAggregation) ID() string

ID implements Plan ID interface.

func (*PhysicalAggregation) MarshalJSON ¶ 

func (p *PhysicalAggregation) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalAggregation) Parents ¶ 

func (p PhysicalAggregation) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalAggregation) ReplaceChild ¶ 

func (p PhysicalAggregation) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalAggregation) ReplaceParent ¶ 

func (p PhysicalAggregation) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalAggregation) ResolveIndices ¶ 

func (p *PhysicalAggregation) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalAggregation) Schema ¶ 

func (p PhysicalAggregation) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalAggregation) SetChildren ¶ 

func (p PhysicalAggregation) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalAggregation) SetParents ¶ 

func (p PhysicalAggregation) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalAggregation) SetSchema ¶ 

func (p PhysicalAggregation) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalAggregation) ToPB ¶ 

func (p *PhysicalAggregation) ToPB(ctx context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalApply ¶ 

type PhysicalApply struct {
	PhysicalJoin PhysicalPlan
	OuterSchema  []*expression.CorrelatedColumn
	// contains filtered or unexported fields
}

PhysicalApply represents apply plan, only used for subquery.

func (PhysicalApply) AddChild ¶ 

func (p PhysicalApply) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalApply) AddParent ¶ 

func (p PhysicalApply) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalApply) Allocator ¶ 

func (p PhysicalApply) Allocator() *idAllocator

func (PhysicalApply) Children ¶ 

func (p PhysicalApply) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalApply) Copy ¶ 

func (p *PhysicalApply) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalApply) ID ¶ 

func (p PhysicalApply) ID() string

ID implements Plan ID interface.

func (*PhysicalApply) MarshalJSON ¶ 

func (p *PhysicalApply) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalApply) Parents ¶ 

func (p PhysicalApply) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalApply) ReplaceChild ¶ 

func (p PhysicalApply) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalApply) ReplaceParent ¶ 

func (p PhysicalApply) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalApply) ResolveIndices ¶ 

func (p *PhysicalApply) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalApply) Schema ¶ 

func (p PhysicalApply) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalApply) SetChildren ¶ 

func (p PhysicalApply) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalApply) SetParents ¶ 

func (p PhysicalApply) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalApply) SetSchema ¶ 

func (p PhysicalApply) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalApply) ToPB ¶ 

func (p *PhysicalApply) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalHashJoin ¶ 

type PhysicalHashJoin struct {
	JoinType JoinType

	EqualConditions []*expression.ScalarFunction
	LeftConditions  []expression.Expression
	RightConditions []expression.Expression
	OtherConditions []expression.Expression
	SmallTable      int
	Concurrency     int

	DefaultValues []types.Datum
	// contains filtered or unexported fields
}

PhysicalHashJoin represents hash join for inner/ outer join.

func (PhysicalHashJoin) AddChild ¶ 

func (p PhysicalHashJoin) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalHashJoin) AddParent ¶ 

func (p PhysicalHashJoin) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalHashJoin) Allocator ¶ 

func (p PhysicalHashJoin) Allocator() *idAllocator

func (PhysicalHashJoin) Children ¶ 

func (p PhysicalHashJoin) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalHashJoin) Copy ¶ 

func (p *PhysicalHashJoin) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalHashJoin) ID ¶ 

func (p PhysicalHashJoin) ID() string

ID implements Plan ID interface.

func (*PhysicalHashJoin) MarshalJSON ¶ 

func (p *PhysicalHashJoin) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalHashJoin) Parents ¶ 

func (p PhysicalHashJoin) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalHashJoin) ReplaceChild ¶ 

func (p PhysicalHashJoin) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalHashJoin) ReplaceParent ¶ 

func (p PhysicalHashJoin) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalHashJoin) ResolveIndices ¶ 

func (p *PhysicalHashJoin) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalHashJoin) Schema ¶ 

func (p PhysicalHashJoin) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalHashJoin) SetChildren ¶ 

func (p PhysicalHashJoin) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalHashJoin) SetParents ¶ 

func (p PhysicalHashJoin) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalHashJoin) SetSchema ¶ 

func (p PhysicalHashJoin) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalHashJoin) ToPB ¶ 

func (p *PhysicalHashJoin) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalHashSemiJoin ¶ 

type PhysicalHashSemiJoin struct {
	WithAux bool
	Anti    bool

	EqualConditions []*expression.ScalarFunction
	LeftConditions  []expression.Expression
	RightConditions []expression.Expression
	OtherConditions []expression.Expression
	// contains filtered or unexported fields
}

PhysicalHashSemiJoin represents hash join for semi join.

func (PhysicalHashSemiJoin) AddChild ¶ 

func (p PhysicalHashSemiJoin) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalHashSemiJoin) AddParent ¶ 

func (p PhysicalHashSemiJoin) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalHashSemiJoin) Allocator ¶ 

func (p PhysicalHashSemiJoin) Allocator() *idAllocator

func (PhysicalHashSemiJoin) Children ¶ 

func (p PhysicalHashSemiJoin) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalHashSemiJoin) Copy ¶ 

func (p *PhysicalHashSemiJoin) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalHashSemiJoin) ID ¶ 

func (p PhysicalHashSemiJoin) ID() string

ID implements Plan ID interface.

func (*PhysicalHashSemiJoin) MarshalJSON ¶ 

func (p *PhysicalHashSemiJoin) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalHashSemiJoin) Parents ¶ 

func (p PhysicalHashSemiJoin) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalHashSemiJoin) ReplaceChild ¶ 

func (p PhysicalHashSemiJoin) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalHashSemiJoin) ReplaceParent ¶ 

func (p PhysicalHashSemiJoin) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalHashSemiJoin) ResolveIndices ¶ 

func (p *PhysicalHashSemiJoin) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalHashSemiJoin) Schema ¶ 

func (p PhysicalHashSemiJoin) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalHashSemiJoin) SetChildren ¶ 

func (p PhysicalHashSemiJoin) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalHashSemiJoin) SetParents ¶ 

func (p PhysicalHashSemiJoin) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalHashSemiJoin) SetSchema ¶ 

func (p PhysicalHashSemiJoin) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalHashSemiJoin) ToPB ¶ 

func (p *PhysicalHashSemiJoin) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalIndexJoin ¶ 

type PhysicalIndexJoin struct {
	Outer           bool
	OuterJoinKeys   []*expression.Column
	InnerJoinKeys   []*expression.Column
	LeftConditions  expression.CNFExprs
	RightConditions expression.CNFExprs
	OtherConditions expression.CNFExprs

	DefaultValues []types.Datum
	// contains filtered or unexported fields
}

PhysicalIndexJoin represents the plan of index look up join.

func (PhysicalIndexJoin) AddChild ¶ 

func (p PhysicalIndexJoin) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalIndexJoin) AddParent ¶ 

func (p PhysicalIndexJoin) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalIndexJoin) Allocator ¶ 

func (p PhysicalIndexJoin) Allocator() *idAllocator

func (PhysicalIndexJoin) Children ¶ 

func (p PhysicalIndexJoin) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalIndexJoin) Copy ¶ 

func (p *PhysicalIndexJoin) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalIndexJoin) ID ¶ 

func (p PhysicalIndexJoin) ID() string

ID implements Plan ID interface.

func (PhysicalIndexJoin) MarshalJSON ¶ 

func (p PhysicalIndexJoin) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalIndexJoin) Parents ¶ 

func (p PhysicalIndexJoin) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalIndexJoin) ReplaceChild ¶ 

func (p PhysicalIndexJoin) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalIndexJoin) ReplaceParent ¶ 

func (p PhysicalIndexJoin) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalIndexJoin) ResolveIndices ¶ 

func (p *PhysicalIndexJoin) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalIndexJoin) Schema ¶ 

func (p PhysicalIndexJoin) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalIndexJoin) SetChildren ¶ 

func (p PhysicalIndexJoin) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalIndexJoin) SetParents ¶ 

func (p PhysicalIndexJoin) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalIndexJoin) SetSchema ¶ 

func (p PhysicalIndexJoin) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalIndexJoin) ToPB ¶ 

func (p *PhysicalIndexJoin) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalIndexLookUpReader ¶ 

type PhysicalIndexLookUpReader struct {

	// IndexPlans flats the indexPlan to construct executor pb.
	IndexPlans []PhysicalPlan
	// TablePlans flats the tablePlan to construct executor pb.
	TablePlans []PhysicalPlan
	// contains filtered or unexported fields
}

PhysicalIndexLookUpReader is the index look up reader in tidb. It's used in case of double reading.

func (PhysicalIndexLookUpReader) AddChild ¶ 

func (p PhysicalIndexLookUpReader) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalIndexLookUpReader) AddParent ¶ 

func (p PhysicalIndexLookUpReader) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalIndexLookUpReader) Allocator ¶ 

func (p PhysicalIndexLookUpReader) Allocator() *idAllocator

func (PhysicalIndexLookUpReader) Children ¶ 

func (p PhysicalIndexLookUpReader) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalIndexLookUpReader) Copy ¶ 

func (p *PhysicalIndexLookUpReader) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalIndexLookUpReader) ID ¶ 

func (p PhysicalIndexLookUpReader) ID() string

ID implements Plan ID interface.

func (PhysicalIndexLookUpReader) MarshalJSON ¶ 

func (p PhysicalIndexLookUpReader) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalIndexLookUpReader) Parents ¶ 

func (p PhysicalIndexLookUpReader) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalIndexLookUpReader) ReplaceChild ¶ 

func (p PhysicalIndexLookUpReader) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalIndexLookUpReader) ReplaceParent ¶ 

func (p PhysicalIndexLookUpReader) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalIndexLookUpReader) ResolveIndices ¶ 

func (p *PhysicalIndexLookUpReader) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalIndexLookUpReader) Schema ¶ 

func (p PhysicalIndexLookUpReader) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalIndexLookUpReader) SetChildren ¶ 

func (p PhysicalIndexLookUpReader) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalIndexLookUpReader) SetParents ¶ 

func (p PhysicalIndexLookUpReader) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalIndexLookUpReader) SetSchema ¶ 

func (p PhysicalIndexLookUpReader) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalIndexLookUpReader) ToPB ¶ 

func (p *PhysicalIndexLookUpReader) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalIndexReader ¶ 

type PhysicalIndexReader struct {

	// IndexPlans flats the indexPlan to construct executor pb.
	IndexPlans []PhysicalPlan

	// OutputColumns represents the columns that index reader should return.
	OutputColumns []*expression.Column
	// contains filtered or unexported fields
}

PhysicalIndexReader is the index reader in tidb.

func (PhysicalIndexReader) AddChild ¶ 

func (p PhysicalIndexReader) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalIndexReader) AddParent ¶ 

func (p PhysicalIndexReader) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalIndexReader) Allocator ¶ 

func (p PhysicalIndexReader) Allocator() *idAllocator

func (PhysicalIndexReader) Children ¶ 

func (p PhysicalIndexReader) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalIndexReader) Copy ¶ 

func (p *PhysicalIndexReader) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalIndexReader) ID ¶ 

func (p PhysicalIndexReader) ID() string

ID implements Plan ID interface.

func (PhysicalIndexReader) MarshalJSON ¶ 

func (p PhysicalIndexReader) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalIndexReader) Parents ¶ 

func (p PhysicalIndexReader) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalIndexReader) ReplaceChild ¶ 

func (p PhysicalIndexReader) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalIndexReader) ReplaceParent ¶ 

func (p PhysicalIndexReader) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalIndexReader) ResolveIndices ¶ 

func (p *PhysicalIndexReader) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalIndexReader) Schema ¶ 

func (p PhysicalIndexReader) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalIndexReader) SetChildren ¶ 

func (p PhysicalIndexReader) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalIndexReader) SetParents ¶ 

func (p PhysicalIndexReader) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalIndexReader) SetSchema ¶ 

func (p PhysicalIndexReader) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalIndexReader) ToPB ¶ 

func (p *PhysicalIndexReader) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalIndexScan ¶ 

type PhysicalIndexScan struct {
	Table      *model.TableInfo
	Index      *model.IndexInfo
	Ranges     []*types.IndexRange
	Columns    []*model.ColumnInfo
	DBName     model.CIStr
	Desc       bool
	OutOfOrder bool
	// DoubleRead means if the index executor will read kv two times.
	// If the query requires the columns that don't belong to index, DoubleRead will be true.
	DoubleRead bool

	TableAsName *model.CIStr
	// contains filtered or unexported fields
}

PhysicalIndexScan represents an index scan plan.

func (*PhysicalIndexScan) Copy ¶ 

func (p *PhysicalIndexScan) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (*PhysicalIndexScan) IsPointGetByUniqueKey ¶ 

func (p *PhysicalIndexScan) IsPointGetByUniqueKey(sc *variable.StatementContext) bool

IsPointGetByUniqueKey checks whether is a point get by unique key.

func (*PhysicalIndexScan) MarshalJSON ¶ 

func (p *PhysicalIndexScan) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*PhysicalIndexScan) ToPB ¶ 

func (p *PhysicalIndexScan) ToPB(ctx context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalMemTable ¶ 

type PhysicalMemTable struct {
	DBName      model.CIStr
	Table       *model.TableInfo
	Columns     []*model.ColumnInfo
	Ranges      []types.IntColumnRange
	TableAsName *model.CIStr
	// contains filtered or unexported fields
}

PhysicalMemTable reads memory table.

func (PhysicalMemTable) AddChild ¶ 

func (p PhysicalMemTable) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalMemTable) AddParent ¶ 

func (p PhysicalMemTable) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalMemTable) Allocator ¶ 

func (p PhysicalMemTable) Allocator() *idAllocator

func (PhysicalMemTable) Children ¶ 

func (p PhysicalMemTable) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalMemTable) Copy ¶ 

func (p *PhysicalMemTable) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalMemTable) ID ¶ 

func (p PhysicalMemTable) ID() string

ID implements Plan ID interface.

func (*PhysicalMemTable) MarshalJSON ¶ 

func (p *PhysicalMemTable) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalMemTable) Parents ¶ 

func (p PhysicalMemTable) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalMemTable) ReplaceChild ¶ 

func (p PhysicalMemTable) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalMemTable) ReplaceParent ¶ 

func (p PhysicalMemTable) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (PhysicalMemTable) ResolveIndices ¶ 

func (p PhysicalMemTable) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalMemTable) Schema ¶ 

func (p PhysicalMemTable) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalMemTable) SetChildren ¶ 

func (p PhysicalMemTable) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalMemTable) SetParents ¶ 

func (p PhysicalMemTable) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalMemTable) SetSchema ¶ 

func (p PhysicalMemTable) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalMemTable) ToPB ¶ 

func (p *PhysicalMemTable) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalMergeJoin ¶ 

type PhysicalMergeJoin struct {
	JoinType JoinType

	EqualConditions []*expression.ScalarFunction
	LeftConditions  []expression.Expression
	RightConditions []expression.Expression
	OtherConditions []expression.Expression

	DefaultValues []types.Datum
	Desc          bool
	// contains filtered or unexported fields
}

PhysicalMergeJoin represents merge join for inner/ outer join.

func (PhysicalMergeJoin) AddChild ¶ 

func (p PhysicalMergeJoin) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalMergeJoin) AddParent ¶ 

func (p PhysicalMergeJoin) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalMergeJoin) Allocator ¶ 

func (p PhysicalMergeJoin) Allocator() *idAllocator

func (PhysicalMergeJoin) Children ¶ 

func (p PhysicalMergeJoin) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalMergeJoin) Copy ¶ 

func (p *PhysicalMergeJoin) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalMergeJoin) ID ¶ 

func (p PhysicalMergeJoin) ID() string

ID implements Plan ID interface.

func (*PhysicalMergeJoin) MarshalJSON ¶ 

func (p *PhysicalMergeJoin) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalMergeJoin) Parents ¶ 

func (p PhysicalMergeJoin) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalMergeJoin) ReplaceChild ¶ 

func (p PhysicalMergeJoin) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalMergeJoin) ReplaceParent ¶ 

func (p PhysicalMergeJoin) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalMergeJoin) ResolveIndices ¶ 

func (p *PhysicalMergeJoin) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalMergeJoin) Schema ¶ 

func (p PhysicalMergeJoin) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalMergeJoin) SetChildren ¶ 

func (p PhysicalMergeJoin) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalMergeJoin) SetParents ¶ 

func (p PhysicalMergeJoin) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalMergeJoin) SetSchema ¶ 

func (p PhysicalMergeJoin) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalMergeJoin) ToPB ¶ 

func (p *PhysicalMergeJoin) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalPlan ¶ 

type PhysicalPlan interface {
	json.Marshaler
	Plan

	// Copy copies the current plan.
	Copy() PhysicalPlan

	// ToPB converts physical plan to tipb executor.
	ToPB(ctx context.Context) (*tipb.Executor, error)
	// contains filtered or unexported methods
}

PhysicalPlan is a tree of the physical operators.

func EliminateProjection ¶ 

func EliminateProjection(p PhysicalPlan) PhysicalPlan

EliminateProjection eliminates projection operator to avoid the cost of memory copy in the iterator of projection.

type PhysicalTableReader ¶ 

type PhysicalTableReader struct {

	// TablePlans flats the tablePlan to construct executor pb.
	TablePlans []PhysicalPlan
	// contains filtered or unexported fields
}

PhysicalTableReader is the table reader in tidb.

func (PhysicalTableReader) AddChild ¶ 

func (p PhysicalTableReader) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalTableReader) AddParent ¶ 

func (p PhysicalTableReader) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalTableReader) Allocator ¶ 

func (p PhysicalTableReader) Allocator() *idAllocator

func (PhysicalTableReader) Children ¶ 

func (p PhysicalTableReader) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalTableReader) Copy ¶ 

func (p *PhysicalTableReader) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalTableReader) ID ¶ 

func (p PhysicalTableReader) ID() string

ID implements Plan ID interface.

func (PhysicalTableReader) MarshalJSON ¶ 

func (p PhysicalTableReader) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalTableReader) Parents ¶ 

func (p PhysicalTableReader) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalTableReader) ReplaceChild ¶ 

func (p PhysicalTableReader) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalTableReader) ReplaceParent ¶ 

func (p PhysicalTableReader) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalTableReader) ResolveIndices ¶ 

func (p *PhysicalTableReader) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalTableReader) Schema ¶ 

func (p PhysicalTableReader) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalTableReader) SetChildren ¶ 

func (p PhysicalTableReader) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalTableReader) SetParents ¶ 

func (p PhysicalTableReader) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalTableReader) SetSchema ¶ 

func (p PhysicalTableReader) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalTableReader) ToPB ¶ 

func (p *PhysicalTableReader) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalTableScan ¶ 

type PhysicalTableScan struct {
	Table   *model.TableInfo
	Columns []*model.ColumnInfo
	DBName  model.CIStr
	Desc    bool
	Ranges  []types.IntColumnRange

	TableAsName *model.CIStr

	// KeepOrder is true, if sort data by scanning pkcol,
	KeepOrder bool
	// contains filtered or unexported fields
}

PhysicalTableScan represents a table scan plan.

func (*PhysicalTableScan) Copy ¶ 

func (p *PhysicalTableScan) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (*PhysicalTableScan) MarshalJSON ¶ 

func (p *PhysicalTableScan) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*PhysicalTableScan) ToPB ¶ 

func (p *PhysicalTableScan) ToPB(ctx context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type PhysicalUnionScan ¶ 

type PhysicalUnionScan struct {
	Conditions []expression.Expression
	// contains filtered or unexported fields
}

PhysicalUnionScan represents a union scan operator.

func (PhysicalUnionScan) AddChild ¶ 

func (p PhysicalUnionScan) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (PhysicalUnionScan) AddParent ¶ 

func (p PhysicalUnionScan) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (PhysicalUnionScan) Allocator ¶ 

func (p PhysicalUnionScan) Allocator() *idAllocator

func (PhysicalUnionScan) Children ¶ 

func (p PhysicalUnionScan) Children() []Plan

Children implements Plan Children interface.

func (*PhysicalUnionScan) Copy ¶ 

func (p *PhysicalUnionScan) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (PhysicalUnionScan) ID ¶ 

func (p PhysicalUnionScan) ID() string

ID implements Plan ID interface.

func (PhysicalUnionScan) MarshalJSON ¶ 

func (p PhysicalUnionScan) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (PhysicalUnionScan) Parents ¶ 

func (p PhysicalUnionScan) Parents() []Plan

Parents implements Plan Parents interface.

func (PhysicalUnionScan) ReplaceChild ¶ 

func (p PhysicalUnionScan) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (PhysicalUnionScan) ReplaceParent ¶ 

func (p PhysicalUnionScan) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*PhysicalUnionScan) ResolveIndices ¶ 

func (p *PhysicalUnionScan) ResolveIndices()

ResolveIndices implements Plan interface.

func (PhysicalUnionScan) Schema ¶ 

func (p PhysicalUnionScan) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (PhysicalUnionScan) SetChildren ¶ 

func (p PhysicalUnionScan) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (PhysicalUnionScan) SetParents ¶ 

func (p PhysicalUnionScan) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (PhysicalUnionScan) SetSchema ¶ 

func (p PhysicalUnionScan) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*PhysicalUnionScan) ToPB ¶ 

func (p *PhysicalUnionScan) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Plan ¶ 

type Plan interface {
	// AddParent means appending a parent for plan.
	AddParent(parent Plan)
	// AddChild means appending a child for plan.
	AddChild(children Plan)
	// ReplaceParent means replacing a parent with another one.
	ReplaceParent(parent, newPar Plan) error
	// ReplaceChild means replacing a child with another one.
	ReplaceChild(children, newChild Plan) error
	// Get all the parents.
	Parents() []Plan
	// Get all the children.
	Children() []Plan
	// Set the schema.
	SetSchema(schema *expression.Schema)
	// Get the schema.
	Schema() *expression.Schema
	// Get the ID.
	ID() string
	// Get id allocator
	Allocator() *idAllocator
	// SetParents sets the parents for the plan.
	SetParents(...Plan)
	// SetChildren sets the children for the plan.
	SetChildren(...Plan)

	// ResolveIndices resolves the indices for columns. After doing this, the columns can evaluate the rows by their indices.
	ResolveIndices()
	// contains filtered or unexported methods
}

Plan is the description of an execution flow. It is created from ast.Node first, then optimized by the optimizer, finally used by the executor to create a Cursor which executes the statement.

func BuildLogicalPlan ¶ 

func BuildLogicalPlan(ctx context.Context, node ast.Node, is infoschema.InfoSchema) (Plan, error)

BuildLogicalPlan is exported and only used for test.

func Optimize ¶ 

func Optimize(ctx context.Context, node ast.Node, is infoschema.InfoSchema) (Plan, error)

Optimize does optimization and creates a Plan. The node must be prepared first.

type Prepare ¶ 

type Prepare struct {
	Name    string
	SQLText string
	// contains filtered or unexported fields
}

Prepare represents prepare plan.

func (*Prepare) AddChild ¶ 

func (p *Prepare) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Prepare) AddParent ¶ 

func (p *Prepare) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Prepare) Allocator ¶ 

func (p *Prepare) Allocator() *idAllocator

func (*Prepare) Children ¶ 

func (p *Prepare) Children() []Plan

Children implements Plan Children interface.

func (*Prepare) ID ¶ 

func (p *Prepare) ID() string

ID implements Plan ID interface.

func (*Prepare) MarshalJSON ¶ 

func (p *Prepare) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Prepare) Parents ¶ 

func (p *Prepare) Parents() []Plan

Parents implements Plan Parents interface.

func (*Prepare) ReplaceChild ¶ 

func (p *Prepare) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Prepare) ReplaceParent ¶ 

func (p *Prepare) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Prepare) ResolveIndices ¶ 

func (p *Prepare) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Prepare) Schema ¶ 

func (p *Prepare) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Prepare) SetChildren ¶ 

func (p *Prepare) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Prepare) SetParents ¶ 

func (p *Prepare) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Prepare) SetSchema ¶ 

func (p *Prepare) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Projection ¶ 

type Projection struct {
	Exprs []expression.Expression
	// contains filtered or unexported fields
}

Projection represents a select fields plan.

func (Projection) AddChild ¶ 

func (p Projection) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Projection) AddParent ¶ 

func (p Projection) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Projection) Allocator ¶ 

func (p Projection) Allocator() *idAllocator

func (Projection) Children ¶ 

func (p Projection) Children() []Plan

Children implements Plan Children interface.

func (*Projection) Copy ¶ 

func (p *Projection) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Projection) ID ¶ 

func (p Projection) ID() string

ID implements Plan ID interface.

func (*Projection) MarshalJSON ¶ 

func (p *Projection) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Projection) Parents ¶ 

func (p Projection) Parents() []Plan

Parents implements Plan Parents interface.

func (*Projection) PredicatePushDown ¶ 

func (p *Projection) PredicatePushDown(predicates []expression.Expression) (ret []expression.Expression, retPlan LogicalPlan, err error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*Projection) PruneColumns ¶ 

func (p *Projection) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Projection) ReplaceChild ¶ 

func (p Projection) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Projection) ReplaceParent ¶ 

func (p Projection) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Projection) ResolveIndices ¶ 

func (p *Projection) ResolveIndices()

ResolveIndices implements Plan interface.

func (Projection) Schema ¶ 

func (p Projection) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Projection) SetChildren ¶ 

func (p Projection) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Projection) SetParents ¶ 

func (p Projection) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Projection) SetSchema ¶ 

func (p Projection) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Projection) ToPB ¶ 

func (p *Projection) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type SelectLock ¶ 

type SelectLock struct {
	Lock ast.SelectLockType
	// contains filtered or unexported fields
}

SelectLock represents a select lock plan.

func (SelectLock) AddChild ¶ 

func (p SelectLock) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (SelectLock) AddParent ¶ 

func (p SelectLock) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (SelectLock) Allocator ¶ 

func (p SelectLock) Allocator() *idAllocator

func (SelectLock) Children ¶ 

func (p SelectLock) Children() []Plan

Children implements Plan Children interface.

func (*SelectLock) Copy ¶ 

func (p *SelectLock) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (SelectLock) ID ¶ 

func (p SelectLock) ID() string

ID implements Plan ID interface.

func (SelectLock) MarshalJSON ¶ 

func (p SelectLock) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (SelectLock) Parents ¶ 

func (p SelectLock) Parents() []Plan

Parents implements Plan Parents interface.

func (*SelectLock) PredicatePushDown ¶ 

func (p *SelectLock) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*SelectLock) PruneColumns ¶ 

func (p *SelectLock) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (SelectLock) ReplaceChild ¶ 

func (p SelectLock) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (SelectLock) ReplaceParent ¶ 

func (p SelectLock) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (SelectLock) ResolveIndices ¶ 

func (p SelectLock) ResolveIndices()

ResolveIndices implements Plan interface.

func (SelectLock) Schema ¶ 

func (p SelectLock) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (SelectLock) SetChildren ¶ 

func (p SelectLock) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (SelectLock) SetParents ¶ 

func (p SelectLock) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (SelectLock) SetSchema ¶ 

func (p SelectLock) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*SelectLock) ToPB ¶ 

func (p *SelectLock) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Selection ¶ 

type Selection struct {

	// Originally the WHERE or ON condition is parsed into a single expression,
	// but after we converted to CNF(Conjunctive normal form), it can be
	// split into a list of AND conditions.
	Conditions []expression.Expression

	// If ScanController is true, then the child of this selection is a scan,
	// which use pk or index. we will record the accessConditions, idxConditions,
	// and tblConditions to control the below plan.
	ScanController bool
	// contains filtered or unexported fields
}

Selection means a filter.

func (Selection) AddChild ¶ 

func (p Selection) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Selection) AddParent ¶ 

func (p Selection) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Selection) Allocator ¶ 

func (p Selection) Allocator() *idAllocator

func (Selection) Children ¶ 

func (p Selection) Children() []Plan

Children implements Plan Children interface.

func (*Selection) Copy ¶ 

func (p *Selection) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Selection) ID ¶ 

func (p Selection) ID() string

ID implements Plan ID interface.

func (*Selection) MarshalJSON ¶ 

func (p *Selection) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Selection) Parents ¶ 

func (p Selection) Parents() []Plan

Parents implements Plan Parents interface.

func (*Selection) PredicatePushDown ¶ 

func (p *Selection) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*Selection) PruneColumns ¶ 

func (p *Selection) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Selection) ReplaceChild ¶ 

func (p Selection) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Selection) ReplaceParent ¶ 

func (p Selection) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Selection) ResolveIndices ¶ 

func (p *Selection) ResolveIndices()

ResolveIndices implements Plan interface.

func (Selection) Schema ¶ 

func (p Selection) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Selection) SetChildren ¶ 

func (p Selection) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Selection) SetParents ¶ 

func (p Selection) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Selection) SetSchema ¶ 

func (p Selection) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Selection) ToPB ¶ 

func (p *Selection) ToPB(ctx context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Set ¶ 

type Set struct {
	VarAssigns []*expression.VarAssignment
	// contains filtered or unexported fields
}

Set represents a plan for set stmt.

func (*Set) AddChild ¶ 

func (p *Set) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Set) AddParent ¶ 

func (p *Set) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Set) Allocator ¶ 

func (p *Set) Allocator() *idAllocator

func (*Set) Children ¶ 

func (p *Set) Children() []Plan

Children implements Plan Children interface.

func (*Set) ID ¶ 

func (p *Set) ID() string

ID implements Plan ID interface.

func (*Set) MarshalJSON ¶ 

func (p *Set) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Set) Parents ¶ 

func (p *Set) Parents() []Plan

Parents implements Plan Parents interface.

func (*Set) ReplaceChild ¶ 

func (p *Set) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Set) ReplaceParent ¶ 

func (p *Set) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Set) ResolveIndices ¶ 

func (p *Set) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Set) Schema ¶ 

func (p *Set) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Set) SetChildren ¶ 

func (p *Set) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Set) SetParents ¶ 

func (p *Set) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Set) SetSchema ¶ 

func (p *Set) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Show ¶ 

type Show struct {
	Tp     ast.ShowStmtType // Databases/Tables/Columns/....
	DBName string
	Table  *ast.TableName  // Used for showing columns.
	Column *ast.ColumnName // Used for `desc table column`.
	Flag   int             // Some flag parsed from sql, such as FULL.
	Full   bool
	User   string // Used for show grants.

	// Used by show variables
	GlobalScope bool
	// contains filtered or unexported fields
}

Show represents a show plan.

func (Show) AddChild ¶ 

func (p Show) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Show) AddParent ¶ 

func (p Show) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Show) Allocator ¶ 

func (p Show) Allocator() *idAllocator

func (Show) Children ¶ 

func (p Show) Children() []Plan

Children implements Plan Children interface.

func (*Show) Copy ¶ 

func (p *Show) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Show) ID ¶ 

func (p Show) ID() string

ID implements Plan ID interface.

func (Show) MarshalJSON ¶ 

func (p Show) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Show) Parents ¶ 

func (p Show) Parents() []Plan

Parents implements Plan Parents interface.

func (*Show) PredicatePushDown ¶ 

func (p *Show) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*Show) PruneColumns ¶ 

func (p *Show) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Show) ReplaceChild ¶ 

func (p Show) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Show) ReplaceParent ¶ 

func (p Show) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (Show) ResolveIndices ¶ 

func (p Show) ResolveIndices()

ResolveIndices implements Plan interface.

func (Show) Schema ¶ 

func (p Show) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Show) SetChildren ¶ 

func (p Show) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Show) SetParents ¶ 

func (p Show) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Show) SetSchema ¶ 

func (p Show) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Show) ToPB ¶ 

func (p *Show) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type ShowDDL ¶ 

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

ShowDDL is for showing DDL information.

func (*ShowDDL) AddChild ¶ 

func (p *ShowDDL) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*ShowDDL) AddParent ¶ 

func (p *ShowDDL) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*ShowDDL) Allocator ¶ 

func (p *ShowDDL) Allocator() *idAllocator

func (*ShowDDL) Children ¶ 

func (p *ShowDDL) Children() []Plan

Children implements Plan Children interface.

func (*ShowDDL) ID ¶ 

func (p *ShowDDL) ID() string

ID implements Plan ID interface.

func (*ShowDDL) MarshalJSON ¶ 

func (p *ShowDDL) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*ShowDDL) Parents ¶ 

func (p *ShowDDL) Parents() []Plan

Parents implements Plan Parents interface.

func (*ShowDDL) ReplaceChild ¶ 

func (p *ShowDDL) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*ShowDDL) ReplaceParent ¶ 

func (p *ShowDDL) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*ShowDDL) ResolveIndices ¶ 

func (p *ShowDDL) ResolveIndices()

ResolveIndices implements Plan interface.

func (*ShowDDL) Schema ¶ 

func (p *ShowDDL) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*ShowDDL) SetChildren ¶ 

func (p *ShowDDL) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*ShowDDL) SetParents ¶ 

func (p *ShowDDL) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*ShowDDL) SetSchema ¶ 

func (p *ShowDDL) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Simple ¶ 

type Simple struct {
	Statement ast.StmtNode
	// contains filtered or unexported fields
}

Simple represents a simple statement plan which doesn't need any optimization.

func (*Simple) AddChild ¶ 

func (p *Simple) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (*Simple) AddParent ¶ 

func (p *Simple) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (*Simple) Allocator ¶ 

func (p *Simple) Allocator() *idAllocator

func (*Simple) Children ¶ 

func (p *Simple) Children() []Plan

Children implements Plan Children interface.

func (*Simple) ID ¶ 

func (p *Simple) ID() string

ID implements Plan ID interface.

func (*Simple) MarshalJSON ¶ 

func (p *Simple) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (*Simple) Parents ¶ 

func (p *Simple) Parents() []Plan

Parents implements Plan Parents interface.

func (*Simple) ReplaceChild ¶ 

func (p *Simple) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (*Simple) ReplaceParent ¶ 

func (p *Simple) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Simple) ResolveIndices ¶ 

func (p *Simple) ResolveIndices()

ResolveIndices implements Plan interface.

func (*Simple) Schema ¶ 

func (p *Simple) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (*Simple) SetChildren ¶ 

func (p *Simple) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (*Simple) SetParents ¶ 

func (p *Simple) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (*Simple) SetSchema ¶ 

func (p *Simple) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

type Sort ¶ 

type Sort struct {
	ByItems   []*ByItems
	ExecLimit *Limit // no longer be used by new plan
	// contains filtered or unexported fields
}

Sort stands for the order by plan.

func (Sort) AddChild ¶ 

func (p Sort) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Sort) AddParent ¶ 

func (p Sort) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Sort) Allocator ¶ 

func (p Sort) Allocator() *idAllocator

func (Sort) Children ¶ 

func (p Sort) Children() []Plan

Children implements Plan Children interface.

func (*Sort) Copy ¶ 

func (p *Sort) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Sort) ID ¶ 

func (p Sort) ID() string

ID implements Plan ID interface.

func (*Sort) MarshalJSON ¶ 

func (p *Sort) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Sort) Parents ¶ 

func (p Sort) Parents() []Plan

Parents implements Plan Parents interface.

func (*Sort) PredicatePushDown ¶ 

func (p *Sort) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*Sort) PruneColumns ¶ 

func (p *Sort) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Sort) ReplaceChild ¶ 

func (p Sort) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Sort) ReplaceParent ¶ 

func (p Sort) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Sort) ResolveIndices ¶ 

func (p *Sort) ResolveIndices()

ResolveIndices implements Plan interface.

func (Sort) Schema ¶ 

func (p Sort) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Sort) SetChildren ¶ 

func (p Sort) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Sort) SetParents ¶ 

func (p Sort) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Sort) SetSchema ¶ 

func (p Sort) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Sort) ToPB ¶ 

func (p *Sort) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type TableDual ¶ 

type TableDual struct {
	RowCount int
	// contains filtered or unexported fields
}

TableDual represents a dual table plan.

func (TableDual) AddChild ¶ 

func (p TableDual) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (TableDual) AddParent ¶ 

func (p TableDual) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (TableDual) Allocator ¶ 

func (p TableDual) Allocator() *idAllocator

func (TableDual) Children ¶ 

func (p TableDual) Children() []Plan

Children implements Plan Children interface.

func (*TableDual) Copy ¶ 

func (p *TableDual) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (TableDual) ID ¶ 

func (p TableDual) ID() string

ID implements Plan ID interface.

func (TableDual) MarshalJSON ¶ 

func (p TableDual) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (TableDual) Parents ¶ 

func (p TableDual) Parents() []Plan

Parents implements Plan Parents interface.

func (*TableDual) PredicatePushDown ¶ 

func (p *TableDual) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*TableDual) PruneColumns ¶ 

func (p *TableDual) PruneColumns(_ []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (TableDual) ReplaceChild ¶ 

func (p TableDual) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (TableDual) ReplaceParent ¶ 

func (p TableDual) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (TableDual) ResolveIndices ¶ 

func (p TableDual) ResolveIndices()

ResolveIndices implements Plan interface.

func (TableDual) Schema ¶ 

func (p TableDual) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (TableDual) SetChildren ¶ 

func (p TableDual) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (TableDual) SetParents ¶ 

func (p TableDual) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (TableDual) SetSchema ¶ 

func (p TableDual) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*TableDual) ToPB ¶ 

func (p *TableDual) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type TopN ¶ 

type TopN struct {
	ByItems []*ByItems
	Offset  uint64
	Count   uint64
	// contains filtered or unexported fields
}

TopN represents a top-n plan.

func (TopN) AddChild ¶ 

func (p TopN) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (TopN) AddParent ¶ 

func (p TopN) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (TopN) Allocator ¶ 

func (p TopN) Allocator() *idAllocator

func (TopN) Children ¶ 

func (p TopN) Children() []Plan

Children implements Plan Children interface.

func (*TopN) Copy ¶ 

func (p *TopN) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (TopN) ID ¶ 

func (p TopN) ID() string

ID implements Plan ID interface.

func (TopN) MarshalJSON ¶ 

func (p TopN) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (TopN) Parents ¶ 

func (p TopN) Parents() []Plan

Parents implements Plan Parents interface.

func (*TopN) PredicatePushDown ¶ 

func (p *TopN) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*TopN) PruneColumns ¶ 

func (p *TopN) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (TopN) ReplaceChild ¶ 

func (p TopN) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (TopN) ReplaceParent ¶ 

func (p TopN) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*TopN) ResolveIndices ¶ 

func (p *TopN) ResolveIndices()

ResolveIndices implements Plan interface.

func (TopN) Schema ¶ 

func (p TopN) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (TopN) SetChildren ¶ 

func (p TopN) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (TopN) SetParents ¶ 

func (p TopN) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (TopN) SetSchema ¶ 

func (p TopN) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*TopN) ToPB ¶ 

func (p *TopN) ToPB(ctx context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Union ¶ 

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

Union represents Union plan.

func (Union) AddChild ¶ 

func (p Union) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Union) AddParent ¶ 

func (p Union) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Union) Allocator ¶ 

func (p Union) Allocator() *idAllocator

func (Union) Children ¶ 

func (p Union) Children() []Plan

Children implements Plan Children interface.

func (*Union) Copy ¶ 

func (p *Union) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Union) ID ¶ 

func (p Union) ID() string

ID implements Plan ID interface.

func (Union) MarshalJSON ¶ 

func (p Union) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Union) Parents ¶ 

func (p Union) Parents() []Plan

Parents implements Plan Parents interface.

func (*Union) PredicatePushDown ¶ 

func (p *Union) PredicatePushDown(predicates []expression.Expression) (ret []expression.Expression, retPlan LogicalPlan, err error)

PredicatePushDown implements LogicalPlan PredicatePushDown interface.

func (*Union) PruneColumns ¶ 

func (p *Union) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Union) ReplaceChild ¶ 

func (p Union) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Union) ReplaceParent ¶ 

func (p Union) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (Union) ResolveIndices ¶ 

func (p Union) ResolveIndices()

ResolveIndices implements Plan interface.

func (Union) Schema ¶ 

func (p Union) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Union) SetChildren ¶ 

func (p Union) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Union) SetParents ¶ 

func (p Union) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Union) SetSchema ¶ 

func (p Union) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Union) ToPB ¶ 

func (p *Union) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

type Update ¶ 

type Update struct {
	OrderedList []*expression.Assignment
	// contains filtered or unexported fields
}

Update represents Update plan.

func (Update) AddChild ¶ 

func (p Update) AddChild(child Plan)

AddChild implements Plan AddChild interface.

func (Update) AddParent ¶ 

func (p Update) AddParent(parent Plan)

AddParent implements Plan AddParent interface.

func (Update) Allocator ¶ 

func (p Update) Allocator() *idAllocator

func (Update) Children ¶ 

func (p Update) Children() []Plan

Children implements Plan Children interface.

func (*Update) Copy ¶ 

func (p *Update) Copy() PhysicalPlan

Copy implements the PhysicalPlan Copy interface.

func (Update) ID ¶ 

func (p Update) ID() string

ID implements Plan ID interface.

func (Update) MarshalJSON ¶ 

func (p Update) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler interface.

func (Update) Parents ¶ 

func (p Update) Parents() []Plan

Parents implements Plan Parents interface.

func (*Update) PredicatePushDown ¶ 

func (p *Update) PredicatePushDown(predicates []expression.Expression) ([]expression.Expression, LogicalPlan, error)

PredicatePushDown implements LogicalPlan interface.

func (*Update) PruneColumns ¶ 

func (p *Update) PruneColumns(parentUsedCols []*expression.Column)

PruneColumns implements LogicalPlan interface.

func (Update) ReplaceChild ¶ 

func (p Update) ReplaceChild(child, newChild Plan) error

ReplaceChild means replace a child with another one.

func (Update) ReplaceParent ¶ 

func (p Update) ReplaceParent(parent, newPar Plan) error

ReplaceParent means replace a parent for another one.

func (*Update) ResolveIndices ¶ 

func (p *Update) ResolveIndices()

ResolveIndices implements Plan interface.

func (Update) Schema ¶ 

func (p Update) Schema() *expression.Schema

Schema implements Plan Schema interface.

func (Update) SetChildren ¶ 

func (p Update) SetChildren(children ...Plan)

SetChildren implements Plan SetChildren interface.

func (Update) SetParents ¶ 

func (p Update) SetParents(pars ...Plan)

SetParents implements Plan SetParents interface.

func (Update) SetSchema ¶ 

func (p Update) SetSchema(schema *expression.Schema)

SetSchema implements Plan SetSchema interface.

func (*Update) ToPB ¶ 

func (p *Update) ToPB(_ context.Context) (*tipb.Executor, error)

ToPB implements PhysicalPlan ToPB interface.

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.