cloud-fan commented on code in PR #41058:
URL: https://github.com/apache/spark/pull/41058#discussion_r1186990157
##########
sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects.scala:
##########
@@ -111,11 +111,11 @@ abstract class JdbcDialect extends Serializable with
Logging {
* JDBC dialects should override this function to provide implementations
that suite their
* JDBC drivers.
* @param t Timestamp returned from JDBC driver getTimestamp method.
- * @return A LocalDateTime representing the same wall clock time as the
timestamp in database.
+ * @return A Long value representing the same wall clock time as the
timestamp in database.
*/
@Since("3.5.0")
- def convertJavaTimestampToTimestampNTZ(t: Timestamp): LocalDateTime = {
-
DateTimeUtils.microsToLocalDateTime(DateTimeUtils.fromJavaTimestampNoRebase(t))
+ def convertJavaTimestampToTimestampNTZ(t: Timestamp): Long = {
Review Comment:
I think symmetry API is more important than tiny perf improvements. But if
you have benchmark numbers to show this is a big issue, I'm happy to change my
mind.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
