Я использую Google Dataflow с шаблонами: шаблон развертывается в GCS сервером CI (Continuous...

Я нахожусь в процессе написания простого теста для проверки семантики ранних / своевременных /...

Попробуйте использовать BeamSQL для удаления вложенного типа PCollection.Предположим, что...

Я использую Google Cloud Data Runner с шаблонами и передаю ему конфиденциальную информацию через...

Моя цель - сравнить латентность и пропускную способность Apache Beam в сценарии использования...

пытается прочитать файл CSV размером 10+ ГБ, используя apache beam FileIO в задании потока данных,...

Используется ли теперь опцией numberOfWorkerHarnessThreads облачный бегун потока данных? Ранее...

Я пытался реализовать SQL для двух наборов данных в облачном хранилище Google, используя Apache...

Я хотел бы сравнить результаты работы моего конвейера.Получение различий между jsons с одной и той...

У меня возникла проблема при попытке запустить конвейер GCP Cloud-Dataflow. Конвейер работает при...

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

Я хотел бы установить таймер во время события, которое срабатывает на основе наименьшей отметки...

Я вижу все типы странных ошибок при выполнении задания потока данных (Луч 2.12). Задание в основном...

У меня есть PCollection, который, я уверен, содержит: "Боб" "Джон" "Фред" Однако, когда я проверяю...

Прочитав Своевременная (и с учетом состояния) обработка с использованием Apache Beam и просмотрев...

Я создаю конвейер в потоке данных (луч Apache) для чтения и записи данных в Google BigQuery, однако...

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

При использовании BeamSQL в конвейере потока данных (javacode), после применения SQLTransform.query...

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

Я написал этот конвейер, но когда я запускаю его как jar, он не может найти прямого бегуна, когда...

У меня есть конвейер, который создает граф потока данных (сериализованное представление JSON),...

У меня та же проблема, что и у Github: GoogleCloudPlatform / DataflowJavaSDK # 220 Если я пытаюсь...

Это пример придуманной игрушки, чтобы попытаться получить помощь по сложным частям моей проблемы....

Я сейчас учусь apache beam и из любопытства хотел бы задать вопрос ниже. Заранее я прочитал ниже...

Рассмотрим понятие входного потока переплетенных записей, представляющих взаимодействие с...