1 repository
Executing asynchronous or effectful computations for every individual element processed by a stream.
Distinct from Stream Processing: Focuses on the execution of effects per-element, whereas general Stream Processing covers the entire pipeline architecture.
Explore 1 awesome GitHub repository matching data & databases · Per-Element Effect Execution. Refine with filters or upvote what's useful.
Streem este un limbaj de programare bazat pe fluxuri (stream-based) și un orchestrator de pipeline-uri de date. Oferă un limbaj specific domeniului (DSL) pentru definirea fluxurilor de date concurente, permițând utilizatorilor să lege sursele de date la destinații printr-o secvență de operațiuni care transformă și filtrează elementele individuale ale fluxului. Sistemul utilizează o sintaxă de script personalizată pentru a defini conexiunile fluxului de date și definițiile pipeline-ului. Acest lucru permite orchestrarea procesării concurente a datelor, unde mai multe etape ale pipeline-ului se execută simultan pentru a muta elementele de date prin sistem. Platforma acoperă transformarea funcțională a datelor și compoziția bazată pe etape, aplicând funcții specifice pentru a modifica sau filtra elementele pe măsură ce trec printr-un lanț secvențial de operațiuni legate.
Executes a function for every individual item passing through a pipeline to modify or filter the data.