aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst
diff options
context:
space:
mode:
authorgatorsmile <gatorsmile@gmail.com>2015-12-08 10:15:58 -0800
committerMichael Armbrust <michael@databricks.com>2015-12-08 10:15:58 -0800
commitc0b13d5565c45ae2acbe8cfb17319c92b6a634e4 (patch)
tree21457ea9d9174df6b39ae41f8b8152697e320c65 /sql/catalyst
parent381f17b540d92507cc07adf18bce8bc7e5ca5407 (diff)
downloadspark-c0b13d5565c45ae2acbe8cfb17319c92b6a634e4.tar.gz
spark-c0b13d5565c45ae2acbe8cfb17319c92b6a634e4.tar.bz2
spark-c0b13d5565c45ae2acbe8cfb17319c92b6a634e4.zip
[SPARK-12195][SQL] Adding BigDecimal, Date and Timestamp into Encoder
This PR is to add three more data types into Encoder, including `BigDecimal`, `Date` and `Timestamp`. marmbrus cloud-fan rxin Could you take a quick look at these three types? Not sure if it can be merged to 1.6. Thank you very much! Author: gatorsmile <gatorsmile@gmail.com> Closes #10188 from gatorsmile/dataTypesinEncoder.
Diffstat (limited to 'sql/catalyst')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala18
1 files changed, 18 insertions, 0 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala
index c40061ae0a..3ca5ade7f3 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala
@@ -98,6 +98,24 @@ object Encoders {
def STRING: Encoder[java.lang.String] = ExpressionEncoder()
/**
+ * An encoder for nullable decimal type.
+ * @since 1.6.0
+ */
+ def DECIMAL: Encoder[java.math.BigDecimal] = ExpressionEncoder()
+
+ /**
+ * An encoder for nullable date type.
+ * @since 1.6.0
+ */
+ def DATE: Encoder[java.sql.Date] = ExpressionEncoder()
+
+ /**
+ * An encoder for nullable timestamp type.
+ * @since 1.6.0
+ */
+ def TIMESTAMP: Encoder[java.sql.Timestamp] = ExpressionEncoder()
+
+ /**
* Creates an encoder for Java Bean of type T.
*
* T must be publicly accessible.