diff options
| author | Cheng Hao <hao.cheng@intel.com> | 2014-09-11 11:57:01 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2014-09-11 11:57:01 -0700 |
| commit | ca83f1e2c4dfa519e44b837b6815cba3b4526d92 (patch) | |
| tree | 0f1929f65f5e4a51f25d679b59238f7b0bf47e8d /sql/core/src/main | |
| parent | 1ef656ea85b4b93c7b0f3cf8042b63a0de0901cb (diff) | |
| download | spark-ca83f1e2c4dfa519e44b837b6815cba3b4526d92.tar.gz spark-ca83f1e2c4dfa519e44b837b6815cba3b4526d92.tar.bz2 spark-ca83f1e2c4dfa519e44b837b6815cba3b4526d92.zip | |
[SPARK-2917] [SQL] Avoid table creation in logical plan analyzing for CTAS
Author: Cheng Hao <hao.cheng@intel.com>
Closes #1846 from chenghao-intel/ctas and squashes the following commits:
56a0578 [Cheng Hao] remove the unused imports
9a57abc [Cheng Hao] Avoid table creation in logical plan analyzing
Diffstat (limited to 'sql/core/src/main')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/SchemaRDDLike.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDDLike.scala b/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDDLike.scala index 2f3033a5f9..e52eeb3e1c 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDDLike.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDDLike.scala @@ -54,7 +54,7 @@ private[sql] trait SchemaRDDLike { @transient protected[spark] val logicalPlan: LogicalPlan = baseLogicalPlan match { // For various commands (like DDL) and queries with side effects, we force query optimization to // happen right away to let these side effects take place eagerly. - case _: Command | _: InsertIntoTable | _: InsertIntoCreatedTable | _: WriteToFile => + case _: Command | _: InsertIntoTable | _: CreateTableAsSelect |_: WriteToFile => queryExecution.toRdd SparkLogicalPlan(queryExecution.executedPlan)(sqlContext) case _ => @@ -124,7 +124,7 @@ private[sql] trait SchemaRDDLike { */ @Experimental def saveAsTable(tableName: String): Unit = - sqlContext.executePlan(InsertIntoCreatedTable(None, tableName, logicalPlan)).toRdd + sqlContext.executePlan(CreateTableAsSelect(None, tableName, logicalPlan)).toRdd /** Returns the schema as a string in the tree format. * |