Documentation
¶
Index ¶
- func ConstructDAGReq(ctx sessionctx.Context, plans []plannercore.PhysicalPlan, ...) (dagReq *tipb.DAGRequest, err 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 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.