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 runnersApache 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