Вопросы с тегом google-облако-поток-данных

0 голосов

1 ответ

GCloud Dataflow воссоздает таблицу BigQuery, если она удаляется во время выполнения задания

Kodin / 21 марта 2020

0 голосов

0 ответов

Заставить луч / узел потока данных Create.of (List <String>) выдавать ровно количество элементов в списке

nsandersen / 21 марта 2020

0 голосов

1 ответ

Bigquery, как удалить записи из потока данных

user3066281 / 19 марта 2020

0 голосов

1 ответ

Используйте fastavro при чтении из BigQuery с использованием Apache Beam / Dataflow

Cethy / 19 марта 2020

0 голосов

0 ответов

Почему конвейер потока данных GCP выдает Python UnicodeDecode Error?

Claudio Davi / 19 марта 2020

0 голосов

1 ответ

Последовательное выполнение в Apache Beam - Java SDK 2.18.0

SarfarazSoomro / 19 марта 2020

0 голосов

0 ответов

Входные коллекции Google Cloud Dataflow количество добавленных элементов не соответствует количеству элементов, вставленных в BigQuery?

eagerbeaver / 18 марта 2020

0 голосов

0 ответов

Apache Beam GroupByKey не производит вывод

O Bishop / 18 марта 2020

0 голосов

1 ответ

Apache Beam: чтение в PCollection как PBegin для конвейера

user8811409 / 18 марта 2020

0 голосов

1 ответ

Поток данных: использование beam.combiners по результатам предыдущего beam.combiners

Philip M / 18 марта 2020

0 голосов

2 ответов

Как программно убить задание Beam Dataflow от рабочих

PetrosP / 18 марта 2020

0 голосов

1 ответ

Поток данных читается из topi c PubSub и записывается в Bigquery (несколько таблиц)

user3066281 / 18 марта 2020

1 голос

2 ответов

Эффективная настройка ParDo или start_bundle для бокового ввода

Thijs / 17 марта 2020

0 голосов

1 ответ

JOB в Dataflow с использованием функции

Alan Batista / 17 марта 2020

1 голос

1 ответ

Ошибки зависимости при запуске Apache Beam с Kafka

Jonny5 / 16 марта 2020

1 голос

1 ответ

Apache Воздушный поток: динамический c интервал времени, основанный на времени выполнения

Diego / 16 марта 2020

0 голосов

1 ответ

Apache Beam / Dataflow ReShuffle устарел, что использовать вместо этого?

gogstad / 16 марта 2020

1 голос

1 ответ

SpannerIO java .lang.IllegalStateException: сортировщик должен быть нулевым здесь

KlaaTh / 12 марта 2020

1 голос

1 ответ

JAVA - Apache BEAM-GCP: GroupByKey отлично работает с Direct Runner, но не работает с Dataflow runner

Oumab10 / 11 марта 2020

1 голос

0 ответов

Ошибка при установке apache -beam [gcp] на терминал ma c zsh - «zsh: совпадений не найдено: apache -beam [gcp]»

Sadeeq Akintola / 11 марта 2020

1 голос

1 ответ

Объединить PCollection с apache_beam

Elon Salfati / 10 марта 2020

0 голосов

1 ответ

Является ли apache -beam хорошим выбором, когда порядок записи событий должен сохраняться при записи в сток?

allen / 10 марта 2020

1 голос

1 ответ

Выполняет потоковую передачу данных из Pub / Sub в BigQuery с использованием Dataflow и Apache Beam (Python)

Davis / 10 марта 2020

0 голосов

1 ответ

Какое преобразование использовать в Dataflow для объединения файлов CSV с разными столбцами при загрузке их в BigQuery?

jar / 10 марта 2020

0 голосов

1 ответ

Как обеспечить скорость вставки 1 вставка в секунду при использовании ClickhouseIO

Oleksandr Bushkovskyi / 10 марта 2020