Я пишу потоковое приложение Apache Flink, которое десериализует данные (в формате Avro),...

Я создаю приложение Apache Flink в Scala, которое считывает потоковые данные с шины Kafka, а затем...

Мне нужно подумать, как записать мои данные в Hadoop. Я использую Spark, я получил сообщение из...

Я пытаюсь преобразовать GenericRecord в строку json, чтобы я мог передать ее что-то вроде...

У меня есть Kafka Producer, который отправляет записи Avro в «тестовую» тему. У меня также есть...

У меня есть тема Kafka Avro, созданная с помощью KafkaAvroSerializer. Мои автономные свойства, как...

private static final String json = "{" + "\"name\":\"Frank\"...

Как описано в Spark Structured Streaming с интеграцией Hbase , мне интересно записывать данные в...

Я пытаюсь прочитать несколько файлов с помощью Spark Файлы являются файлами avro и хранятся в...

Я пытаюсь загрузить содержимое файла avro в виде строки в Java (Eclipse), чтобы я мог его...

Есть ли способ получить полезную информацию о проблемах схемы avro? Я пытаюсь сделать следующую...

Я пытаюсь создать сложную запись AVRO с типом записи члена, поддерживаемым типом данных Union. {...

KStream<String, String> left = builder.stream("source1"); left

Я создал таблицу (test_load) на основе схемы другой (test).Затем я вставил test_load в другую...

Для производителя Kafka Avro я запускаю: ./kafka-avro-console-producer --broker-list localhost:9092...

Q1: скажем, я загружаю закодированные данные Avro, используя инструмент загрузки BigQuery.Теперь...

Можно ли использовать avro DataFileWriter с реестром схемы?

Я использую схему Avro, но я не уверен, как указать диапазон для конкретной записи. {...

Мы используем Kafka, Avro и Avro Schema Registry.Учитывая набор тем, которые я хочу использовать,...

Я пытаюсь преобразовать это значение 1520200800049 в Avro.Это спецификация поля в моей схеме,...

У меня есть некоторые сериализованные данные AVRO (сочетание печатных и непечатаемых символов) в...

Я выполнил операции объединения двух kstream, которые состоят из данных формата avro, а затем мой...

Я пытаюсь интегрировать Avro и Schema Registry в наши конвейеры данных Kafka.Теперь он выглядит...

Я знаю, что Avro - это очень быстрая система сериализации и десериализации данных.Это также...

У меня есть набор таблиц кустов на основе Avro, и мне нужно прочитать данные из них.Поскольку...