В Dataflow 1.9 раньше был TemplatingDataflowPipelineRunner
, а в Beam его нет. Каковы шаги по созданию конвейера шаблона потока данных с помощью Java SDK для Beam 2.0?
Понравилась статья? Поделиться с друзьями:
Вам также может быть интересно
У меня есть предварительный загрузчик css, который работает до полной загрузки страницы. Который затем
Я бы хотел, чтобы pip установил зависимость, которая у меня есть на GitHub, когда
Попытка модульного тестирования конечного автомата Spring UML с таймерами. Ожидается, что в реальном режиме
Я бы хотел, чтобы моя база данных сбрасывалась после каждого теста выполнением консольных команд
У меня есть изображение, и когда я нахожу на него указатель мыши, запускается событие
Это мой код на С++: #include <iostream> using namespace std; typedef struct Node {
Комментарии: 1
Добавить комментарий Отменить ответ
Начиная с Beam 2.0, используйте
DataflowRunner
и укажите--templateLocation
:Обратите внимание, что
--templateLocation
заменяет предыдущий--dataflowJobFile
.См. Документацию по потоку данных на странице Создание и размещение шаблонов для Java SDK 2.X