public interface Command
Modifier and Type | Method and Description |
---|---|
RDD<org.apache.spark.sql.catalyst.expressions.Row> |
execute() |
org.apache.spark.sql.catalyst.expressions.Row[] |
executeCollect() |
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Row> |
sideEffectResult()
A concrete command should override this lazy field to wrap up any side effects caused by the
command or any other computation that should be evaluated exactly once.
|
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Row> sideEffectResult()
The execute()
method of all the physical command classes should reference sideEffectResult
so that the command can be executed eagerly right after the command query is created.
org.apache.spark.sql.catalyst.expressions.Row[] executeCollect()
RDD<org.apache.spark.sql.catalyst.expressions.Row> execute()