Я пытаюсь прочитать значение метки времени сообщения Pubsub из Apache Beam. p.apply("Read...

Я настроил локальную (java) среду для запуска Apache Beam Pipeline, следуя официальному doc ....

Я пытаюсь построить следующий пример потоковой передачи Pub / Sub на BigQuery: https://github

У меня есть Java Iterable объект, Iterable records.И я хочу передать его на конвейер Beam.Я пытался...

У нас есть задание Apache Beam, которое считывает данные из Big Query и преобразует их в POJO перед...

При локальном запуске моего конвейера Beam все работает как положено, но при попытке запустить его...

Обзор Я следовал следующему руководству, чтобы написать TF Records, где я использовал tf.Transform...

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

Я пытаюсь написать приложение для приема пищи на GCP с использованием Apache Beam. Я должен...

Мне нужно отложить обработку или публикацию имен файлов (файлов).Я ищу лучший вариант. В настоящее...

Мы начали использовать Dataflow для чтения из PubSub и Stream в BigQuery.Поток данных должен...

Я хочу написать конвейер DataFlow, который будет принимать сообщения от GCP Pub / Sub, но только до...

Я только начал изучать Apache Beam.Вот пример wordCount: https://beam.apache

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

Я пытаюсь добиться точной однократной доставки с использованием Google Dataflow и PubSub с...

У нас есть конвейер Apache Beam, и нам нужно выполнить несколько запросов BeamSql. Запросы не...