builder

Documentation

Index

• func ConstructDAGReq(ctx sessionctx.Context, plans []plannercore.PhysicalPlan, ...) (dagReq *tipb.DAGRequest, err error)
• func ConstructListBasedDistExec(pctx planctx.PlanContext, plans []plannercore.PhysicalPlan) ([]*tipb.Executor, error)
• func ConstructTreeBasedDistExec(pctx planctx.PlanContext, p plannercore.PhysicalPlan) ([]*tipb.Executor, error)

Functions

func ConstructDAGReq

func ConstructDAGReq(ctx sessionctx.Context, plans []plannercore.PhysicalPlan, storeType kv.StoreType) (dagReq *tipb.DAGRequest, err error)

ConstructDAGReq constructs DAGRequest for physical plans

func ConstructListBasedDistExec

func ConstructListBasedDistExec(pctx planctx.PlanContext, plans []plannercore.PhysicalPlan) ([]*tipb.Executor, error)

ConstructListBasedDistExec constructs list based DAGRequest

func ConstructTreeBasedDistExec

func ConstructTreeBasedDistExec(pctx planctx.PlanContext, p plannercore.PhysicalPlan) ([]*tipb.Executor, error)

ConstructTreeBasedDistExec constructs tree based DAGRequest