Это мой код: package hadoopPlayground; import java.io.BufferedReader; import org.apache.avro
Я пытаюсь использовать сливной коннектор Kafka s3 , используя confluent-4.1.1 . s3 раковина...
Я новичок в коллекционировании Divolte. После настройки для отслеживания пользовательских событий...
Я столкнулся с проблемой, у меня есть сгенерированный avro класс A и другой B, определенный...
У меня есть список объектов Avro, и я пытаюсь сериализовать их в json и записать их на диск. Вот...
У меня есть Java-класс pojo для сопоставления входящих данных с JavaObject, я относительно новичок...
У меня есть вопрос о SpecificAvroDeserializer, поскольку из-за имени класса я всегда предполагал,...
Мне известно, что BigQuery получает схему из самих данных и загружает файлы с разными схемами,...
Я использую spark и мне нужно применить файлы cdc из реплики базы данных к файлу паркета, как...
Я пытаюсь создать схему, которая содержит общую запись. Вот схема теста, которую я создал: {...
У меня есть много (относительно небольших) файлов AVRO с разными схемами, каждый в одном месте,...
Я - файл Avro из захвата концентратора событий, у которого есть свойство body, моя строка...
Я пытаюсь понять Avro Serialization на Confluent Kafka вместе с использованием реестра Schema.До...
У меня есть ByteArrayInputStream, который был сериализован с List<TestAvroModel>, который...
Я создал авросхему, используя SchemaConverter в scala / spark.Теперь мне нужно изменить некоторые...
Ниже приведена трассировка стека: Ошибка обработки запроса;Вложенное исключение: org.apache.kafka
Я извлекаю строку данных из таблицы в MSSQL, столбец имеет тип «BIT».В реестре схем этот столбец,...
Сценарий Я создаю концентратор событий 1 января 2018 года. Мой срок хранения концентратора событий...
Я изучаю основы больших данных для своей диссертации.Я сделал сканер, который загружает данные об...
Предположим, у меня есть файл Avro, и я хотел бы знать, как добавить новое поле / столбец, например...
Я начинаю свой проект с изучения авро вещей.Итак, чтобы проверить, я хочу преобразовать JSON в...
Имеется сжатый файл, написанный на платформе hadoop, в одном из следующих форматов: Avro Parquet...
Все, у меня возникли проблемы с совместным использованием ввода файла Logstash и кодека avro.Идея...
У меня есть следующий csv:...
Как сериализовать метку времени в поле Json в процессоре NiFi ValidateRecord / JsonRecordSetWriter....