P2 Description
We need to support queries with "LIMIT xxx".
Problem is that we don't know when aggregates will trigger, they can potentially accumulate values in global window and never trigger.
If we have some trigger syntax (BEAM-4193), then the use case becomes similar to what we have at the moment, where the user defines the trigger upstream for all inputs. In this case LIMIT probably can be implemented as sample.any(5) with trigger at count.
Attachments
Issue Links
- links to
