Я не нашел, как получить таблицы из указанного набора данных. Я хочу использовать Dataflow для...

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

Мне трудно понять, могут ли объединения в Apache Beam (например, http://www.waitingforcode

Мой конвейер Apache Beam принимает бесконечный поток сообщений.Каждое сообщение разветвляет N...

Читая об обработке потоковых элементов в Apache Beam с использованием Java, я наткнулся на...

Я получаю эту ошибку pickle.PicklingError: Выборка клиентских объектов явно не поддерживается

Я пишу код луча Apache, в котором мне нужно прочитать файл JSON, который был помещен в папку...

Я пишу код луча Apache для тестирования.Пожалуйста, ознакомьтесь с кодом ниже.Я создал образец...

Как определить обработанные файлы в задании потока данных?Я использую подстановочный знак для...

Я строю проект gradle java (см. Ниже), используя код Apache Beam и выполняю на Eclipse Oxygen....

В Apache Beam / Dataflow я считываю данные в коллекцию, используя следующий код: // read the...

Я пытаюсь создать шаблон потока данных Google, но не могу найти способ сделать это, не выдав...

Я пытаюсь использовать безопасные классы BigQuery. Я также установил intellij scio плагин . Но я...

Я анализирую потоковую обработку данных Apache Beam.Я работал над обработкой потоков Apache Kafka...

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

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

Я следую вместе с ответом на этот пост и документацию , чтобы выполнить динамическую оконную запись...

У меня есть задание потока данных на основе Apache-Beam для чтения с использованием vcf source из...

Итак, у меня есть работа с потоком данных, выполняющая p.apply(RedisIO.read()

private interface Options extends PipelineOptions { @Description("Path of the file to write...

Я вижу, что начиная с Apache Beam 2.2.0 есть источник и приемник RedisIO, но, кажется, просто...

Мы создаем конвейер, используя поток данных Google. Одним из наших случаев является вызов сторонней...

Я пытаюсь читать файлы с помощью Apache Beam на сервере Hadoop (не локальном). Проблема в том, как...

Постановка задачи: У меня есть две таблицы - Данные (40 столбцов) и LookUp (2 столбца). Мне нужно...

Я мигрирую из Dataflow SDK 1.x в 2.x, который использует Apache Beam. Код работает правильно, когда...