Я получаю неожиданную ошибку, когда пытаюсь использовать выходные данные beam.combiners.ToList в...

Я пытался запустить пример луча Python-SDK, но у меня были проблемы с чтением ввода. https://cwiki

Мне нужно выполнить запросы на пучок SQL и в конце записать результат в BigQuery. У меня есть...

Я пишу конвейер Beam для запуска произвольного кода Pandas в коллекции CSV. Это должно выполняться...

Есть ли в python коннектор потоков Kinesis для apache Flink? В документации явно не сказано, что...

Можно ли программно вызвать контрольную точку в Beam DoFn? Как мне это сделать? p.s. Мне нужно...

У меня есть файл .txt в качестве входных данных для моего проекта по программированию луча с...

Все примеры окон, которые я вижу, включают определение окон.Например, падающие 1-минутные окна или...

Мы пытаемся создать приложение, используя BEAM в качестве нашего API преобразования. В настоящее...

Я хочу отправить сообщение Кафке и прочитать его без автоматической фиксации. Я отправляю такие...

Я пытаюсь прочитать набор файлов XML в конвейер Apache Beam. Некоторые элементы имеют пространства...

Обновление Apache Beam Python SDK до версии 2.11.0. Я обновляю sdk с 2.4.0 до 2.11.0, используя...

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

Для построения запросов потоковой обработки было рекомендовано (одним из членов команды), чтобы мы...

Мое приложение apache beam получает сообщение в массиве JSON, но вставляет каждую строку в таблицу...

Имеет ли Apache Beam для Python поддержку Flink Runner прямо сейчас? или даже портативный бегун? И...

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

Моя проблема в следующем, я хочу объединить некоторые данные, которые хранятся на S3.В качестве...

Попытка скомпилировать и использовать снимок для Apache Beam Cassandra JAR. Похоже, что сборка не...

Мне нужно подключить SAP HANA к большому запросу с использованием Apache Beam. Любой использовал...

У меня есть требование прочитать таблицу BQ, применить преобразование и загрузить его в другую...

Я получаю следующую ошибку при запуске примера кода Streaming Wordcount из GitHub. Это происходит...

Краткий вопрос: Поскольку Tensorflow движется в направлении Keras и от Оценщиков, как мы можем...

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

Я создал программный продукт, использующий GCP Pub / Sub в качестве очереди сообщений, Apache Beam...