coreusage

Documentation

Index

• func ExtractCorColumnsBySchema(corCols []*expression.CorrelatedColumn, schema *expression.Schema, ...) []*expression.CorrelatedColumn
• func ExtractCorColumnsBySchema4LogicalPlan(p base.LogicalPlan, schema *expression.Schema) []*expression.CorrelatedColumn
• func ExtractCorColumnsBySchema4PhysicalPlan(p base.PhysicalPlan, schema *expression.Schema) []*expression.CorrelatedColumn
• func ExtractCorrelatedCols4LogicalPlan(p base.LogicalPlan) []*expression.CorrelatedColumn
• func ExtractCorrelatedCols4PhysicalPlan(p base.PhysicalPlan) []*expression.CorrelatedColumn
• func WrapCastForAggFuncs(sctx expression.BuildContext, aggFuncs []*aggregation.AggFuncDesc)

Functions

func ExtractCorColumnsBySchema

func ExtractCorColumnsBySchema(corCols []*expression.CorrelatedColumn,
	schema *expression.Schema, resolveIndex bool) []*expression.CorrelatedColumn

ExtractCorColumnsBySchema only extracts the correlated columns that match the specified schema. e.g. If the correlated columns from plan are [t1.a, t2.a, t3.a] and specified schema is [t2.a, t2.b, t2.c], only [t2.a] is returned.

func ExtractCorColumnsBySchema4LogicalPlan

func ExtractCorColumnsBySchema4LogicalPlan(p base.LogicalPlan,
	schema *expression.Schema) []*expression.CorrelatedColumn

ExtractCorColumnsBySchema4LogicalPlan only extracts the correlated columns that match the specified schema. e.g. If the correlated columns from plan are [t1.a, t2.a, t3.a] and specified schema is [t2.a, t2.b, t2.c], only [t2.a] is returned.

func ExtractCorColumnsBySchema4PhysicalPlan

func ExtractCorColumnsBySchema4PhysicalPlan(p base.PhysicalPlan,
	schema *expression.Schema) []*expression.CorrelatedColumn

ExtractCorColumnsBySchema4PhysicalPlan only extracts the correlated columns that match the specified schema. e.g. If the correlated columns from plan are [t1.a, t2.a, t3.a] and specified schema is [t2.a, t2.b, t2.c], only [t2.a] is returned.

func ExtractCorrelatedCols4LogicalPlan

func ExtractCorrelatedCols4LogicalPlan(p base.LogicalPlan) []*expression.CorrelatedColumn

ExtractCorrelatedCols4LogicalPlan recursively extracts all of the correlated columns from a plan tree by calling base.LogicalPlan.ExtractCorrelatedCols.

func ExtractCorrelatedCols4PhysicalPlan

func ExtractCorrelatedCols4PhysicalPlan(p base.PhysicalPlan) []*expression.CorrelatedColumn

ExtractCorrelatedCols4PhysicalPlan recursively extracts all of the correlated columns from a plan tree by calling PhysicalPlan.ExtractCorrelatedCols.

func WrapCastForAggFuncs

func WrapCastForAggFuncs(sctx expression.BuildContext, aggFuncs []*aggregation.AggFuncDesc)

WrapCastForAggFuncs wraps the args of an aggregate function with a cast function. If the mode is FinalMode or Partial2Mode, we do not need to wrap cast upon the args, since the types of the args are already the expected.