无界可分割 DoFn 支持状态
基础 |
---|
侧输入 |
可分割 DoFn 初始化的检查点 |
动态拆分 |
捆绑包最终化 |
Google Cloud Dataflow | Apache Flink | Apache Spark(基于 RDD/DStream) | Apache Spark 结构化流(基于 Dataset) | Apache Samza | Apache Nemo | Hazelcast Jet | Twister2 | Python Direct FnRunner | Go Direct Runner |
---|
是 | 部分 支持不完整或在可移植 Flink 运行器上已损坏(#19637) | : | : | : | : | : | : | 是 | 否 |
是:完全支持 | 否 | : | : | : | : | : | : | : | 是 |
是 | 部分 | : | : | : | : | : | : | 是 | 否 |
否 | 否 | : | : | : | : | : | : | 否 | 否 |
部分:只有 Dataflow 运行器 V2 支持此功能。 | 否 | : | : | : | : | : | : | 是 | 否 |
上次更新时间:2024/10/31
您是否找到了您想要的一切?
是否所有内容都实用且清晰?您想更改任何内容吗?请告诉我们!