diff options
| author | Daoyuan Wang <daoyuan.wang@intel.com> | 2015-02-03 12:21:45 -0800 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2015-02-03 12:21:45 -0800 |
| commit | db821ed2ededf6ce79b838c77a9c10bed2ce555a (patch) | |
| tree | d34b200923ca35a67163d179f16521ff03865648 /sql/hive/v0.12.0/src | |
| parent | 5adbb39482631998dbfe4a1da88f6e75b30fb5ac (diff) | |
| download | spark-db821ed2ededf6ce79b838c77a9c10bed2ce555a.tar.gz spark-db821ed2ededf6ce79b838c77a9c10bed2ce555a.tar.bz2 spark-db821ed2ededf6ce79b838c77a9c10bed2ce555a.zip | |
[SPARK-4508] [SQL] build native date type to conform behavior to Hive
The previous #3732 is reverted due to some test failure.
Have fixed that.
Author: Daoyuan Wang <daoyuan.wang@intel.com>
Closes #4325 from adrian-wang/datenative and squashes the following commits:
096e20d [Daoyuan Wang] fix for mixed timezone
0ed0fdc [Daoyuan Wang] fix test data
a2fdd4e [Daoyuan Wang] getDate
c37832b [Daoyuan Wang] row to catalyst
f0005b1 [Daoyuan Wang] add date in sql parser and java type conversion
024c9a6 [Daoyuan Wang] clean some import order
d6715fc [Daoyuan Wang] refactoring Date as Primitive Int internally
374abd5 [Daoyuan Wang] spark native date type support
Diffstat (limited to 'sql/hive/v0.12.0/src')
| -rw-r--r-- | sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala b/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala index 254919e8f6..b5a0754ff6 100644 --- a/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala +++ b/sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim12.scala @@ -160,7 +160,7 @@ private[hive] object HiveShim { if (value == null) null else new hadoopIo.BytesWritable(value.asInstanceOf[Array[Byte]]) def getDateWritable(value: Any): hiveIo.DateWritable = - if (value == null) null else new hiveIo.DateWritable(value.asInstanceOf[java.sql.Date]) + if (value == null) null else new hiveIo.DateWritable(value.asInstanceOf[Int]) def getTimestampWritable(value: Any): hiveIo.TimestampWritable = if (value == null) { |