beliefer commented on code in PR #41058:
URL: https://github.com/apache/spark/pull/41058#discussion_r1187131685
##########
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:
Yes. the performance is very bad.
--
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]
