OptimizeTableCommand¶
OptimizeTableCommand
is a LeafRunnableCommand
(Spark SQL).
Creating Instance¶
OptimizeTableCommand
takes the following to be created:
- Table Path
-
TableIdentifier
- Optional partition predicate
OptimizeTableCommand
is created when:
DeltaSqlAstBuilder
is requested to parse OPTIMIZE SQL statement
Executing Command¶
run(
sparkSession: SparkSession): Seq[Row]
run
gets the DeltaLog of the Delta table (by the path or tableId).
In the end, run
creates an OptimizeExecutor that is in turn requested to optimize.
run
is part of the RunnableCommand
(Spark SQL) abstraction.