Я пытаюсь следовать шаблону разработки для медленно изменяющегося кэша поиска (https://cloud.google

Я пытаюсь запустить очень простую программу в Apache Beam, чтобы проверить, как она работает....

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

Для каждой новой записи пользователя в таблице BigQuery я должен отправить электронное письмо этому...

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

Получение сообщений из pubsub и последующее сохранение их в почасовых или других интервальных...

Скажем, я хочу вычислить среднее значение определенного показателя за последние 10 минут после...

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

Основная цель - объединить две темы Кафки, одну - сжатые медленно движущиеся данные, а другую -...

Согласно документации Apache Beam, я могу найти кодеры, специфичные для типа данных, а также...

Моя цель - проверить мои данные в BQ, используя тензор потока-проверки данных для моей среды...

Я изучал руководства Beam KafkaIO и пытался найти документацию по аутентификации клиента kafka, но...

Я хочу обработать данные из объекта org.apache.spark.sql.Dataset, которые я получаю из spark.sql...

У меня есть многофайловое Python Apache Beam, которое я хочу запустить в облаке Dataflow через...

Я использую код PubSubToBigQuery.java без каких-либо изменений.Кто-нибудь, пожалуйста, покажите мне...

У меня есть простой конвейер, который преобразует события из Кафки в Большой запрос.Я хочу...

Невозможно соединить Cassandra с помощью драйвера jdbc, получающего ошибку java.sql.SQLException:...

Я ищу работу с потоком данных с помощью apache beam python SDK, который просто подсчитывает...

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

Я использую Beam 2.9.0 для записи файлов Avro в несколько каталогов.У меня есть некоторый класс...

Мой конвейер постоянно выдает ошибки OOM, поэтому я читаю следующий ответ и пытаюсь установить...

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

В моей новой новой виртуальной среде. Я запускаю pip search apache-beam Я получил apache-beam (2.9

Почему классы, определенные в вашем главном файле конвейера луча apache, не могут быть использованы...

Я пытаюсь запустить PubSubToBigQuery.java локально, используя https://github