-
- Downloads
[SPARK-4861][SQL] Refactory command in spark sql
Follow up for #3712. This PR finally remove ```CommandStrategy``` and make all commands follow ```RunnableCommand``` so they can go with ```case r: RunnableCommand => ExecutedCommand(r) :: Nil```. One exception is the ```DescribeCommand``` of hive, which is a special case and need to distinguish hive table and temporary table, so still keep ```HiveCommandStrategy``` here. Author: scwf <wangfei1@huawei.com> Closes #3948 from scwf/followup-SPARK-4861 and squashes the following commits: 6b48e64 [scwf] minor style fix 2c62e9d [scwf] fix for hive module 5a7a819 [scwf] Refactory command in spark sql
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/AbstractSparkSQLParser.scala 0 additions, 69 deletions...rg/apache/spark/sql/catalyst/AbstractSparkSQLParser.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/commands.scala 1 addition, 47 deletions...rg/apache/spark/sql/catalyst/plans/logical/commands.scala
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 1 addition, 2 deletions...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/SparkSQLParser.scala 97 additions, 0 deletions.../src/main/scala/org/apache/spark/sql/SparkSQLParser.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 2 additions, 18 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/commands.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/sql/execution/commands.scala
- sql/hive-thriftserver/v0.12.0/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim12.scala 2 additions, 2 deletions...scala/org/apache/spark/sql/hive/thriftserver/Shim12.scala
- sql/hive-thriftserver/v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala 2 additions, 2 deletions...scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala 1 addition, 3 deletions...rc/main/scala/org/apache/spark/sql/hive/HiveContext.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala 27 additions, 4 deletions...ive/src/main/scala/org/apache/spark/sql/hive/HiveQl.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala 3 additions, 2 deletions...main/scala/org/apache/spark/sql/hive/HiveStrategies.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/TestHive.scala 2 additions, 1 deletion...e/src/main/scala/org/apache/spark/sql/hive/TestHive.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveComparisonTest.scala 2 additions, 0 deletions.../apache/spark/sql/hive/execution/HiveComparisonTest.scala
Loading
Please register or sign in to comment