{"repo":"lpgauth/swirl","free":true,"listed":false,"github":"https://github.com/lpgauth/swirl","clone":"git clone https://github.com/lpgauth/swirl.git","description":"High-Performance Erlang Stream Processor","language":"Erlang","stars":58,"topics":["high-performance","erlang","stream-processing","flow"],"license":"MIT","category":"data-pipelines","readme_excerpt":"swirl High Performance Erlang Stream Processor Requirements Erlang/OTP 25+ Environment variables Name Type Default Description mappers max pos integer() 100 maximum number of mappers reducers max pos integer() 100 maximum number of reducers Examples Starting a flow Implementing a flow Stream Filter Swirl QL variables: values: boolean operators: comparison operators: inclusion operators: null operators: Telemetry swirl emits four telemetry events covering flow lifecycle and window dispatch. Attach handlers via telemetry:attach/4 : Event Measurements Metadata --- --- --- [swirl, flow, start] count = 1 flow id, module [swirl, flow, stop] count = 1 flow id, module [swirl, mapper, window] row count flow id, period [swirl, reducer, window] row count flow id, period Window events fire per mapper / reducer flush — natural per-batch granularity, not per-event. TODO node discovery boolean expression indexing Tests License","default_branch":null,"files":null,"tree":[],"storefront":"/r/lpgauth","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/lpgauth/swirl/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}