Hello! I am trying to understand how aligned wind...
# troubleshooting
k
Hello! I am trying to understand how aligned windows are implemented in the Table API/SQL. I was looking through the Flink GitHub repo and noticed that there is something called a
SlicingWindowOperator
which appears to formulate a sliding window with multiple non-overlapping windows and aggregate them together upon emission (source code reference). However, I am having trouble figuring out where this operator is invoked when a hopping/tumbling window is used in the table API. From the comments in the source code, it appears that it’s related but wanted to reach out to see if anyone knows here. Additionally, any further documentation on the window implementation that people could link would be helpful as well Thanks!