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 f2acab20637 [SPARK-38834][SQL] Update the version of TimestampNTZ
related changes as 3.4.0
f2acab20637 is described below
commit f2acab20637eb8b48b3d0273c5409560b098123a
Author: Gengliang Wang <[email protected]>
AuthorDate: Fri Apr 8 23:29:41 2022 +0800
[SPARK-38834][SQL] Update the version of TimestampNTZ related changes as
3.4.0
### What changes were proposed in this pull request?
Update the version info of TimestampNTZ related changes as 3.4.0
### Why are the changes needed?
We decided to remove the TimestampNTZ support in 3.3
release(https://github.com/apache/spark/pull/36094) and release TimestampNTZ in
3.4 release.
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
GA tests.
Closes #36118 from gengliangwang/updateNTZVersion.
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 | 12 ++++++------
.../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 +-
5 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 98d2f1a5712..a4198044886 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.3.0
+ * @since 3.4.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 fc701d4f817..ff3d898942c 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
@@ -219,7 +219,7 @@ case class Now() extends CurrentTimestampLike {
2020-04-25 15:49:11.914
""",
group = "datetime_funcs",
- since = "3.3.0")
+ since = "3.4.0")
case class LocalTimestamp(timeZoneId: Option[String] = None) extends
LeafExpression
with TimeZoneAwareExpression with CodegenFallback {
@@ -1111,7 +1111,7 @@ case class GetTimestamp(
2016-12-31 00:00:00
""",
group = "datetime_funcs",
- since = "3.3.0")
+ since = "3.4.0")
// scalastyle:on line.size.limit
object ParseToTimestampNTZExpressionBuilder extends ExpressionBuilder {
override def build(funcName: String, expressions: Seq[Expression]):
Expression = {
@@ -1148,7 +1148,7 @@ object ParseToTimestampNTZExpressionBuilder extends
ExpressionBuilder {
2016-12-31 00:00:00
""",
group = "datetime_funcs",
- since = "3.3.0")
+ since = "3.4.0")
// scalastyle:on line.size.limit
object ParseToTimestampLTZExpressionBuilder extends ExpressionBuilder {
override def build(funcName: String, expressions: Seq[Expression]):
Expression = {
@@ -2440,7 +2440,7 @@ case class MakeDate(
NULL
""",
group = "datetime_funcs",
- since = "3.3.0")
+ since = "3.4.0")
// scalastyle:on line.size.limit
object MakeTimestampNTZExpressionBuilder extends ExpressionBuilder {
override def build(funcName: String, expressions: Seq[Expression]):
Expression = {
@@ -2487,7 +2487,7 @@ object MakeTimestampNTZExpressionBuilder extends
ExpressionBuilder {
NULL
""",
group = "datetime_funcs",
- since = "3.3.0")
+ since = "3.4.0")
// scalastyle:on line.size.limit
object MakeTimestampLTZExpressionBuilder extends ExpressionBuilder {
override def build(funcName: String, expressions: Seq[Expression]):
Expression = {
@@ -3015,7 +3015,7 @@ object SubtractDates {
2021-12-06 00:00:00
""",
group = "datetime_funcs",
- since = "3.3.0")
+ since = "3.4.0")
// scalastyle:on line.size.limit
case class ConvertTimezone(
sourceTz: 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 87c5f43c5cc..ad9e4c61444 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
@@ -3237,9 +3237,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.3.0 release, Spark only supports the TIMESTAMP WITH " +
+ "Before the 3.4.0 release, Spark only supports the TIMESTAMP WITH " +
"LOCAL TIME ZONE type.")
- .version("3.3.0")
+ .version("3.4.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 ef653100e81..ff31309af50 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.3.0
+ * @since 3.4.0
*/
@Unstable
class TimestampNTZType private() extends DatetimeType {
@@ -59,7 +59,7 @@ class TimestampNTZType private() extends DatetimeType {
* "TimestampNTZType" in byte code. Defined with a private constructor so the
companion
* object is the only possible instantiation.
*
- * @since 3.3.0
+ * @since 3.4.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 044231f4b5a..d257a6b771b 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.3.0 */
+ /** @since 3.4.0 */
implicit def newLocalDateTimeEncoder: Encoder[java.time.LocalDateTime] =
Encoders.LOCALDATETIME
/** @since 2.2.0 */
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
