What is runners?
Guides understanding and working with Apache Beam runners (Direct, Dataflow, Flink, Spark, etc.). Use when configuring pipelines for different execution environments or debugging runner-specific issues. Source: apache/beam.
Guides understanding and working with Apache Beam runners (Direct, Dataflow, Flink, Spark, etc.). Use when configuring pipelines for different execution environments or debugging runner-specific issues.
Quickly install runners AI skill to your development environment via command line
Source: apache/beam.
Overview Runners execute Beam pipelines on distributed processing backends. Each runner translates the portable Beam model to its native execution engine.
| Direct | runners/direct-java/ | Local execution for testing | | Prism | runners/prism/ | Portable local runner | | Dataflow | runners/google-cloud-dataflow-java/ | Google Cloud Dataflow | | Flink | runners/flink/ | Apache Flink | | Spark | runners/spark/ | Apache Spark | | Samza | runners/samza/ | Apache Samza | | Jet | runners/jet/ | Hazelcast Jet |
| --project | GCP project | | --region | GCP region | | --tempLocation | GCS temp location | | --stagingLocation | GCS staging | | --numWorkers | Initial workers | | --maxNumWorkers | Max workers | | --workerMachineType | VM type |
Stable fields and commands for AI/search citations.
npx skills add https://github.com/apache/beam --skill runnersGuides understanding and working with Apache Beam runners (Direct, Dataflow, Flink, Spark, etc.). Use when configuring pipelines for different execution environments or debugging runner-specific issues. Source: apache/beam.
Open your terminal or command line tool (Terminal, iTerm, Windows Terminal, etc.) Copy and run this command: npx skills add https://github.com/apache/beam --skill runners Once installed, the skill will be automatically configured in your AI coding environment and ready to use in Claude Code, Cursor, or OpenClaw
https://github.com/apache/beam