Skip to content

ColumnarRule

ColumnarRule is an abstraction to hold preColumnarTransitions and postColumnarTransitions user-defined rules to inject columnar physical operators to a query plan (using SparkSessionExtensions).

Note

ApplyColumnarRulesAndInsertTransitions physical optimization is used to execute ColumnarRules.

Contract

preColumnarTransitions

preColumnarTransitions: Rule[SparkPlan]

Used when ApplyColumnarRulesAndInsertTransitions physical optimization is executed.

postColumnarTransitions

postColumnarTransitions: Rule[SparkPlan]

Used when ApplyColumnarRulesAndInsertTransitions physical optimization is executed.