Я использую библиотеку Spotify Scio для написания конвейеров Apache Beam в Scala. Я хочу рекурсивно...

sbt застревает при попытке скомпилировать этот проект (snowplow/snowplow, ветвь sbt_issue) и выходит...

В последнее время в моих журналах вакансий в представлении сведений о работе много записей, таких...

Я пытаюсь использовать набранные bigquery api, как показано на scio веб-сайте : @BigQueryType

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

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

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

Я пытаюсь начать работу с Scio, и я использовал их стартовый проект giter8. https://github

Мы используем com.spotify.scio.testing.JobTest для сквозного тестирования нашего конвейера scio....

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

У меня есть файл .txt в качестве входных данных для моего проекта по программированию луча с...

Я пытаюсь экспортировать потоки Cloud Pub / Sub в Cloud Storage, как описано в этом сообщении от...

Я хочу реализовать следующий сценарий с использованием потокового конвейера в Apache Beam (и запуск...

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