У меня есть данные в формате значения ключа.Я создал сумку для сумок, а затем фрейм данных из этой...
Я хочу создать Schema из Class, но отбрасывать поля пришли из его родительского класса.Возможно ли...
Можно ли располагать поля на карте в схеме Avro в определенном порядке.Я попытался использовать...
У меня есть несколько авромасел и соответствующие структуры codec_traits .Я использую libserdes +...
Я пытаюсь обработать файл и затем сохранить его в формате файла avro, используя метод...
Я использую Avro для создания класса.Вот мой код в продюсере выглядит так: TweetInfo tweetInfo =...
У меня есть тема кафки, в которой есть сообщения без авро-схемы.Недавно мы хотим отправить...
Я использую com.databricks.spark.avro.Когда я запускаю его из spark-shell следующим образом:...
Я вижу следующую ошибку exception Unsupported Avro type. Supported types are null, Boolean, Integer...
Я работаю над фреймворком, который может принимать входные данные в виде набора файлов,...
У меня есть XML-файл и XSD-файл в качестве входных данных.Идеальной целью является сериализация...
Я пытаюсь проанализировать некоторые данные в Nifi (1.7.1) с помощью процессора UpdateRecord
Я хочу создать схему Avro, которая будет иметь имена столбцов 123 или 342 и т. Д. Я попытался...
Я тестирую Spark 2.4.0 новые функции from_avro и to_avro. Я создаю фрейм данных только с одним...
Я пытаюсь найти способ / помощника для преобразования .Net Class в Avro.Generic.GenericRecord.В...
Я использую блоки данных spark-avro для преобразования схемы данных в схему avro. Возвращенная...
Я создал секционированную таблицу Hive, используя следующий запрос CREATE EXTERNAL TABLE...
Теперь, когда Spark 2.4 имеет встроенную поддержку формата Avro, я рассматриваю возможность...
У меня есть схема авро: { "namespace":"nifi",...
У меня есть требование для потоковой передачи, когда мне нужно преобразовать GenericRecord в...
Попытка использовать confluent_kafka.AvroConsumer для получения сообщений с заданной отметкой...
СБОЙ: RuntimeException MetaException (сообщение: org.apache.hadoop.hive.serde2.SerDeException...
Я использую песочницу maprR для тестирования различных настроек в кустах и MaprF.Я получил в...
Я посылаю сообщение Avro с отметкой времени (Int64 - тип long) и несколькими данными (тип String) в...
Исходя из моего понимания Производитель: При первом вызове локальный кеш реестра схемы пуст. Затем...