Pipeline Data Flow

Data flow operations in the PIPELINE pillar.

map

const processed = pipeline.map(items, item => transform(item))

filter

const filtered = pipeline.filter(items, item => item.active)

reduce

const sum = pipeline.reduce(items, (acc, item) => acc + item.value, 0)

validate

const validated = pipeline.validate(data, schema)

Next Steps

• PIPELINE Pillar
• Pipeline Composition
• Examples