SuccessChanges

Summary

  1. [MINOR][SS] Remove duplicate 'add' in comment of (commit: 306ebb2975b0346a557a0e0f23e6f897d3912eef) (details)
  2. [SPARK-27735][SS] Parsing interval string should be case-insensitive in (commit: 7bdcc77e64af563de0fb24a9984b06f7d08b7298) (details)
Commit 306ebb2975b0346a557a0e0f23e6f897d3912eef by gurwls223
[MINOR][SS] Remove duplicate 'add' in comment of
`StructuredSessionization`.
## What changes were proposed in this pull request?
`StructuredSessionization` comment contains duplicate 'add', I think it
should be changed.
## How was this patch tested?
Exists UT.
Closes #24589 from beliefer/remove-duplicate-add-in-comment.
Lead-authored-by: gengjiaan <gengjiaan@360.cn> Co-authored-by: Jiaan
Geng <beliefer@163.com> Signed-off-by: HyukjinKwon
<gurwls223@apache.org>
(cherry picked from commit 7dd2dd5dc5d4210bef88b75b7f5b06266dc4ce1c)
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
(commit: 306ebb2975b0346a557a0e0f23e6f897d3912eef)
The file was modifiedexamples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredSessionization.scala (diff)
Commit 7bdcc77e64af563de0fb24a9984b06f7d08b7298 by dhyun
[SPARK-27735][SS] Parsing interval string should be case-insensitive in
SS
Some APIs in Structured Streaming requires the user to specify an
interval. Right now these APIs don't accept upper-case strings.
This PR adds a new method `fromCaseInsensitiveString` to
`CalendarInterval` to support paring upper-case strings, and fixes all
APIs that need to parse an interval string.
The new unit test.
Closes #24619 from zsxwing/SPARK-27735.
Authored-by: Shixiong Zhu <zsxwing@gmail.com> Signed-off-by: Dongjoon
Hyun <dhyun@apple.com>
(cherry picked from commit 6a317c8f014557dfd60931bd1eac3f545520d939)
Signed-off-by: Dongjoon Hyun <dhyun@apple.com>
(commit: 7bdcc77e64af563de0fb24a9984b06f7d08b7298)
The file was modifiedsql/core/src/main/scala/org/apache/spark/sql/Dataset.scala (diff)
The file was modifiedsql/core/src/main/scala/org/apache/spark/sql/streaming/ProcessingTime.scala (diff)
The file was modifiedcommon/unsafe/src/test/java/org/apache/spark/unsafe/types/CalendarIntervalSuite.java (diff)
The file was modifiedsql/core/src/main/scala/org/apache/spark/sql/execution/streaming/GroupStateImpl.scala (diff)
The file was modifiedsql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TimeWindow.scala (diff)
The file was modifiedsql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousTrigger.scala (diff)
The file was modifiedcommon/unsafe/src/main/java/org/apache/spark/unsafe/types/CalendarInterval.java (diff)