Как создать конвейер шаблона потока данных с помощью Beam 2.0?

В Dataflow 1.9 раньше был TemplatingDataflowPipelineRunner, а в Beam его нет. Каковы шаги по созданию конвейера шаблона потока данных с помощью Java SDK для Beam 2.0?