avro

3зной

1ответ

При определении декодера, который должен быть предоставлен классам DatumReader, существует возможность повторного использования декодера, как вы можете видеть ниже. Как упоминалось в документе, класс

0зной

1ответ

Можем ли мы использовать «oneOf» в Regy Schema Registry Registry?

У меня есть случай изменения баланса пользователя. Я хочу поместить все события баланса пользователя в одну тему. Но изменения баланса пользователя происходят из-за множества событий, таких как рефера

2зной

1ответ

Spark Avro для паркета, пишущего нулевые значения в числовых полях

Я сохраняю блок данных искры в качестве файла паркета, а в DataFrame строятся строки, созданные из объекта avro. Точный код для него здесь: https://stackoverflow.com/a/41491999/2440775 Задача, с котор

1зной

1ответ

Как десериализовать файл Avro с помощью Джексона?

Avro может хранить партии сериализованного объекта в одном файле («файл контейнера объекта»). Avro поддерживает десериализацию для создаваемых avro классов Java или объектов java-bean-style, которые,

14зной

2ответ

Почему Spark хуже работает при использовании сериализации Kryo?

Я включил сериализацию Kryo для моей работы Spark, включил параметр, требующий регистрации, и обеспечил регистрацию всех моих типов. val conf = new SparkConf() conf.set("spark.serializer", "org.apach

0зной

1ответ

Что это за ошибки? (avro)

What are these errors ? /home/pi/try/client/c/libs/kaa/src/kaa/gen/kaa_logging_gen.c:93:9: error: too many arguments to function ‘avro_binary_encoding.read_char’ avro_binary_encoding.read_char

0зной

1ответ

springxd - невозможно десериализовать [имя_класса] Класс не найден

Я столкнулся с этой проблемой, сохраняя данные из ESB JMS Queue в HDFS в avro, используя springxd. Я создал пользовательский процессор для синтаксического анализа входящего XML из очереди JMS и преобр

0зной

1ответ

Ошибка выполнения, код возврата 1 из org.apache.hadoop.hive.ql.exec.DDLTask. Не удалось проверить serde: org.apache.hadoop.hive.serde2.avro.AvroSerde

Я создаю таблицу улья, используя avro serde для хранения данных Twitter. Вот код- create table tweets row format serde 'org.apache.hadoop.hive.serde2.avro.AvroSerde' stored as inputform

0зной

2ответ

Преобразование данных в паркет в Spark

У меня есть некоторые устаревшие данные в S3, которые я хочу преобразовать в формат паркета, используя Spark 2, используя Java API. У меня есть желаемая схема Avro (файлы .avsc) и их сгенерированные к