常见的管道模式

管道模式演示了常见的 Beam 用例。管道模式基于真实世界的 Beam 部署。每个模式都有一个描述、示例和解决方案或伪代码。

文件处理模式 - 用于从文件读取和写入文件的模式

侧输入模式 - 用于处理补充数据的模式

管道选项模式 - 用于配置管道的模式

自定义 I/O 模式 - 用于管道 I/O 的模式

自定义窗口模式 - 用于窗口函数的模式

BigQuery 模式 - 用于 BigQueryIO 的模式

AI 平台集成模式 - 用于使用 Google Cloud AI 平台转换的模式

模式模式 - 用于使用模式的模式

BQML 集成模式 - 将 BigQuery ML 集成到你的 Beam 管道中的模式

跨语言模式 - 用于创建跨语言管道的模式

状态和计时器模式 - 用于使用状态和计时器的模式

使用共享对象缓存 - 用于使用 Python SDK 将共享对象用作缓存的模式

贡献模式

要贡献新的管道模式，请创建 功能请求 并将详细信息添加到问题描述中。有关更多信息，请参阅 开始贡献。

下一步