V2CommandExec Physical Commands¶

V2CommandExec is an extension of the SparkPlan abstraction for physical commands that can be executed and cache the result to prevent multiple executions.

Contract¶

Executing Command¶

run(): Seq[InternalRow]

Executing the command (and computing the result)

Used when:

• V2CommandExec physical command is requested for a result

Implementations¶

• LeafV2CommandExec
• ShowCreateTableExec
• ShowNamespacesExec
• ShowPartitionsExec
• ShowTablesExec
• V2TableWriteExec

result¶

result: Seq[InternalRow]

result is the cached result of executing the physical command.

result is used when V2CommandExec physical command is requested to doExecute, executeCollect, executeToIterator, executeTake or executeTail.

Executing Physical Operator¶

doExecute(): RDD[InternalRow]

doExecute...FIXME

doExecute is part of the SparkPlan abstraction.

executeCollect¶

executeCollect(): Array[InternalRow]

executeCollect...FIXME

executeCollect is part of the SparkPlan abstraction.

executeToIterator¶

executeToIterator: Iterator[InternalRow]

executeToIterator...FIXME

executeToIterator is part of the SparkPlan abstraction.

executeTake¶

executeTake(
  limit: Int): Array[InternalRow]

executeTake...FIXME

executeTake is part of the SparkPlan abstraction.

executeTail¶

executeTail(
  limit: Int): Array[InternalRow]

executeTail...FIXME

executeTail is part of the SparkPlan abstraction.