Skip to content

Commit 542977c

Browse files
committed
Avoids confusion between logical and physical plan by adding package prefixes
1 parent 55b2aa5 commit 542977c

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -18,17 +18,19 @@
1818
package org.apache.spark.sql.hive
1919

2020
import org.apache.spark.annotation.Experimental
21-
import org.apache.spark.sql._
2221
import org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute
2322
import org.apache.spark.sql.catalyst.expressions._
2423
import org.apache.spark.sql.catalyst.expressions.codegen.GeneratePredicate
2524
import org.apache.spark.sql.catalyst.planning._
2625
import org.apache.spark.sql.catalyst.plans._
2726
import org.apache.spark.sql.catalyst.plans.logical.{LogicalPlan, LowerCaseSchema}
28-
import org.apache.spark.sql.execution._
29-
import org.apache.spark.sql.hive.execution._
27+
import org.apache.spark.sql.catalyst.types.StringType
3028
import org.apache.spark.sql.columnar.InMemoryRelation
31-
import org.apache.spark.sql.parquet.{ParquetRelation, ParquetTableScan}
29+
import org.apache.spark.sql.execution.{DescribeCommand, OutputFaker, SparkPlan}
30+
import org.apache.spark.sql.hive
31+
import org.apache.spark.sql.hive.execution._
32+
import org.apache.spark.sql.parquet.ParquetRelation
33+
import org.apache.spark.sql.{SQLContext, SchemaRDD}
3234

3335
import scala.collection.JavaConversions._
3436

@@ -196,9 +198,9 @@ private[hive] trait HiveStrategies {
196198
case logical.NativeCommand(sql) =>
197199
NativeCommand(sql, plan.output)(context) :: Nil
198200

199-
case DropTable(tableName, ifExists) => execution.DropTable(tableName, ifExists) :: Nil
201+
case hive.DropTable(tableName, ifExists) => execution.DropTable(tableName, ifExists) :: Nil
200202

201-
case AnalyzeTable(tableName) => execution.AnalyzeTable(tableName) :: Nil
203+
case hive.AnalyzeTable(tableName) => execution.AnalyzeTable(tableName) :: Nil
202204

203205
case describe: logical.DescribeCommand =>
204206
val resolvedTable = context.executePlan(describe.table).analyzed

0 commit comments

Comments
 (0)