aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorCheng Lian <lian.cs.zju@gmail.com>2014-08-02 17:12:49 -0700
committerMichael Armbrust <michael@databricks.com>2014-08-02 17:12:49 -0700
commit866cf1f822cfda22294054be026ef2d96307eb75 (patch)
tree3f3a1d3ab2f78be1d962508bb247012b99aee7cf /sql
parent198df11f1a9f419f820f47eba0e9f2ab371a824b (diff)
downloadspark-866cf1f822cfda22294054be026ef2d96307eb75.tar.gz
spark-866cf1f822cfda22294054be026ef2d96307eb75.tar.bz2
spark-866cf1f822cfda22294054be026ef2d96307eb75.zip
[SPARK-2729][SQL] Added test case for SPARK-2729
This is a follow up of #1636. Author: Cheng Lian <lian.cs.zju@gmail.com> Closes #1738 from liancheng/test-for-spark-2729 and squashes the following commits: b13692a [Cheng Lian] Added test case for SPARK-2729
Diffstat (limited to 'sql')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/TestData.scala12
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/columnar/InMemoryColumnarQuerySuite.scala12
2 files changed, 22 insertions, 2 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/TestData.scala b/sql/core/src/test/scala/org/apache/spark/sql/TestData.scala
index 58cee21e8a..088e6e3c84 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/TestData.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/TestData.scala
@@ -17,11 +17,13 @@
package org.apache.spark.sql
+import java.sql.Timestamp
+
import org.apache.spark.sql.catalyst.plans.logical
import org.apache.spark.sql.test._
/* Implicits */
-import TestSQLContext._
+import org.apache.spark.sql.test.TestSQLContext._
case class TestData(key: Int, value: String)
@@ -40,7 +42,7 @@ object TestData {
LargeAndSmallInts(2147483646, 1) ::
LargeAndSmallInts(3, 2) :: Nil)
largeAndSmallInts.registerAsTable("largeAndSmallInts")
-
+
case class TestData2(a: Int, b: Int)
val testData2: SchemaRDD =
TestSQLContext.sparkContext.parallelize(
@@ -143,4 +145,10 @@ object TestData {
"2, B2, false, null" ::
"3, C3, true, null" ::
"4, D4, true, 2147483644" :: Nil)
+
+ case class TimestampField(time: Timestamp)
+ val timestamps = TestSQLContext.sparkContext.parallelize((1 to 3).map { i =>
+ TimestampField(new Timestamp(i))
+ })
+ timestamps.registerAsTable("timestamps")
}
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/columnar/InMemoryColumnarQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/columnar/InMemoryColumnarQuerySuite.scala
index 86727b93f3..b561b44ad7 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/columnar/InMemoryColumnarQuerySuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/columnar/InMemoryColumnarQuerySuite.scala
@@ -73,4 +73,16 @@ class InMemoryColumnarQuerySuite extends QueryTest {
sql("SELECT * FROM nullableRepeatedData"),
nullableRepeatedData.collect().toSeq)
}
+
+ test("SPARK-2729 regression: timestamp data type") {
+ checkAnswer(
+ sql("SELECT time FROM timestamps"),
+ timestamps.collect().toSeq)
+
+ TestSQLContext.cacheTable("timestamps")
+
+ checkAnswer(
+ sql("SELECT time FROM timestamps"),
+ timestamps.collect().toSeq)
+ }
}