Вопросы с тегом apache--beam

0 голосов

1 ответ

Избегайте двойных кавычек с помощью двойной кавычки

BSpinoza / 06 августа 2020

1 голос

2 ответов

Apache Avro генерирует неправильную схему Avro из Java POJO с @AvroSchema

gixen / 06 августа 2020

0 голосов

1 ответ

Apache Бегунок искры / мигания луча не запускается в EMR (файлы доступа из GCS)

user3483651 / 05 августа 2020

1 голос

1 ответ

Прочтите файл CSV, очистите его, затем запишите результат в формате CSV, используя поток данных Apache Beam

BSpinoza / 04 августа 2020

0 голосов

0 ответов

Размер состояния контрольной точки Flinks RocksDB растет и никогда не уменьшается

aditya kumar / 03 августа 2020

0 голосов

2 ответов

Можно ли выполнить некоторый код, такой как ведение журнала и запись метрик результатов в GCS, в конце пакетного задания потока данных?

user2179539 / 03 августа 2020

0 голосов

1 ответ

Apache Beam: как решить «ParDo требует детерминированного c ключевого кодировщика для использования состояния и таймеров» при использовании функции дедупликации

kylebutters / 02 августа 2020

0 голосов

1 ответ

Активировать элементы ровно один раз, используя фиксированное окно с Apache Beam

kylebutters / 02 августа 2020

1 голос

0 ответов

Подключиться к экземпляру Google Cloud SQL из GCP Dataflow (ml метаданные)?

Zarkopafilis / 14 июля 2020

0 голосов

1 ответ

RemoteEnvironment нельзя использовать при отправке программы через клиента или при запуске в контексте TestEnvironment.

Akul Sharma / 13 июля 2020

0 голосов

1 ответ

Как развернуть воркера потока данных Google с файлом, загруженным в память?

enzed01 / 10 июля 2020

0 голосов

0 ответов

Как работает концепция контрольных точек / отказоустойчивости в балке apache?

Akul Sharma / 09 июля 2020

1 голос

2 ответов

Beam - функции для запуска только один раз в начале и в конце трубопровода Beam.

SamsonStannus / 09 июля 2020

0 голосов

0 ответов

Обработка сгруппированных данных в потоке данных занимает больше времени

user_a27 / 08 июля 2020

0 голосов

1 ответ

как указать брокеров kafka с KafkaIO в Apache Beam

artofdoe / 20 июня 2020

0 голосов

1 ответ

Шаблон луча для потока данных не будет загружен в корзину

gixen / 19 июня 2020

1 голос

1 ответ

Конвейер потоковой передачи Beam не записывает файлы в корзину

gixen / 17 июня 2020

0 голосов

0 ответов

Обработка исключений с помощью Apache Beam и GCP PubSub

IoT user / 17 июня 2020

0 голосов

2 ответов

Как выбрать набор полей из входных данных как массив повторяющихся полей в луче SQL

Shashank Kamath / 29 мая 2020

0 голосов

1 ответ

Вход Pub / Sub в шаблонном потоке данных полностью игнорирует NestedValueProvider

Kapitalny / 26 мая 2020

0 голосов

0 ответов

Beam Java Dataflow, Bigquery streaming insert GroupByKey сокращающие элементы

LPD / 26 мая 2020

0 голосов

1 ответ

Apache DoFn с разделением лучей не распределяет работу между несколькими рабочими потоками данных

ROSS XIE / 26 мая 2020

0 голосов

1 ответ

Apache Beam Combine vs GroupByKey

ericVE / 09 мая 2020

0 голосов

2 ответов

Чтение задания Cloud Dataflow из одного проекта BigQuery и запись в другой проект BigQuery

Alex / 08 мая 2020

0 голосов

0 ответов

Возможно ли чтение с сервера Microsoft SQL в качестве источника и приемника данных в PostgreSQL с помощью Apache Beam?

Chairul / 08 мая 2020