[SPARK-38069] improve structured streaming window of calculated

• Type: Improvement
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: 3.2.0
• Fix Version/s: 3.3.0
• Component/s: Structured Streaming
• Target Version/s: 3.2.0
• Assignee: nyingping
• Reporter: nyingping
• Created: 29/Jan/22 23:27
• Updated: 08/Feb/22 23:41
• Resolved: 08/Feb/22 23:41

Description

Structed Streaming computes window by intermediate result windowId, and windowId computes window by CaseWhen.

We can use Flink's method of calculating window to write it, which is more easy to understand, simple and efficient

Issue Links

• links to: [Github] Pull Request #35362 (nyingping)