Hi, Does integration with DataFlow (apache beam) on the roadmap?

Hi Miri - it's currently possible to run DataFlow code inside Dagster solids. Are there particular capabilities you'd find useful inside an integration?

Could Dagster work with a Java dataflow also .?

One approach for using dagster with Java dataflow would be to use the dagster-shell package to have dagster invoke shell commands that launch Java dataflow jobs. This is essentially what the dagster-spark package does to launch Scala Spark jobs. https://docs.dagster.io/_apidocs/libraries/dagster_shell#shell-dagster-shell