Typed data pipelines, straight from your IDE

// 1. Define the source import { pipeline, source, sink } from '@stratum/core' const orders = source.postgres({ table: 'orders', watermark: 'updated_at' }) // 2. Transform with types const enriched = orders .filter(o => o.total > 0) .join(users, 'user_id') .select({ id: o => o.id, revenue: o => o.total * 0.97, cohort: o => o.user.plan }) // 3. Ship it await pipeline('orders_fact') .from(enriched) .to(sink.snowflake({ table: 'fact_orders' })) .run()