diff options
| author | wangfei <wangfei1@huawei.com> | 2014-12-18 20:24:56 -0800 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2014-12-18 20:24:56 -0800 |
| commit | c3d91da5ea8b85ca75444ec606f2e1eae376c4b2 (patch) | |
| tree | 3e41b59c473f6954af52b7e059049b41c99a5754 /sql/catalyst | |
| parent | ae9f128608f67cbee0a2fb24754783ee3b4f3098 (diff) | |
| download | spark-c3d91da5ea8b85ca75444ec606f2e1eae376c4b2.tar.gz spark-c3d91da5ea8b85ca75444ec606f2e1eae376c4b2.tar.bz2 spark-c3d91da5ea8b85ca75444ec606f2e1eae376c4b2.zip | |
[SPARK-4861][SQL] Refactory command in spark sql
Remove ```Command``` and use ```RunnableCommand``` instead.
Author: wangfei <wangfei1@huawei.com>
Author: scwf <wangfei1@huawei.com>
Closes #3712 from scwf/cmd and squashes the following commits:
51a82f2 [wangfei] fix test failure
0e03be8 [wangfei] address comments
4033bed [scwf] remove CreateTableAsSelect in hivestrategy
5d20010 [wangfei] address comments
125f542 [scwf] factory command in spark sql
Diffstat (limited to 'sql/catalyst')
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/commands.scala | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/commands.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/commands.scala index 1d513d7789..5a1863953e 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/commands.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/commands.scala @@ -30,23 +30,6 @@ abstract class Command extends LeafNode { } /** - * Returned for commands supported by a given parser, but not catalyst. In general these are DDL - * commands that are passed directly to another system. - */ -case class NativeCommand(cmd: String) extends Command { - override def output = - Seq(AttributeReference("result", StringType, nullable = false)()) -} - -/** - * Commands of the form "SET [key [= value] ]". - */ -case class DFSCommand(kv: Option[(String, Option[String])]) extends Command { - override def output = Seq( - AttributeReference("DFS output", StringType, nullable = false)()) -} - -/** * * Commands of the form "SET [key [= value] ]". */ |