beyond1920 opened a new pull request #16669:
URL: https://github.com/apache/flink/pull/16669
## What is the purpose of the change
This pr is a subtask for support session window in Window TVF. This pr only
focuses on planner, the next pr would focus on runtime.
## Brief change log
- Introduce `SqlSessionTableFunction` and add a session table function
object in `FlinkSqlOperatorTable`
- Introduce `SessionWindowSpec`
- Modify `WindowUtil#convertToWindowingStrategy` to add SESSION window
- Disable `two-phase` (local-global) optimization for session window agg
because window assigner results may be different
- Disable `distinct-split`(partial-final) for session window agg because
window assigner results may be different
- Disable window table function for session window because
`WindowTableFunctionOperator` is not suitable for Session Window because can't
do state-less window assigning for input row per record for Session Window.
## Verifying this change
- Add planner test for normal window aggregate on session window in
`WindowAggregateTest`
- Add planner test to validate two-phase optimization and distinct-phase
optimization are disabled for window aggregate on session window in
`WindowAggregateTest`
- Add planner test for validate window- assigner table function is
disabled for session window
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (no)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (no)
- The serializers: (no)
- The runtime per-record code paths (performance sensitive): (no)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no)
- The S3 file system connector: (no)
## Documentation
- Does this pull request introduce a new feature? (no)
- If yes, how is the feature documented? (not applicable)
--
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]
