Documentation
¶
Index ¶
- func ConstructDAGReq(ctx sessionctx.Context, plans []plannercore.PhysicalPlan, ...) (dagReq *tipb.DAGRequest, err error)
- func ConstructDAGReqForUnNatureOrderPlans(ctx sessionctx.Context, plans []plannercore.PhysicalPlan, ...) (*tipb.DAGRequest, error)
- func ConstructListBasedDistExec(pctx *planctx.BuildPBContext, plans []plannercore.PhysicalPlan) ([]*tipb.Executor, error)
- func ConstructTreeBasedDistExec(pctx *planctx.BuildPBContext, p plannercore.PhysicalPlan) ([]*tipb.Executor, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ConstructDAGReqForUnNatureOrderPlans ¶
func ConstructDAGReqForUnNatureOrderPlans(ctx sessionctx.Context, plans []plannercore.PhysicalPlan, unNatureOrders map[int]int, storeType kv.StoreType) (*tipb.DAGRequest, error)
ConstructDAGReqForUnNatureOrderPlans constructs DAGRequest for physical plans. The unNatureOrders map is used to set the ParentIdx of executors in DAGRequest. `unNatureOrders` is a map with layout {childIndex => parentIndex} and contains the children indexes whose parent is not the next one.
func ConstructListBasedDistExec ¶
func ConstructListBasedDistExec(pctx *planctx.BuildPBContext, plans []plannercore.PhysicalPlan) ([]*tipb.Executor, error)
ConstructListBasedDistExec constructs list based DAGRequest
func ConstructTreeBasedDistExec ¶
func ConstructTreeBasedDistExec(pctx *planctx.BuildPBContext, p plannercore.PhysicalPlan) ([]*tipb.Executor, error)
ConstructTreeBasedDistExec constructs tree based DAGRequest
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.