diff options
author | Cheng Hao <hao.cheng@intel.com> | 2015-04-29 16:23:34 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-04-29 16:23:34 -0700 |
commit | f8cbb0a4b37b0d4ba49515d888cb52dea9eb01f1 (patch) | |
tree | 51745ca0fed9e28d388748e46aa2bd208f72d9a9 /sql/core | |
parent | 3fc6cfd079d8cdd35574605cb9a4178ca7f2613d (diff) | |
download | spark-f8cbb0a4b37b0d4ba49515d888cb52dea9eb01f1.tar.gz spark-f8cbb0a4b37b0d4ba49515d888cb52dea9eb01f1.tar.bz2 spark-f8cbb0a4b37b0d4ba49515d888cb52dea9eb01f1.zip |
[SPARK-7229] [SQL] SpecificMutableRow should take integer type as internal representation for Date
Author: Cheng Hao <hao.cheng@intel.com>
Closes #5772 from chenghao-intel/specific_row and squashes the following commits:
2cd064d [Cheng Hao] scala style issue
60347a2 [Cheng Hao] SpecificMutableRow should take integer type as internal representation for DateType
Diffstat (limited to 'sql/core')
-rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala index db096af453..856a806781 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala @@ -256,6 +256,15 @@ class JDBCSuite extends FunSuite with BeforeAndAfter { assert(cachedRows(0).getAs[java.sql.Date](1) === java.sql.Date.valueOf("1996-01-01")) } + test("test DATE types in cache") { + val rows = TestSQLContext.jdbc(urlWithUserAndPass, "TEST.TIMETYPES").collect() + TestSQLContext + .jdbc(urlWithUserAndPass, "TEST.TIMETYPES").cache().registerTempTable("mycached_date") + val cachedRows = sql("select * from mycached_date").collect() + assert(rows(0).getAs[java.sql.Date](1) === java.sql.Date.valueOf("1996-01-01")) + assert(cachedRows(0).getAs[java.sql.Date](1) === java.sql.Date.valueOf("1996-01-01")) + } + test("H2 floating-point types") { val rows = sql("SELECT * FROM flttypes").collect() assert(rows(0).getDouble(0) === 1.00000000000000022) // Yes, I meant ==. |