Windows and Triggers
Learn how to use Windows and Triggers in Elixir's Flow library to handle ongoing data streams efficiently. Understand different window types and trigger mechanisms that help manage large datasets and long-running flows, enabling timely progress updates and event grouping for improved concurrency.
Introduction
Operations like Flow.reduce/3, group_by/2, and take_sort/3 require all events to complete before they produce a result. After all, we cannot group or sort a list without all the data in the list being available to us. However, what if the data source keeps producing events for a long time or keeps producing events forever? This means we’ll have to wait for a ...