Какова цель org.apache.beam.sdk.transforms.Reshuffle? В документации цель определяется как:...

Я создаю пользовательский соединитель ввода-вывода в Java, который работает в потоковом режиме с 2

Я работаю над синтаксическим анализом файла CSV в apache beam python. Однако, когда в CSV-файле...

Я использую конвейер луча apache и хочу выполнить пакетную вставку в bigquery с помощью python. Мои...

Поскольку я знаю, как запустить Apache Beam в задании Google Dataflow, я должен сначала установить...

Я хочу загрузить определенные файлы из временного местоположения до начала конвейера. Файлы .mmdb...

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

Учитывая, что потоковые вставки в BigQuery сопряжены с расходами, означает ли использование...

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

Вот минимальный проект, который демонстрирует проблему https://github

У меня есть приложение для потоковой передачи Java-лучей, которое я развертывал в потоке данных.Я...

Может показаться глупым, но это мой самый первый пост здесь.Извините, что сделал что-то не так. В...

Как при запуске задания Dataflow в облаке Google можно настроить конвейер Dataflow на отправку...

У меня есть конвейер потока данных, в котором я использую приведенный ниже метод AvroIO для чтения...

Было бы хорошо, если кто-нибудь знает, как обновить записи таблицы BigQuery, используя Google Cloud...

Итак, моя лучевая работа сегодня закончилась этим предупреждением: / usr / local / lib / python2.7...

SDK: Apache Beam SDK для Go 0.5.0 Мы выполняем задания Apache Beam Go SDK в облачном потоке данных...

Я пытаюсь построить конвейер потока данных для преобразования объекта AVRO, ниже приведен код...

Я передаю строку соответствия wilcard как gs: // dev-test / dev_decisions-2018-11-13 * /.И я...

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

SDK: Apache Beam SDK для Go 0.5.0 Наша работа на Golang в течение нескольких недель успешно...

Мне нужно прочитать файл AVRO из облачного хранилища, а затем записать запись в большую таблицу с...

У меня есть следующий рабочий процесс для пакета потока данных: Обновление кода в шаблоне (основной...

В документации Beam рекомендуется использовать withLogAppendTime вместо withProcessingTime.Почему...

Было бы хорошо, если кто-нибудь знает о том, как обрезать таблицу MySQL в потоке данных Google...