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: Rule[SparkPlan]

Used when ApplyColumnarRulesAndInsertTransitions physical optimization is executed.

postColumnarTransitions: Rule[SparkPlan]

Used when ApplyColumnarRulesAndInsertTransitions physical optimization is executed.