The original CQL query uses the ALL operator over the set of rows that are within a certain period from the watermark. We instead have a fancy join, due to windowing. Nonetheless, can this be simplified?
Imported from Jira BEAM-5795. Original Jira may contain additional context.
Reported by: kenn.