Я разрабатываю систему отказа от корзины для электронной коммерции.Система отправит сообщение...
Я читаю данные из ограниченного источника, файла csv, в пакетном конвейере и хотел бы назначить...
Мое имя файла содержит информацию, которая мне нужна в моем конвейере, например, идентификатор для...
Я пытаюсь выполнить простой подсчет количества прогонов в Apache Beam (Dataflowrunner), но мне...
Я устанавливаю медленно меняющуюся карту поиска в моем конвейере Apache-Beam.Он постоянно обновляет...
Я пытаюсь сделать запаздывающее обновление после того, как мой конвейер завершит, где таблицы...
Скажем, у меня есть данные key1 = [1, 2, 3] and key2 = [a, b, c], где a и b - значение ключа, а...
Я пытаюсь понять, как поток данных / Beam управляет состоянием. Например, при использовании потоков...
Dynamic Work Rebalancing оптимально распределит работу среди рабочих, где fusion свернет график...
В потоке данных SDK 2.4.0 я имел обыкновение запускать: PipelineOptionsFactory
Я прошу прощения за этот наивный вопрос, но я хотел бы получить некоторые разъяснения о том,...
Согласно следующей документации указано, что если вы не укажете явно триггер, вы получите поведение...
Моя компания получает данные о событиях в пакетном и потоковом режиме. Я хочу обрабатывать данные с...
Если атрибут отметки времени не назначен во время публикации или чтения, какая отметка времени...
У меня есть потоковый конвейер Beam / Dataflow. Мне нужно обновлять метаданные, чтобы элемент...
Какова цель org.apache.beam.sdk.transforms.Reshuffle? В документации цель определяется как:...
Я создаю пользовательский соединитель ввода-вывода в Java, который работает в потоковом режиме с 2
Поскольку я знаю, как запустить Apache Beam в задании Google Dataflow, я должен сначала установить...
Я хочу загрузить определенные файлы из временного местоположения до начала конвейера. Файлы .mmdb...
Учитывая, что потоковые вставки в BigQuery сопряжены с расходами, означает ли использование...
Мой конвейер лучей импортирует данные в большие запросы, и в последнее время он должен поддерживать...
Вот минимальный проект, который демонстрирует проблему https://github
У меня есть приложение для потоковой передачи Java-лучей, которое я развертывал в потоке данных.Я...
Как при запуске задания Dataflow в облаке Google можно настроить конвейер Dataflow на отправку...
Было бы хорошо, если кто-нибудь знает, как обновить записи таблицы BigQuery, используя Google Cloud...