Apache Beam Model

What: sum, average or machine learning? used to be done with classic batch processing.
Where: windowing with event time such as fixed, sliding or session.
When: triggering with a water mark for input completeness but it can trigger multiple times based on each use case.
How: accumulation mode, discarding or accumulating previous window.