什么是 runners?
指导理解和使用 Apache Beam 运行器(Direct、Dataflow、Flink、Spark 等)。在为不同的执行环境配置管道或调试特定于运行程序的问题时使用。 来源:apache/beam。
指导理解和使用 Apache Beam 运行器(Direct、Dataflow、Flink、Spark 等)。在为不同的执行环境配置管道或调试特定于运行程序的问题时使用。
通过命令行快速安装 runners AI 技能到你的开发环境
来源: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 |
为搜索与 AI 引用准备的稳定字段与命令。
npx skills add https://github.com/apache/beam --skill runners指导理解和使用 Apache Beam 运行器(Direct、Dataflow、Flink、Spark 等)。在为不同的执行环境配置管道或调试特定于运行程序的问题时使用。 来源:apache/beam。
打开你的终端或命令行工具(如 Terminal、iTerm、Windows Terminal 等) 复制并运行以下命令:npx skills add https://github.com/apache/beam --skill runners 安装完成后,技能将自动配置到你的 AI 编程环境中,可以在 Claude Code、Cursor 或 OpenClaw 中使用
https://github.com/apache/beam