1 个仓库
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 是一种基于流的编程语言和数据流水线编排器。它提供了一种用于定义并发数据流的领域特定语言(DSL),允许用户通过一系列转换和过滤单个流元素的运算,将数据源链接到目的地。 该系统使用自定义脚本语法来定义数据流连接和流水线定义。这允许编排并发数据处理,其中多个流水线阶段同时执行,以在系统中移动数据元素。 该平台涵盖函数式数据转换和基于阶段的组合,在项目通过链接运算的顺序链时应用特定函数来修改或过滤项目。
Executes a function for every individual item passing through a pipeline to modify or filter the data.