Я пытаюсь использовать существующий пример кода Google (PubSubToBigQuery.java), чтобы...

У меня есть Задание облачного потока данных , которое записывает все в одну таблицу и одно...

Каково ожидаемое поведение maxTimestamp для глобального окна?У меня есть топология с неограниченным...

Я пытаюсь вызвать шаблон потока данных через REST API , однако, когда в теле указаны параметры ,...

У меня следующая топология, я не могу создать кодер для последнего шага, который KV[K,...

Я бы хотел выполнить следующее с помощью Apache Beam: вычислять каждые 5 секунд события, которые...

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

Я читаю данные из ограниченного источника, файла csv, в пакетном конвейере и хотел бы назначить...

Если данные поступают в различных форматах файлов в одном хранилище объектов.Должно ли это быть...

Мое имя файла содержит информацию, которая мне нужна в моем конвейере, например, идентификатор для...

Я пытаюсь выполнить простой подсчет количества прогонов в Apache Beam (Dataflowrunner), но мне...

Я делаю простой конвейер, используя Apache Beam в python (в потоке данных GCP) для чтения из PubSub...

Я устанавливаю медленно меняющуюся карту поиска в моем конвейере Apache-Beam.Он постоянно обновляет...

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

Я разработал образец конвейера лучей в Python, который получает некоторые данные из подписки pubsub...

Скажем, у меня есть данные key1 = [1, 2, 3] and key2 = [a, b, c], где a и b - значение ключа, а...

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

Я запускаю здесь пример настроения для преобразования тензорного потока.https://github

Dynamic Work Rebalancing оптимально распределит работу среди рабочих, где fusion свернет график...

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

В потоке данных SDK 2.4.0 я имел обыкновение запускать: PipelineOptionsFactory

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

Моя компания получает данные о событиях в пакетном и потоковом режиме. Я хочу обрабатывать данные с...

Если атрибут отметки времени не назначен во время публикации или чтения, какая отметка времени...

У меня есть потоковый конвейер Beam / Dataflow. Мне нужно обновлять метаданные, чтобы элемент...