diff options
| author | Reynold Xin <rxin@databricks.com> | 2016-05-20 09:36:14 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-05-20 09:36:14 -0700 |
| commit | e8adc552df80af413e1d31b020489612d13a8770 (patch) | |
| tree | ff85224ad75aae666448e813624c6cb806c9d9f6 /sql/hive/src/main/scala | |
| parent | d2e1aa97ef5bf7cfffc777a178f44ab8fa775266 (diff) | |
| download | spark-e8adc552df80af413e1d31b020489612d13a8770.tar.gz spark-e8adc552df80af413e1d31b020489612d13a8770.tar.bz2 spark-e8adc552df80af413e1d31b020489612d13a8770.zip | |
[SPARK-15435][SQL] Append Command to all commands
## What changes were proposed in this pull request?
We started this convention to append Command suffix to all SQL commands. However, not all commands follow that convention. This patch adds Command suffix to all RunnableCommands.
## How was this patch tested?
Updated test cases to reflect the renames.
Author: Reynold Xin <rxin@databricks.com>
Closes #13215 from rxin/SPARK-15435.
Diffstat (limited to 'sql/hive/src/main/scala')
| -rw-r--r-- | sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala | 2 | ||||
| -rw-r--r-- | sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelectCommand.scala (renamed from sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelect.scala) | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala index 4c528fbbbe..86ab152402 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala @@ -485,7 +485,7 @@ private[hive] class HiveMetastoreCatalog(sparkSession: SparkSession) extends Log val QualifiedTableName(dbName, tblName) = getQualifiedTableName(table) - execution.CreateTableAsSelect( + execution.CreateTableAsSelectCommand( desc.copy(identifier = TableIdentifier(tblName, Some(dbName))), child, allowExisting) diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelect.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelectCommand.scala index 9dfbafae87..3fc900961e 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelect.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelectCommand.scala @@ -32,7 +32,7 @@ import org.apache.spark.sql.hive.MetastoreRelation * raise exception */ private[hive] -case class CreateTableAsSelect( +case class CreateTableAsSelectCommand( tableDesc: CatalogTable, query: LogicalPlan, allowExisting: Boolean) |