Anton Kedin created BEAM-4194:
---------------------------------
Summary: [SQL] Support LIMIT
Key: BEAM-4194
URL: https://issues.apache.org/jira/browse/BEAM-4194
Project: Beam
Issue Type: New Feature
Components: dsl-sql
Reporter: Anton Kedin
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)