We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent faef887 commit 2c5d54dCopy full SHA for 2c5d54d
sql/core/src/test/scala/org/apache/spark/sql/parquet/ParquetIOSuite.scala
@@ -135,6 +135,21 @@ class ParquetIOSuiteBase extends QueryTest with ParquetTest {
135
}
136
137
138
+ test("date type") {
139
+ def makeDateRDD(): DataFrame =
140
+ sparkContext
141
+ .parallelize(0 to 1000)
142
+ .map(i => Tuple1(DateUtils.toJavaDate(i)))
143
+ .toDF()
144
+ .select($"_1")
145
+
146
+ withTempPath { dir =>
147
+ val data = makeDateRDD()
148
+ data.saveAsParquetFile(dir.getCanonicalPath)
149
+ checkAnswer(parquetFile(dir.getCanonicalPath), data.collect().toSeq)
150
+ }
151
152
153
test("map") {
154
val data = (1 to 4).map(i => Tuple1(Map(i -> s"val_$i")))
155
checkParquetFile(data)
0 commit comments