?
?
不多說,直接上干貨!
?
?
https://beam.apache.org/get-started/beam-overview/
?
?
?
在 Beam 管道上運行引擎會根據你選擇的分布式處理引擎,其中兼容的 API 轉換你的 Beam 程序應用,讓你的 Beam 應用程序可以有效的運行在指定的分布式處理引擎上。因而,當運行 Beam 程序的時候,你可以按照自己的需求選擇一種分布式處理引擎。當前 Beam 支持的管道運行引擎有以下幾種:
- Apache Apex
- Apache Flink
- Apache Spark
- Google Cloud Dataflow
?
?
即,一個 Beam 程序可以運行在多個 Beam 的可執行引擎上,包括 ApexRunner,FlinkRunner,SparkRunner 或者 DataflowRunner。 另外還有 DirectRunner。不需要特殊的配置就可以在本地執行,方便測試使用。
?
?
?
?
?
Beam編程系列之Java SDK Quickstart(官網的推薦步驟)
?