[BEAM-3749] support customized trigger/accumulationMode in BeamSql

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Won't Fix
• Fix Version/s: 2.5.0
• Component/s: dsl-sql
• Assignee: Mingmin Xu
• Reporter: Mingmin Xu
• Created: 26/Feb/18 23:03
• Updated: 24/Jul/20 20:17
• Resolved: 22/Mar/18 21:13

Description

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.

Issue Links

• links to: GitHub Pull Request #4775
• links to: GitHub Pull Request #4826