1 dépôt
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 is a stream-based programming language and data pipeline orchestrator. It provides a domain-specific language for defining concurrent data flows, allowing users to link data sources to destinations through a sequence of operations that transform and filter individual stream elements. The system uses a custom script syntax to define data-flow connections and pipeline definitions. This allows for the orchestration of concurrent data processing where multiple pipeline stages execute simultaneously to move data elements through the system. The platform covers functional data transformatio
Executes a function for every individual item passing through a pipeline to modify or filter the data.