avro

5зной

4ответ

Deserialize файл Avro с C#

Я не могу найти способ десериализации файла Apache Avro с C#. Файл Avro - это файл, созданный Archive feature в концентраторах событий Microsoft Azure. С Java я могу использовать Avro Tools из Apache,

c# azure hadoop avro 2016-10-04

---

2зной

1ответ

искры потоковой другого декодера стоимости на KAFKA тему

мне нужно создать искру потоковое видео, который считывает из несколько темы, и использует другой декодер по каждой теме (каждая тема содержит различный Авро-закодированный obect): def decode_avro(mes

python apache-spark apache-kafka avro 2016-10-04

---

2зной

1ответ

Схема таблицы улей Avro не обновляется после настройки свойств таблицы от avro.schema.literal до avro.schema.url

Сначала я согнул таблицу Avro Hive, как показано ниже. CREATE EXTERNAL TABLE user STORED AS AVRO LOCATION '/work/user' TBLPROPERTIES ('avro.schema.literal'='{"type":"record","name":"user", "fields"

hadoop hive schema avro 2016-10-08

---

0зной

1ответ

Что такое "Класс <R> recordClass" в JavaInputDStream?

Я пытаюсь использовать ниже API для Spark streaming с Kafka. Я должен передавать данные, связанные с сериализацией avro с помощью искры, данные находятся в Кафке. static <K,V,KD extends kafka.serializ

java apache-spark apache-kafka spark-streaming avro 2016-10-10

---

1зной

1ответ

как правильно преобразовать Avro схемы в JSon схеме

У меня есть следующий объект JSON данные: { "name": "John", "favorite_number": 5, "favorite_color" : "green" } Схема JSON для этого объекта выглядит следующим образом: { "$schem

java json avro jackson-dataformat-avro 2016-10-12

---

0зной

1ответ

AttributeError: «ул» объект не имеет атрибута «расшифровывать» при чтении из AVRO с помощью Python

from avro import io, datafile import pprint OUTFILE_NAME = "demo.avro" rec_reader = io.DatumReader() df_reader = datafile.DataFileReader(open(OUTFILE_NAME, 'r'), rec_reader) pp = pprint.PrettyPri

python avro 2016-10-22

---

0зной

1ответ

Использование нескольких десериализаторов для потребителя кафки

Я новичок в kafka и даже сериализации. до сих пор мне приходилось обрабатывать кафкинские события формата json, сериализованные с использованием простого кода. но теперь добавляются дополнительные соб

java serialization properties avro kafka-consumer-api 2016-10-24

---

3зной

1ответ

Kafka Stream от JSON до Avro

Я пытаюсь использовать поток Kafka для преобразования темы с сообщениями String/JSON в другую тему как сообщения Avro. поток Основной метод: streamsConfiguration.put(StreamsConfig.KEY_SERDE_CLASS_CONF

json apache-kafka avro apache-kafka-streams 2016-10-28

---