Download icon
Write icon
RunPipeline icon
Log icon
SlackIncomingWebhook icon

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.

Categories
Data

More Data Blueprints

Generate and Execute SQL Queries from Natural Language Using OpenAI GPT-4o
Queries icon
ChatCompletion icon
If icon
IonToJson icon
Log icon
AIData
Sync Postgres records to Algolia index
Trigger icon
ForEach icon
Index icon
Query icon
postgresql icon
BusinessData
AI-Powered Inventory Demand Forecasting, Auto-Generate Purchase Orders with OpenAI
Parallel icon
Request icon
ChatCompletion icon
Script icon
If icon
ForEach icon
+3
AIBusinessData
See How

New to Kestra?

Use blueprints to kickstart your first workflows.

Get Started