-
- Downloads
[SPARK-7654][SQL] Move JDBC into DataFrame's reader/writer interface.
Also moved all the deprecated functions into one place for SQLContext and DataFrame, and updated tests to use the new API. Author: Reynold Xin <rxin@databricks.com> Closes #6210 from rxin/df-writer-reader-jdbc and squashes the following commits: 7465c2c [Reynold Xin] Fixed unit test. 118e609 [Reynold Xin] Updated tests. 3441b57 [Reynold Xin] Updated javadoc. 13cdd1c [Reynold Xin] [SPARK-7654][SQL] Move JDBC into DataFrame's reader/writer interface.
Showing
- examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java 2 additions, 2 deletions...main/java/org/apache/spark/examples/sql/JavaSparkSQL.java
- sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala 110 additions, 174 deletionssql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala 88 additions, 1 deletion...src/main/scala/org/apache/spark/sql/DataFrameReader.scala
- sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala 52 additions, 1 deletion...src/main/scala/org/apache/spark/sql/DataFrameWriter.scala
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 276 additions, 406 deletions...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala 18 additions, 12 deletions...re/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala
- sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRelation.scala 4 additions, 12 deletions...c/main/scala/org/apache/spark/sql/jdbc/JDBCRelation.scala
- sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcUtils.scala 52 additions, 0 deletions.../src/main/scala/org/apache/spark/sql/jdbc/JdbcUtils.scala
- sql/core/src/main/scala/org/apache/spark/sql/jdbc/jdbc.scala 3 additions, 3 deletionssql/core/src/main/scala/org/apache/spark/sql/jdbc/jdbc.scala
- sql/core/src/test/java/test/org/apache/spark/sql/JavaApplySchemaSuite.java 2 additions, 2 deletions.../java/test/org/apache/spark/sql/JavaApplySchemaSuite.java
- sql/core/src/test/java/test/org/apache/spark/sql/sources/JavaSaveLoadSuite.java 4 additions, 6 deletions.../test/org/apache/spark/sql/sources/JavaSaveLoadSuite.java
- sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala 19 additions, 12 deletions.../src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala
- sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCWriteSuite.scala 28 additions, 26 deletions...test/scala/org/apache/spark/sql/jdbc/JDBCWriteSuite.scala
- sql/hive/src/test/java/org/apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java 16 additions, 4 deletions.../apache/spark/sql/hive/JavaMetastoreDataSourcesSuite.java
- sql/hive/src/test/scala/org/apache/spark/sql/hive/CachedTableSuite.scala 2 additions, 2 deletions...st/scala/org/apache/spark/sql/hive/CachedTableSuite.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/MetastoreDataSourcesSuite.scala 36 additions, 37 deletions...org/apache/spark/sql/hive/MetastoreDataSourcesSuite.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveResolutionSuite.scala 3 additions, 3 deletions...apache/spark/sql/hive/execution/HiveResolutionSuite.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala 4 additions, 4 deletions...a/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
- sql/hive/src/test/scala/org/apache/spark/sql/hive/parquetSuites.scala 7 additions, 7 deletions.../test/scala/org/apache/spark/sql/hive/parquetSuites.scala
- sql/hive/src/test/scala/org/apache/spark/sql/sources/hadoopFsRelationSuites.scala 21 additions, 47 deletions...org/apache/spark/sql/sources/hadoopFsRelationSuites.scala
Loading
Please register or sign in to comment