Параметризованный тип вывода потока данных в файл avro

У меня есть конвейер, который успешно выводит файл Avro следующим образом:

ETL и анализ CSV-файлов в облачном потоке данных

Я новичок в облачном потоке данных и Java, поэтому надеюсь, что это правильный вопрос.У меня есть CSV-файл с n количеством столбцов и строк, которые могут бы...

Как объединить потоковые данные с большим набором исторических данных в Dataflow / Beam

Когда в облачном потоке данных Google PubSubIO подтверждается чтение сообщения?

Можно ли отложить подтверждение до тех пор, пока подграф (все, что ниже PubSubIO.Read) не будет успешно обработан?Например, мыпотоковый читает из подписки на...

Динамическое имя таблицы при записи в BQ из конвейеров потока данных

Можно ли использовать пользовательский компьютер для экземпляров потока данных?

Может ли облачный поток данных Google (Apache Beam) использовать ffmpeg для обработки видео или данных изображения

Можно ли обрабатывать входные данные хранилища данных в конвейере потока данных Google в пакете из N записей одновременно?

Я пытаюсь выполнить работу конвейера потока данных, которая будет выполнять одну функцию наN записей одновременно из хранилища данных. В моем случае эта функ...

Сложное объединение с потоком данных Google

Я новичок, пытающийся понять, как мы можем переписать пакетный процесс ETL в Google Dataflow. Я прочитал некоторые документы, приведу несколько примеров.Я пр...

Запись вывода конвейера потока данных в разделенное назначение

У нас есть один источник потоковых событий с тысячами событий в секунду, и все эти события помечены идентификатором, указывающим, к какому из наших десятков ...