-
- Downloads
[SPARK-14902][SQL] Expose RuntimeConfig in SparkSession
## What changes were proposed in this pull request? `RuntimeConfig` is the new user-facing API in 2.0 added in #11378. Until now, however, it's been dead code. This patch uses `RuntimeConfig` in `SessionState` and exposes that through the `SparkSession`. ## How was this patch tested? New test in `SQLContextSuite`. Author: Andrew Or <andrew@databricks.com> Closes #12669 from andrewor14/use-runtime-conf.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala 1 addition, 1 deletion...src/main/scala/org/apache/spark/sql/DataFrameWriter.scala
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 2 additions, 1 deletion...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala 27 additions, 10 deletions...re/src/main/scala/org/apache/spark/sql/SparkSession.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzeTable.scala 1 addition, 1 deletion...org/apache/spark/sql/execution/command/AnalyzeTable.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/command/tables.scala 1 addition, 1 deletion...scala/org/apache/spark/sql/execution/command/tables.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala 4 additions, 4 deletions...g/apache/spark/sql/execution/datasources/DataSource.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InsertIntoHadoopFsRelation.scala 2 additions, 1 deletion...ql/execution/datasources/InsertIntoHadoopFsRelation.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/DefaultSource.scala 1 addition, 1 deletion...e/spark/sql/execution/datasources/csv/DefaultSource.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/fileSourceInterfaces.scala 1 addition, 1 deletion...park/sql/execution/datasources/fileSourceInterfaces.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JSONRelation.scala 2 additions, 2 deletions...e/spark/sql/execution/datasources/json/JSONRelation.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRelation.scala 2 additions, 2 deletions...k/sql/execution/datasources/parquet/ParquetRelation.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala 1 addition, 1 deletion.../spark/sql/execution/datasources/text/DefaultSource.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSink.scala 1 addition, 1 deletion...apache/spark/sql/execution/streaming/FileStreamSink.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala 1 addition, 1 deletion...ache/spark/sql/execution/streaming/FileStreamSource.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala 1 addition, 1 deletion...pache/spark/sql/execution/streaming/HDFSMetadataLog.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulAggregate.scala 2 additions, 2 deletions...che/spark/sql/execution/streaming/StatefulAggregate.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamFileCatalog.scala 1 addition, 1 deletion...che/spark/sql/execution/streaming/StreamFileCatalog.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreRDD.scala 5 additions, 2 deletions...e/spark/sql/execution/streaming/state/StateStoreRDD.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/package.scala 4 additions, 3 deletions.../apache/spark/sql/execution/streaming/state/package.scala
- sql/core/src/main/scala/org/apache/spark/sql/internal/RuntimeConfigImpl.scala 19 additions, 19 deletions...ala/org/apache/spark/sql/internal/RuntimeConfigImpl.scala
Loading
Please register or sign in to comment