Я пытаюсь выполнить процедуру postgres, используя JDBCIO для Apache Beam. До сих пор я пытался:

У меня есть сценарий, в котором мне нужно запустить одно Java-задание Apache Beam в двух разных...

Я пишу в BigQuery в лучшем виде из неограниченного источника. Я использую СТРИМОВЫЕ ВСТАВКИ в...

Я довольно новичок в Google Dataflow и обнаружил, что служба тратит несколько часов, оценивая...

Я пытаюсь запустить очень простую программу в Apache Beam, чтобы проверить, как она работает....

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

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

Скажем, я хочу вычислить среднее значение определенного показателя за последние 10 минут после...

Согласно документации Apache Beam, я могу найти кодеры, специфичные для типа данных, а также...

Я запускаю потоковый конвейер в Apache Beam Python SDK.Когда я запускаю его из обработчика потока...

Невозможно соединить Cassandra с помощью драйвера jdbc, получающего ошибку java.sql.SQLException:...

Я создал очень простое задание Apache Beam для теста, оно написано в Scala и выглядит так: object...

Я пытаюсь запечь очень простой конвейер, который читает поток событий из Kafka (KafkaIO.read) и...

После этого ответа Интересно, каковы принципиальные различия (если таковые имеются) между...

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

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

Я пытаюсь прочитать записи из источника на основе общего количества обработанных записей, которое...

Мой вопрос вращается вокруг запуска вызова API, чтобы получить префикс файла для TextIO вывода. Вот...

Я использую AvroIO.<MyCustomType>writeCustomTypeToGenericRecords() для записи общих записей в...

У меня есть конвейер, который извлекает данные MySQL и используется для передачи данных в Монго БД...

Я столкнулся с проблемой, что "Невозможно предоставить кодировщик для org.apache.hadoop.hbase

Apache Beam TextIO можно использовать для чтения файлов JSON в некоторых файловых системах, но как...

Я пытаюсь написать конвейер Beam, который работает с использованием SparkRunner, читает из...

Я использую бегущий искровой разрядник в качестве бегунка трубопровода в Apache Beam и обнаружил...

Ниже приведено несколько вопросов о Apache Beam Windowing: У меня есть конвейер лучей, считывающий...