viirya commented on a change in pull request #24273: [SPARK-27344][SQL][TEST]
Support the LocalDate and Instant classes in Java Bean encoders
URL: https://github.com/apache/spark/pull/24273#discussion_r271380233
##########
File path: sql/catalyst/src/main/scala/org/apache/spark/sql/Row.scala
##########
@@ -269,13 +269,27 @@ trait Row extends Serializable {
*/
def getDate(i: Int): java.sql.Date = getAs[java.sql.Date](i)
+ /**
+ * Returns the value at position i of date type as java.time.LocalDate.
+ *
+ * @throws ClassCastException when data type does not match.
+ */
+ def getLocalDate(i: Int): java.time.LocalDate = getAs[java.time.LocalDate](i)
+
/**
* Returns the value at position i of date type as java.sql.Timestamp.
*
* @throws ClassCastException when data type does not match.
*/
def getTimestamp(i: Int): java.sql.Timestamp = getAs[java.sql.Timestamp](i)
+ /**
+ * Returns the value at position i of date type as java.time.Instant.
+ *
+ * @throws ClassCastException when data type does not match.
+ */
+ def getInstant(i: Int): java.time.Instant = getAs[java.time.Instant](i)
Review comment:
Oh, I just checked and found you added them as external types in
`RowEncoder` recently. Then it makes sense.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
