Я использую 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 и из любопытства хотел бы задать вопрос ниже. Заранее я прочитал ниже...
Рассмотрим понятие входного потока переплетенных записей, представляющих взаимодействие с...