Конвейер Apache Beam с использованием потоковой передачи FileIO не истощает поток данных.

# #java #google-cloud-dataflow #apache-beam Вопрос: Я пытаюсь разработать потоковый конвейер, который считывает данные из расположения файла и выполняет набор задач обработки полученных файлов, и в идеале должен сливаться при запуске.…