physicalop

Documentation

Index

• type BasePhysicalPlan
  • func NewBasePhysicalPlan(ctx base.PlanContext, tp string, self base.PhysicalPlan, offset int) BasePhysicalPlan
  • func (p *BasePhysicalPlan) AppendChildCandidate(op *optimizetrace.PhysicalOptimizeOp)
  • func (p *BasePhysicalPlan) Attach2Task(tasks ...base.Task) base.Task
  • func (p *BasePhysicalPlan) BuildPlanTrace() *tracing.PlanTrace
  • func (p *BasePhysicalPlan) Children() []base.PhysicalPlan
  • func (p *BasePhysicalPlan) Clone(base.PlanContext) (base.PhysicalPlan, error)
  • func (p *BasePhysicalPlan) CloneForPlanCacheWithSelf(newCtx base.PlanContext, newSelf base.PhysicalPlan) (*BasePhysicalPlan, bool)
  • func (p *BasePhysicalPlan) CloneWithSelf(newCtx base.PlanContext, newSelf base.PhysicalPlan) (*BasePhysicalPlan, error)
  • func (*BasePhysicalPlan) ExplainInfo() string
  • func (*BasePhysicalPlan) ExplainNormalizedInfo() string
  • func (*BasePhysicalPlan) ExtractCorrelatedCols() []*expression.CorrelatedColumn
  • func (p *BasePhysicalPlan) GetActualProbeCnt(statsColl *execdetails.RuntimeStatsColl) int64
  • func (p *BasePhysicalPlan) GetChildReqProps(idx int) *property.PhysicalProperty
  • func (p *BasePhysicalPlan) GetEstRowCountForDisplay() float64
  • func (p *BasePhysicalPlan) GetPlanCostVer1(taskType property.TaskType, option *optimizetrace.PlanCostOption) (float64, error)
  • func (p *BasePhysicalPlan) GetPlanCostVer2(taskType property.TaskType, option *optimizetrace.PlanCostOption) (costusage.CostVer2, error)
  • func (p *BasePhysicalPlan) MemoryUsage() (sum int64)
  • func (p *BasePhysicalPlan) ResolveIndices() (err error)
  • func (p *BasePhysicalPlan) Schema() *expression.Schema
  • func (p *BasePhysicalPlan) SetChild(i int, child base.PhysicalPlan)
  • func (p *BasePhysicalPlan) SetChildren(children ...base.PhysicalPlan)
  • func (p *BasePhysicalPlan) SetChildrenReqProps(reqProps []*property.PhysicalProperty)
  • func (p *BasePhysicalPlan) SetProbeParents(probeParents []base.PhysicalPlan)
  • func (p *BasePhysicalPlan) SetXthChildReqProps(x int, reqProps *property.PhysicalProperty)
  • func (p *BasePhysicalPlan) StatsCount() float64
  • func (p *BasePhysicalPlan) ToPB(_ *base.BuildPBContext, _ kv.StoreType) (*tipb.Executor, error)

Types

type BasePhysicalPlan

type BasePhysicalPlan struct {
	baseimpl.Plan

	Self base.PhysicalPlan

	// used by the new cost interface
	PlanCostInit bool
	PlanCost     float64
	PlanCostVer2 costusage.CostVer2 `plan-cache-clone:"shallow"`

	// Only for MPP. If TiFlashFineGrainedShuffleStreamCount > 0:
	// 1. For ExchangeSender, means its output will be partitioned by hash key.
	// 2. For ExchangeReceiver/Window/Sort, means its input is already partitioned.
	TiFlashFineGrainedShuffleStreamCount uint64
	// contains filtered or unexported fields
}

BasePhysicalPlan is the common structure that used in physical plan.

func NewBasePhysicalPlan

func NewBasePhysicalPlan(ctx base.PlanContext, tp string, self base.PhysicalPlan, offset int) BasePhysicalPlan

NewBasePhysicalPlan creates a new BasePhysicalPlan.

func (*BasePhysicalPlan) AppendChildCandidate

func (p *BasePhysicalPlan) AppendChildCandidate(op *optimizetrace.PhysicalOptimizeOp)

AppendChildCandidate implements the base.PhysicalPlan.<15th> interface.

func (*BasePhysicalPlan) Attach2Task

func (p *BasePhysicalPlan) Attach2Task(tasks ...base.Task) base.Task

Attach2Task implements the base.PhysicalPlan.<2nd> interface.

func (*BasePhysicalPlan) BuildPlanTrace

func (p *BasePhysicalPlan) BuildPlanTrace() *tracing.PlanTrace

BuildPlanTrace implements Plan BuildPlanTrace interface.

func (*BasePhysicalPlan) Children

func (p *BasePhysicalPlan) Children() []base.PhysicalPlan

Children implements the base.PhysicalPlan.<7th> interface.

func (*BasePhysicalPlan) Clone

func (p *BasePhysicalPlan) Clone(base.PlanContext) (base.PhysicalPlan, error)

Clone implements the base.PhysicalPlan.<14th> interface.

func (*BasePhysicalPlan) CloneForPlanCacheWithSelf

func (p *BasePhysicalPlan) CloneForPlanCacheWithSelf(newCtx base.PlanContext, newSelf base.PhysicalPlan) (*BasePhysicalPlan, bool)

CloneForPlanCacheWithSelf clones the plan with new self.

func (*BasePhysicalPlan) CloneWithSelf

func (p *BasePhysicalPlan) CloneWithSelf(newCtx base.PlanContext, newSelf base.PhysicalPlan) (*BasePhysicalPlan, error)

CloneWithSelf clones the plan with new self.

func (*BasePhysicalPlan) ExplainInfo

func (*BasePhysicalPlan) ExplainInfo() string

ExplainInfo implements Plan ExplainInfo interface.

func (*BasePhysicalPlan) ExplainNormalizedInfo

func (*BasePhysicalPlan) ExplainNormalizedInfo() string

ExplainNormalizedInfo implements the base.PhysicalPlan.<13th> interface.

func (*BasePhysicalPlan) ExtractCorrelatedCols

func (*BasePhysicalPlan) ExtractCorrelatedCols() []*expression.CorrelatedColumn

ExtractCorrelatedCols implements the base.PhysicalPlan.<6th> interface.

func (*BasePhysicalPlan) GetActualProbeCnt

func (p *BasePhysicalPlan) GetActualProbeCnt(statsColl *execdetails.RuntimeStatsColl) int64

GetActualProbeCnt implements base.PhysicalPlan.<19th> interface.

func (*BasePhysicalPlan) GetChildReqProps

func (p *BasePhysicalPlan) GetChildReqProps(idx int) *property.PhysicalProperty

GetChildReqProps implements the base.PhysicalPlan.<4th> interface.

func (*BasePhysicalPlan) GetEstRowCountForDisplay

func (p *BasePhysicalPlan) GetEstRowCountForDisplay() float64

GetEstRowCountForDisplay implements base.PhysicalPlan.<18th> interface.

func (*BasePhysicalPlan) GetPlanCostVer1

func (p *BasePhysicalPlan) GetPlanCostVer1(taskType property.TaskType, option *optimizetrace.PlanCostOption) (float64, error)

GetPlanCostVer1 implements the base.PhysicalPlan.<0th> interface. which calculates the cost of the plan if it has not been calculated yet and returns the cost.

func (*BasePhysicalPlan) GetPlanCostVer2

func (p *BasePhysicalPlan) GetPlanCostVer2(taskType property.TaskType, option *optimizetrace.PlanCostOption) (costusage.CostVer2, error)

GetPlanCostVer2 implements the base.PhysicalPlan.<1st> interface. which calculates the cost of the plan if it has not been calculated yet and returns the cost.

func (*BasePhysicalPlan) MemoryUsage

func (p *BasePhysicalPlan) MemoryUsage() (sum int64)

MemoryUsage implements the base.PhysicalPlan.<16th> interface.

func (*BasePhysicalPlan) ResolveIndices

func (p *BasePhysicalPlan) ResolveIndices() (err error)

ResolveIndices implements the base.PhysicalPlan.<10th> interface.

func (*BasePhysicalPlan) Schema

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

Schema implements Plan Schema interface.

func (*BasePhysicalPlan) SetChild

func (p *BasePhysicalPlan) SetChild(i int, child base.PhysicalPlan)

SetChild implements the base.PhysicalPlan.<9th> interface.

func (*BasePhysicalPlan) SetChildren

func (p *BasePhysicalPlan) SetChildren(children ...base.PhysicalPlan)

SetChildren implements the base.PhysicalPlan.<8th> interface.

func (*BasePhysicalPlan) SetChildrenReqProps

func (p *BasePhysicalPlan) SetChildrenReqProps(reqProps []*property.PhysicalProperty)

SetChildrenReqProps set the BasePhysicalPlan's childrenReqProps.

func (*BasePhysicalPlan) SetProbeParents

func (p *BasePhysicalPlan) SetProbeParents(probeParents []base.PhysicalPlan)

SetProbeParents implements base.PhysicalPlan.<17th> interface.

func (*BasePhysicalPlan) SetXthChildReqProps

func (p *BasePhysicalPlan) SetXthChildReqProps(x int, reqProps *property.PhysicalProperty)

SetXthChildReqProps set the BasePhysicalPlan's x-th child as required property.

func (*BasePhysicalPlan) StatsCount

func (p *BasePhysicalPlan) StatsCount() float64

StatsCount implements the base.PhysicalPlan.<5th> interface.

func (*BasePhysicalPlan) ToPB

func (p *BasePhysicalPlan) ToPB(_ *base.BuildPBContext, _ kv.StoreType) (*tipb.Executor, error)

ToPB implements the base.PhysicalPlan.<3rd> interface.