runners
Installation
SKILL.md
Apache Beam Runners
Overview
Runners execute Beam pipelines on distributed processing backends. Each runner translates the portable Beam model to its native execution engine.
Available Runners
| Runner | Location | Description |
|---|---|---|
| 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 |
| Twister2 | runners/twister2/ |
Twister2 |