Xu Mingmin created BEAM-3749: -------------------------------- Summary: support customized trigger/accumulationMode in BeamSql Key: BEAM-3749 URL: https://issues.apache.org/jira/browse/BEAM-3749 Project: Beam Issue Type: Improvement Components: dsl-sql Reporter: Xu Mingmin Assignee: Xu Mingmin Fix For: 2.4.0
Currently BeamSql use {{DefaultTrigger}} for aggregation operations. By adding two options {{withTrigger(Trigger)}} and {{withAccumulationMode(AccumulationMode)}}, developers can specify their own aggregation strategies with BeamSql. [~xumingming] [~kedin] [~kenn] for any comments. -- This message was sent by Atlassian JIRA (v7.6.3#76005)