Timm0 commented on PR #29070: URL: https://github.com/apache/flink/pull/29070#issuecomment-5573087416
> one thing I didn't get: are we intentionally omitting `partition by` here? Yes it is intentional. It is not available in the function signatures of windowing TVFs in the DataFrame API. For `tumble`, `hop`, and `cumulate` I don't see a problem here, since window assignment depends only on the time column and interval, and partitioning is expressed through downstream aggregations. For `session` though I can see that this pattern has the effect that global and not per-key sessions are produced. @dianfu do we want to add `partition_by` to the signature of `session` to accommodate for this? -- 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]
