How would you compare dagster to
Apache Beam. Here an example of wordcount. I seems they have similar concepts, but less structured (no solid approach, so I guess more code duplications?), a bit more direct. One other difference they support streams:
https://beam.apache.org/get-started/wordcount-example/
What are your comments on that?