Я хотел бы получить доступ к графическому объекту моего конвейера лучей apache, чтобы...
У меня есть конвейер A , который создает окна сеанса. Окна сеанса публикуются в PubSub < key, {...
Я конвертирую CSV-файл в XML-файл, используя Apache Beam и объект JAXB, TextIO.read () читает весь...
Я пишу преобразование GroupIntoBatches в Python, которое имитирует его аналог в JAVA. class...
Я работаю над потоковым конвейером Java Apache Beam (2.13.0), который работает в облачном потоке...
Я использую Spotify Scio для создания конвейера потока данных Scala, который запускается сообщением...
Я реализовал DataflowPythonOperator в моей Airflow DAG, и во время выполнения я получаю сообщение...
В документации Beam изложено, как обеспечить бегунов для удаленного выполнения зависимостями здесь...
Я пытаюсь написать преобразование луча, например util.py class GroupIntoBatches(PTransform): def...
Я бы хотел последовательно применять пользовательский RicherIndicatorCoder для моего класса дел...
Я использую Apache Beam 2.4.0 с Spark Streaming 2.3.1, чтобы просто прочитать тему kafka и написать...
У меня есть очень простой Beam Pipeline, который читает записи из темы Кафки и записывает их в тему...
В моей работе apache-beam я называю внешний источник, GCP Storage, это можно рассматривать как...
Обновлено : возможно ли окно потока данных на фазе сигналов . Например, есть поток метки времени,...
У меня есть структура папок типа year/month/day/hour/*, и я бы хотел, чтобы луч считывал это как...
Я хочу попробовать сессионные Windows на Apache Beam и LocalRunner с входными источниками Kafka или...
У меня есть очень простой конвейер лучей Apache, который применяет метод преобразования к каждому...
При записи простых записей в таблицу в Postgres (может быть любой дБ) в конце конвейера некоторые...
Beam поддерживает Cython, но нет инструкций по его использованию в приложении (https://beam.apache
Сбой десериализации большого KiePackage с java.io.OptionalDataException для большого количества...
Я получаю следующее исключение при чтении из неограниченного JMS-источника: avro.shaded.com.google
Я пытаюсь запустить свой код Beam на Spark для POC.Я запускаю приложение в Google Cloud Dataproc...
Я пытаюсь интерполировать (вперед-заполнить) значения таблицы. input: таблица BigQuery с n + 1...
Я строю конвейер с помощью Beam Python.У меня есть поток событий, поступающих из PubSub с userId и...
Я надеюсь, что кто-то сможет прояснить связь между TensorFlow и его зависимостями (Beam, AirFlow,...