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

Кто-нибудь пробовал читать / записывать файл Parquet, используя Apache Beam. Поддержка добавлена...

Хит проблемы с помощью GroupByKey, и я считаю, что это отследить до проблемы типа. Я смотрел на это...

Я пытаюсь запустить apache beam sdk 2.4 и библиотеки com.google.cloud.bigquery, но исключение...

В настоящее время я пытаюсь разработать конвейер потока данных для замены некоторых разделов...

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

Я использую KafkaIO.read(), и я хотел бы начать потреблять с определенного смещения. В какой-то...

У меня есть следующий запрос: SELECT DISTINCT Summed, ROW_NUMBER () OVER (order by Summed desc) as...

быстрый вопрос.Я пытаюсь представить метрики луча в Прометея.Я сделал это в своем коде: Counter...

Я ищу кого-то, кто предоставил бы рабочий пример использования преобразования Apache beam Combine

Я читаю документацию по лучу Apache и понимаю, что это единая модель программирования лучей, "пакет...

Я пытаюсь прочитать и проанализировать файл JSON в коде Apache Beam. PipelineOptions options =...

Мне дан URL-адрес облака Google.Я должен: Использовать URL-адрес для получения списка больших...

Apache Flink поддерживает итеративные преобразования: https://ci.apache

В настоящее время я нахожусь в процессе разработки конвейера с использованием Apache Beam с Flink в...

У меня есть преобразование, которое выводит тип с подстановочным знаком: Feature<? extends...

От: https://github.com/spotify/scio/wiki/Scio-data-guideline "Предпочитайте комбинировать /...

У меня есть коллекция записей, для простоты скажем следующее (через запятую): A1, B1, C1 A1, B1,...

Я относительно новичок в Python и Beam, и я следил за Apache Beam - Python Quickstart ( здесь ) до...

Я передаю сообщения из темы Kafka, используя KafkaIO API https://beam.apache