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

Я новичок в Apache Beam. Я пытаюсь прочитать данные из Кафки, используя KafKaIO согласно...

В общем, идея состоит в том, чтобы прочитать файл паркета (который возвращает PCollection), сделать...

Я пытаюсь построить rowFilter, используя объект rowKeyRegexFilter. Как получить строковое значение...

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

Я создаю Bazel Python проект, который зависит от apache_beam SDK. В файле WORKSPACE моего проекта я...

Я хочу использовать данные из потока Kafka и записать их в MySQL, используя Apache Beam....

У меня есть TableResult, я хочу повторить его и поместить ключ и его значение в Hashmap. Я могу...

У меня есть много IoT-устройств, которые отправляют сообщения с переменной скоростью.Используя эти...

Поиск кода Java луча - Переместите исходные файлы в другую папку GCS после выполнения действий...

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

Результатом преобразования Apache-Beam GroupByKey.create () является PCollection . Когда я запускаю...

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

Результатом преобразования Apache-Beam GroupByKey.create () является PCollection . Когда я пытаюсь...

Я переношу код конвейера Apache Beam с Python 2 на Python 3. У меня есть тест конвейера Beam,...

Я использую StateSpec в луче и запускаю его с помощью Spark Runner Я получаю следующую ошибку...

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

Я принимаю данные (файл json) через Pub / sub. Поэтому мое время события по умолчанию - это время...

Я новичок в Dataflow, так что простите меня, если мой вопрос смешной, у меня есть csv-файл, который...

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

Использование фиксированной Windows в Apache Beam.Водяной знак устанавливается по времени события....

Я хочу, чтобы выходные данные моего конвейера Beam (на Java) записывались на другой сервер через...

У меня есть конвейер Apache Beam, написанный на Java, где я хотел бы прочитать данные, поступающие...

Как я могу прочитать все файлы паркета, хранящиеся в HDFS, используя Apache-Beam 2.13.0 Python SDK...

У меня есть PCollection<KV<String,String>> Pcol, я обрабатываю каждый элемент в методе...