Hi, When using streaming api, if I want a tumbling window on proctime all I have to do is the following: table.window(TumblingProcessingTimeWindows.of(Time.seconds(5)))... I don't even need to explicitly create a proctime column.
However, adding an intermediate tumbling window on proctime using the table api has proved more difficult. The docs seem to possibly imply that I can only add a proctime column on table creation [1] however this isn't what I want because it adds complexity. I want to only render and use proctime at one intermediate tumbling windowed aggregate in the entire query plan, Therefore, I don't want proctime carried from the beginning of all my tables to where I finally need it, I just want it where I need it. Every combination of things I've tried though has seemed to have failed. Is there any way to do this? Additionally, I don't want to switch to data streams because my tables have retractions and the table api is simpler to use in that sense. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/time_attributes.html Thanks! -- Rex Fenley | Software Engineer - Mobile and Backend Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | FOLLOW US <https://twitter.com/remindhq> | LIKE US <https://www.facebook.com/remindhq>
