[Feature Request]: Automatically upgrade Dataflow Java pipelines that use cross-language transforms to Runner v2

[chamikaramj]

What would you like to happen?

Such pipelines would not work with Dataflow Runner v1.

We already do this for Python SDK:

beam/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py

Line 418 in f131b2d

if pipeline_proto or pipeline.contains_external_transforms:

Issue Priority

Priority: 2

Issue Component

Component: cross-language