-
- Downloads
[SPARK-13893][SQL] Remove SQLContext.catalog/analyzer (internal method)
## What changes were proposed in this pull request? Our internal code can go through SessionState.catalog and SessionState.analyzer. This brings two small benefits: 1. Reduces internal dependency on SQLContext. 2. Removes 2 public methods in Java (Java does not obey package private visibility). More importantly, according to the design in SPARK-13485, we'd need to claim this catalog function for the user-facing public functions, rather than having an internal field. ## How was this patch tested? Existing unit/integration test code. Author: Reynold Xin <rxin@databricks.com> Closes #11716 from rxin/SPARK-13893.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala 4 additions, 4 deletions...ain/scala/org/apache/spark/sql/DataFrameNaFunctions.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala 1 addition, 1 deletion...src/main/scala/org/apache/spark/sql/DataFrameReader.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala 2 additions, 2 deletions...src/main/scala/org/apache/spark/sql/DataFrameWriter.scala
- sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala 12 additions, 10 deletionssql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 6 additions, 7 deletions...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala 2 additions, 2 deletions...scala/org/apache/spark/sql/execution/QueryExecution.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/command/commands.scala 2 additions, 2 deletions...ala/org/apache/spark/sql/execution/command/commands.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileSourceStrategy.scala 2 additions, 1 deletion.../spark/sql/execution/datasources/FileSourceStrategy.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ddl.scala 4 additions, 4 deletions...cala/org/apache/spark/sql/execution/datasources/ddl.scala
- sql/core/src/test/scala/org/apache/spark/sql/ListTablesSuite.scala 3 additions, 3 deletions...src/test/scala/org/apache/spark/sql/ListTablesSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetQuerySuite.scala 2 additions, 2 deletions...sql/execution/datasources/parquet/ParquetQuerySuite.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala 4 additions, 6 deletions...rc/main/scala/org/apache/spark/sql/hive/HiveContext.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateTableAsSelect.scala 3 additions, 3 deletions...apache/spark/sql/hive/execution/CreateTableAsSelect.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateViewAsSelect.scala 3 additions, 3 deletions.../apache/spark/sql/hive/execution/CreateViewAsSelect.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala 1 addition, 1 deletion...apache/spark/sql/hive/execution/InsertIntoHiveTable.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/commands.scala 10 additions, 9 deletions.../scala/org/apache/spark/sql/hive/execution/commands.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/test/TestHive.scala 4 additions, 4 deletions.../main/scala/org/apache/spark/sql/hive/test/TestHive.scala
- sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java 1 addition, 1 deletion.../apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java
- sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveMetastoreCatalogSuite.scala 3 additions, 3 deletions...org/apache/spark/sql/hive/HiveMetastoreCatalogSuite.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/ListTablesSuite.scala 2 additions, 2 deletions...est/scala/org/apache/spark/sql/hive/ListTablesSuite.scala
Loading
Please register or sign in to comment