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)