自定义 I/O 模式
此页面描述了使用 自定义 I/O 连接器 的管道中的常见模式。自定义 I/O 连接器将管道连接到 Beam 的 内置 I/O 转换 不支持的数据库。
- Java SDK
- Python SDK
在内置连接器和自定义连接器之间进行选择
内置 I/O 连接器 经过测试和强化,因此尽可能使用它们。仅当以下情况发生时才使用自定义 I/O 连接器
- 没有内置选项存在
- 你的管道拉取了少量源数据
例如,可以使用自定义 I/O 连接器将少量源数据添加到管道元素中。如果你正在处理销售订单并将信息添加到每次购买中,可以使用自定义 I/O 连接器将少量数据拉入你的管道(而不是处理整个源数据)。
Beam 在许多线程上分配工作,因此自定义 I/O 连接器可能会增加数据源的平均负载。可以使用 startstart 和 finishfinish 捆绑注释来减少负载。
上次更新时间:2024/10/31
你是否找到了你想要的一切?
所有内容是否都很有用且清晰?你想要更改什么吗?请告诉我们!