apache-beam

-1зной

1ответ

Когда луч apache будет выпущен как файл jar для добавления в зависимости от проекта в eclipse?

Когда луч Apache будет выпущен? Будет ли у него возможность подключаться к RDBMS оракула, чтобы делать ETL в своем первом выпуске?

3зной

3ответ

Как разрешить ошибку травления в классе apache_beam.internal.clients.dataflow.dataflow_v1b3_messages.TypeValueValuesEnum?

PicklingError возникает, когда я запускаю свой конвейер данных удаленно: конвейер данных был написан с использованием Beam SDK для Python, и я запускаю его поверх Google Cloud Dataflow. Трубопровод ра

0зной

1ответ

Apache-Beam исключение во время работы WordCount примера затмения

Загруженного Maven dependecies в затмении, используя <dependency> <groupId>org.apache.beam</groupId> <artifactId>beam-runners-direct-java</artifactId> <version>0.2.0-incubating</version></dependenc

1зной

1ответ

Как вы можете воспроизводить старые данные в поток данных через pub/sub и поддерживать правильную логику времени события?

Мы пытаемся использовать обработку времени независимости DataFlow, чтобы начать новую потоковую работу и воспроизводить все наши данные в него через Pub/Sub, но работают в следующей задаче: Первый эта

1зной

2ответ

JDBC Fetch from oracle with Beam

Следующая программа предназначена для подключения к Oracle 11g и получения записей. Как бы то ни было, это дает мне NullPointerException для кодера на конвейере.apply(). Я добавил ojdbc14.jar в зависи

1зной

1ответ

Выход Wordcount хранится в разных файлах

Выход WordCount хранится в нескольких файлах. Однако разработчик не имеет контроля над тем, где (ip, path) файлы остаются на кластере. В MapReduce API есть возможность для разработчиков написать прогр

3зной

2ответ

Как я могу упорядочить элементы в окне в python apache beam?

Я заметил, что java apache beam имеет класс groupby.sortbytimestamp, на котором у python реализована эта функция? Если бы не было способа сортировки элементов в окне? Я полагаю, я мог бы сортировать в

0зной

1ответ

Передача данных из хранилища данных Google в Bigquery с использованием потока данных в Python

У нас есть проблема с переходом данных из Google Cloud Datastore в Bigquery. Нам нужно создать сценарий потока данных в python для этого задания. Это задание должно передавать данные из хранилища данн