Мне нужно регулярно запускать конвейер потока данных. FAQ для Dataflow гласит следующее: Вы можете автоматизировать выполнение конвейера с помощью Google App Engine или настраиваемых (CRON) процессов заданий на GCE. В будущих выпусках SDK...

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

Луч Apache, похоже, отказывается распознавать Iterable Котлина. Вот пример кода: @ProcessElement fun processElement( @Element input: KV<String, Iterable<String>>, receiver: OutputReceiver<String> ) { val output =...