ParameterTool parameterTool = ParameterTool.fromArgs(args); Properties kafkaProperties = new...
Я пытался загрузить данные с типом данных avro в кирпичи данных, используя формат "com.databricks
Требование: У меня есть приложение, выдающее данные AVRO (около 100 ГБ в час). Я хочу создать...
У меня есть файл JSON.Я ищу любую программу / инструмент, который помогает генерировать схему AVRO...
Получение сообщений из pubsub и последующее сохранение их в почасовых или других интервальных...
Я хочу создать авро-сообщение для каждой записи (csv) с заголовком метаданных, т.е. с вложенной...
Я создал таблицу в схеме Avro. Вот сценарий создания. CREATE TABLE `old_db.MyTable`( `fileld1`...
В соответствии с моими требованиями я бы хотел явно зарегистрировать Avro Serializer для конкретных...
Я использую spark 2.3.1 и kafka 0.10 с приведенными ниже зависимостями: kafka-avro-serializer-3.2.1
Я использую проверочную запись Apache Nifi, используя схемы Avro для вложенного Json.У меня...
Я не могу перейти на Spring 5, поэтому я застрял с spring-kafka 1.3 и его ограниченной обработкой...
У меня есть данные AVRO со следующими полями, где create_at & updated_at - это столбец TIMESTAMP,...
Я изо всех сил пытался получить свои данные из Azure Event Hub в SQL-таблицу на Snowflake-платформе
Я пытаюсь создать внешнюю таблицу в BigQuery, но при этом получаю следующее исключение: Error while...
Основная цель - объединить две темы Кафки, одну - сжатые медленно движущиеся данные, а другую -...
Я пытаюсь сгенерировать схему Avro из Java, чтобы описать таблицу, к которой я могу получить доступ...
Почитав об Apache Flume и его преимуществах в обработке клиентских событий, я решил, что пришло...
У меня есть устройства, которые отправляют сообщения в IOT Hub.Я использую маршрутизацию функцию...
Я пытаюсь прочитать файл avro с помощью моего пользовательского файла схемы avro, но получаю...
Можем ли мы генерировать конечные точки, используя файлы avro idl или avpr?если возможно, могу ли я...
У меня проблемы с анализом моей схемы AVRO JSON.Я пытаюсь использовать функцию avro.ParseSchema из...
Я пытаюсь читать авро-сообщения от Кафки, используя PySpark 2.4.0. Внешний модуль spark-avro может...
Предположим, у меня есть следующая схема в таблице csv или sql: id (INT) content_type (VARCHAR)...
Я пытаюсь добавить аннотацию Java в мой файл avro idl (файл avdl).И я не могу понять, как...
Я не могу найти инструмент для проверки, соответствуют ли схемы avro спецификации avro.Как я могу...