Мне было интересно, возможно ли использовать оператор if в конвейере лучей для принятия другого...

У меня много json-файлов в корзине, и с помощью python 3 я хочу получить имя файла, а затем создать...

Я новичок в Apache Beam и пытаюсь написать свой первый конвейер на Python для вывода данных из...

У меня есть список URL с подстановочными знаками внутри них, как я могу передать его в FileIO.match...

Я пытаюсь написать задание потока данных, которое должно обрабатывать журналы, расположенные в...

Присоединяйтесь к двум Pcollection с подходом CoGroupsByKey, который занимает часы, чтобы выполнить...

В настоящее время мы используем Dataflow для запуска потокового задания. В этой работе мы выполняем...

Apache beam В конвейере ввода / вывода есть две функции для чтения текстовых файлов: beam.io

Я играл с таймерами Apache Beam, но не могу их запустить. Насколько я знаю, вы определяете таймер в...

Я получаю ошибку: Error: A JNI error has occurred, please check your installation and try again...

Я использую конвейер DataFlow для потоковой передачи данных с устройств iot (через подписку PubSub)...

Я пытаюсь использовать набранные bigquery api, как показано на scio веб-сайте : @BigQueryType

У меня есть конвейер потока данных в потоковом режиме, так как он читает из раздела pubsub. Я хочу...

Мы создаем конвейер потока данных, мы будем читать данные из postgres и записывать их в файл...

Я настраиваю конвейер потока данных, в котором одним из действий является получение / добавление...

Я был бы признателен, если бы кто-нибудь помог мне написать код java для apache_beam (2.13.0) . В...

Согласно руководству по программированию BEAM и многим потоков join может быть достигнуто с помощью...

Попытка записать данные в таблицу BigQuery с помощью BeamSQL.Для записи данных нам нужна схема этих...

Я ищу объединение данных в PCollection вход представляет собой файл CSV customer id,customer name...

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

Я вычисляю статистику (min, avg и т. Д.) Для фиксированных окон данных.Данные передаются в виде...

Я бы хотел установить воздушный поток Apache и луч Apache вместе, используя Docker или...

Я пытаюсь запустить объединяющий DoFn с отслеживанием состояний в облачном потоке данных Google,...

Я использую apache-beam python 2.12.0 SDK. У меня проблемы при использовании какого-то специального...

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