有界可分割 DoFn 支持状态
基础 |
---|
侧输入 |
可分割 DoFn 启动的检查点 |
动态拆分 |
捆绑最终化 |
Google Cloud Dataflow | Apache Flink | Apache Spark(基于 RDD/DStream) | Apache Spark 结构化流(基于数据集) | Apache Samza | Apache Nemo | Hazelcast Jet | Twister2 | Python 直接 FnRunner | Go 直接运行器 |
---|
部分:仅 Dataflow Runner V2 支持此功能。 | 部分:仅便携式 Flink Runner 支持此功能。 | : | : | : | : | : | : | 是 | 是 |
部分:仅 Dataflow Runner V2 支持此功能。 | 部分:仅便携式 Flink Runner 支持此功能。 | : | : | : | : | : | : | : | 是 |
部分:仅 Dataflow Runner v2 支持此功能。 | 部分:仅便携式 Flink Runner 支持此功能。 | : | : | : | : | : | : | 是 | 否 |
部分:仅 Dataflow Runner V2 支持此功能。 | 否 | : | : | : | : | : | : | 是:仅适用于 Python SDK | 否 |
部分:仅 Dataflow Runner V2 支持此功能。 | 否 | : | : | : | : | : | : | 是 | 否 |
最后更新于 2024/10/31
您找到您要找的所有内容了吗?
所有内容都有用且清晰吗?您想更改任何内容吗?请告诉我们!