Apache Beam Word Count with the DIRECT Runner

Orchestrate the Apache Beam word-count pipeline on Kestra with the DIRECT runner, real ingested text, retries, timeouts, and Slack failure alerts.

More Data Blueprints

Turn any PDF, web page, or text document into structured JSON with OpenAI GPT-4o, then store the results in PostgreSQL and Slack.

Turn plain-English questions into PostgreSQL queries with OpenAI GPT-4o, grounded on schema only so no row data ever leaves your database.

Run parallel Airbyte syncs, then transform raw data with dbt Core, all in one orchestrated ELT pipeline.

Run Airbyte Cloud syncs in parallel, then trigger a dbt Cloud transformation job once the data lands.

Incrementally push freshly updated Postgres rows into an Algolia search index every five minutes.

Forecast 7-day demand with OpenAI GPT-4o, auto-generate purchase orders for stockout-risk SKUs, and log them to PostgreSQL every 6 hours.

Use blueprints to kickstart your first workflows.