diff --git a/core/src/main/scala/org/apache/spark/sql/execution/datasources/hbase/types/PrimitiveType.scala b/core/src/main/scala/org/apache/spark/sql/execution/datasources/hbase/types/PrimitiveType.scala index 0a99673b..efbffee2 100644 --- a/core/src/main/scala/org/apache/spark/sql/execution/datasources/hbase/types/PrimitiveType.scala +++ b/core/src/main/scala/org/apache/spark/sql/execution/datasources/hbase/types/PrimitiveType.scala @@ -58,6 +58,7 @@ class PrimitiveType(f:Option[Field] = None) extends SHCDataType { case data: Short => Bytes.toBytes(data) case data: UTF8String => data.getBytes case data: String => Bytes.toBytes(data) + case data:java.sql.Timestamp => Bytes.toBytes(data.getTime) case _ => throw new UnsupportedOperationException(s"PrimitiveType coder: unsupported data type $input") }