Apache Beam 是一种用于批处理和流式处理的统一编程模型,包含一套构建管道的特定语言 SDK 和在分布式处理后端执行管道的运行器。 亮点 用于 Calcite SqlTransform 的 Beam Java API 不再是实验性的 (BEAM-12680). Python 的 ParDo 转换现在支持 with_exception_handling 选项 I/O ReadFromBigQuery 和 ReadAllFromBigQu... Apache Beam 2.34.0 发布,大数据流处理与批处理编程范式下载地址