托管式 I/O 支持 BigQuery 的以下功能：
- 创建动态表
- 动态目标
- 对于读取，连接器使用 BigQuery Storage Read API。
对于写入，连接器使用以下 BigQuery 方法：
- 如果来源是无界限的且 Dataflow 使用的是流式“正好一次”处理，则连接器会使用 BigQuery Storage Write API 以“正好一次”传送语义的方式将数据写入 BigQuery。
- 如果来源是无界限的且 Dataflow 使用的是流式“至少一次”处理，则连接器会使用 BigQuery Storage Write API 以“至少一次”传送语义的方式将数据写入 BigQuery。
- 如果来源是有界限的，则连接器会使用 BigQuery 文件加载。
要求
以下 SDK 支持适用于 BigQuery 的托管式 I/O：
- Java 版 Apache Beam SDK 2.61.0 或更高版本
- Python 版 Apache Beam SDK 2.61.0 版或更高版本
配置
| 读取和写入配置 | 数据类型 | 说明 |
|---|---|---|
table |
字符串 | 要读取或写入的 BigQuery 表。格式为 "PROJECT.DATASET.TABLE"。示例："my_project.dataset1.table1"。 |
kms_key |
字符串 | 指定 Cloud Key Management Service (Cloud KMS) 密钥，以在写入时加密 BigQuery 表，或加密在读取期间创建的任何临时表。 |
| 读取配置 | 数据类型 | 说明 |
fields |
字符串列表 | 要从表中读取的列的列表。当表包含许多列时，此参数可实现高效读取。 |
query |
字符串 | 要从中读取的 SQL 查询。如果已指定，则连接器会在 BigQuery 上运行查询并读取查询结果。 |
row_restriction |
字符串 | 在服务器端过滤数据的谓词。示例：
"age > 18"。 |
| 写入配置 | 数据类型 | 说明 |
triggering_frequency |
整数 | 对于无界限来源，指定文件写入触发的频率（以秒为单位）。 |
对于读取，您必须指定 table 或 query。对于写入，您必须指定 table。
如需了解详情，请参阅以下主题：