1 repositorio
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 es un lenguaje de programación basado en flujos y orquestador de pipelines de datos. Proporciona un lenguaje específico de dominio para definir flujos de datos concurrentes, permitiendo a los usuarios vincular fuentes de datos a destinos a través de una secuencia de operaciones que transforman y filtran elementos de flujo individuales. El sistema utiliza una sintaxis de script personalizada para definir conexiones de flujo de datos y definiciones de pipeline. Esto permite la orquestación del procesamiento de datos concurrente donde múltiples etapas del pipeline se ejecutan simultáneamente para mover elementos de datos a través del sistema. La plataforma cubre la transformación funcional de datos y la composición basada en etapas, aplicando funciones específicas para modificar o filtrar elementos a medida que pasan a través de una cadena secuencial de operaciones vinculadas.
Executes a function for every individual item passing through a pipeline to modify or filter the data.