Skip to content

Commit d114c88

Browse files
HanumathRaoekrivokonmapr
authored andcommitted
Fixing the wrong type casting of TimeStamp to OTimeStamp when read from spark dataFrame. (apache#159)
1 parent 12e3913 commit d114c88

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

external/maprdb/src/main/scala/com/mapr/db/spark/sql/utils/MapRSqlUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,7 @@ object MapRSqlUtils {
403403
case (BinaryType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[ByteBuffer])
404404
case (BooleanType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[Boolean])
405405
case (DateType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(new ODate(element.asInstanceOf[java.sql.Date]))
406-
case (TimestampType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[OTimestamp])
406+
case (TimestampType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(new OTimestamp(element.asInstanceOf[java.sql.Timestamp].getTime))
407407
case (NullType) => DBValueBuilderImpl.KeyValueBuilder.initFromNull()
408408
case (DoubleType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[Double])
409409
case (IntegerType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[Integer])

0 commit comments

Comments
 (0)