This is an automated email from the ASF dual-hosted git repository.
gengliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new ae9f612 [SPARK-36257][SQL] Updated the version of TimestampNTZ
related changes as 3.3.0
ae9f612 is described below
commit ae9f6126fbbf0cf5fe5a7ece8d074d7c0e11fd93
Author: Gengliang Wang <[email protected]>
AuthorDate: Thu Jul 22 21:01:29 2021 +0800
[SPARK-36257][SQL] Updated the version of TimestampNTZ related changes as
3.3.0
### What changes were proposed in this pull request?
As we decided to release TimestampNTZ type in Spark 3.3, we should update
the versions of TimestampNTZ related changes as 3.3.0.
### Why are the changes needed?
Correct the versions in documentation/code comment.
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
Existing UT
Closes #33478 from gengliangwang/updateVersion.
Authored-by: Gengliang Wang <[email protected]>
Signed-off-by: Gengliang Wang <[email protected]>
---
.../src/main/scala/org/apache/spark/sql/Encoders.scala | 2 +-
.../spark/sql/catalyst/expressions/datetimeExpressions.scala | 10 +++++-----
.../src/main/scala/org/apache/spark/sql/internal/SQLConf.scala | 4 ++--
.../scala/org/apache/spark/sql/types/TimestampNTZType.scala | 4 ++--
.../src/main/scala/org/apache/spark/sql/SQLImplicits.scala | 2 +-
sql/core/src/main/scala/org/apache/spark/sql/functions.scala | 2 +-
6 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoders.scala
b/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoders.scala
index f23f3c6..98d2f1a5 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoders.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/Encoders.scala
@@ -118,7 +118,7 @@ object Encoders {
* Creates an encoder that serializes instances of the
`java.time.LocalDateTime` class
* to the internal representation of nullable Catalyst's TimestampNTZType.
*
- * @since 3.2.0
+ * @since 3.3.0
*/
def LOCALDATETIME: Encoder[java.time.LocalDateTime] = ExpressionEncoder()
diff --git
a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala
b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala
index bc2e33b..5d42b31 100644
---
a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala
+++
b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala
@@ -217,7 +217,7 @@ case class Now() extends CurrentTimestampLike {
2020-04-25 15:49:11.914
""",
group = "datetime_funcs",
- since = "3.2.0")
+ since = "3.3.0")
case class LocalTimestamp(timeZoneId: Option[String] = None) extends
LeafExpression
with TimeZoneAwareExpression with CodegenFallback {
@@ -1096,7 +1096,7 @@ case class GetTimestamp(
2016-12-31 00:00:00
""",
group = "datetime_funcs",
- since = "3.2.0")
+ since = "3.3.0")
// scalastyle:on line.size.limit
case class ParseToTimestampNTZ(
left: Expression,
@@ -1143,7 +1143,7 @@ case class ParseToTimestampNTZ(
2016-12-31 00:00:00
""",
group = "datetime_funcs",
- since = "3.2.0")
+ since = "3.3.0")
// scalastyle:on line.size.limit
case class ParseToTimestampLTZ(
left: Expression,
@@ -2381,7 +2381,7 @@ case class MakeDate(
NULL
""",
group = "datetime_funcs",
- since = "3.2.0")
+ since = "3.3.0")
// scalastyle:on line.size.limit
case class MakeTimestampNTZ(
year: Expression,
@@ -2440,7 +2440,7 @@ case class MakeTimestampNTZ(
NULL
""",
group = "datetime_funcs",
- since = "3.2.0")
+ since = "3.3.0")
// scalastyle:on line.size.limit
case class MakeTimestampLTZ(
year: Expression,
diff --git
a/sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
b/sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
index bf421f0..189e59a 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
@@ -2892,9 +2892,9 @@ object SQLConf {
s"and type literal. Setting the configuration as
${TimestampTypes.TIMESTAMP_NTZ} will " +
"use TIMESTAMP WITHOUT TIME ZONE as the default type while putting it
as " +
s"${TimestampTypes.TIMESTAMP_LTZ} will use TIMESTAMP WITH LOCAL TIME
ZONE. " +
- "Before the 3.2.0 release, Spark only supports the TIMESTAMP WITH " +
+ "Before the 3.3.0 release, Spark only supports the TIMESTAMP WITH " +
"LOCAL TIME ZONE type.")
- .version("3.2.0")
+ .version("3.3.0")
.stringConf
.transform(_.toUpperCase(Locale.ROOT))
.checkValues(TimestampTypes.values.map(_.toString))
diff --git
a/sql/catalyst/src/main/scala/org/apache/spark/sql/types/TimestampNTZType.scala
b/sql/catalyst/src/main/scala/org/apache/spark/sql/types/TimestampNTZType.scala
index f7d20a0..99c29e4 100644
---
a/sql/catalyst/src/main/scala/org/apache/spark/sql/types/TimestampNTZType.scala
+++
b/sql/catalyst/src/main/scala/org/apache/spark/sql/types/TimestampNTZType.scala
@@ -29,7 +29,7 @@ import org.apache.spark.annotation.Unstable
* To represent an absolute point in time, use `TimestampType` instead.
*
* Please use the singleton `DataTypes.TimestampNTZType` to refer the type.
- * @since 3.2.0
+ * @since 3.3.0
*/
@Unstable
class TimestampNTZType private() extends AtomicType {
@@ -59,7 +59,7 @@ class TimestampNTZType private() extends AtomicType {
* "TimestampNTZType" in byte code. Defined with a private constructor so the
companion
* object is the only possible instantiation.
*
- * @since 3.2.0
+ * @since 3.3.0
*/
@Unstable
case object TimestampNTZType extends TimestampNTZType
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
b/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
index a3004ca..044231f 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/SQLImplicits.scala
@@ -82,7 +82,7 @@ abstract class SQLImplicits extends LowPrioritySQLImplicits {
/** @since 3.0.0 */
implicit def newLocalDateEncoder: Encoder[java.time.LocalDate] =
Encoders.LOCALDATE
- /** @since 3.2.0 */
+ /** @since 3.3.0 */
implicit def newLocalDateTimeEncoder: Encoder[java.time.LocalDateTime] =
Encoders.LOCALDATETIME
/** @since 2.2.0 */
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
b/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
index 74fef63..10ff3d4 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
@@ -2981,7 +2981,7 @@ object functions {
* All calls of localtimestamp within the same query return the same value.
*
* @group datetime_funcs
- * @since 3.2.0
+ * @since 3.3.0
*/
def localtimestamp(): Column = withExpr { LocalTimestamp() }
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
