back to collapsed details

Bounded Splittable DoFn Support Status

Base
Side Inputs
Splittable DoFn Initiated Checkpointing
Dynamic Splitting
Bundle Finalization
Google Cloud DataflowApache FlinkApache Spark (RDD/DStream based)Apache Spark Structured Streaming (Dataset based)IBM StreamsApache SamzaApache NemoHazelcast JetTwister2Python Direct FnRunnerGo Direct Runner

Partially : Only Dataflow Runner V2 supports this.


Partially : Only portable Flink Runner supports this.


:


:


:


:


:


:


:


Yes :


Yes :


Partially : Only Dataflow Runner V2 supports this.


Partially : Only portable Flink Runner supports this.


:


:


:


:


:


:


:


:


Yes :


Partially : Only Dataflow Runner v2 supports this.


Partially : Only portable Flink Runner supports this.


:


:


:


:


:


:


:


Yes :


No :


Partially : Only Dataflow Runner V2 supports this.


No :


:


:


:


:


:


:


:


Yes : Only with Python SDK


No :


Partially : Only Dataflow Runner V2 supports this.


No :


:


:


:


:


:


:


:


Yes :


No :


Last updated on 2021/02/05

Have you found everything you were looking for?

Was it all useful and clear? Is there anything that you would like to change? Let us know!