У меня есть dask dataframe с 100 разделами и 57 столбцами. Я хочу сохранить его как avro в Google...
Проблема в следующем. Шаги: Приложение преобразует некоторый пользовательский объект в фрагмент...
Я использую scala 2.12 и у меня есть следующие зависимости в моем build.sbt. libraryDependencies +=...
Я пытаюсь погрузиться из одной темы в Кассандру.В этом разделе есть схема-реестр для файла avro,...
Я довольно долго боролся с этой проблемой.Я работаю над AvroProducer (confluent kafka) и получаю...
Я пытаюсь выслушать тему, на которую я отправил сообщение, используя функцию подключения kafka к...
Я использую Scala 2.12 и Avro (org.apache.avro) 1.8. У меня есть следующая схема: Schema:...
Мы пытаемся записать значения из темы в базу данных postgres, используя Confluent JDBC Sink...
Поддерживает ли каратэ-макет тестирование объектов AVRO, потому что в моем проекте есть требование...
Я читаю сообщения от Кафки в Flink Shell (Scala) следующим образом: scala> val stream = senv
В настоящее время я получаю некоторые данные в формате csv, в котором есть одно поле,...
Я столкнулся с аналогичной проблемой, упомянутой в https://github
У меня есть этот сценарий.Мы должны предоставить функциональность, которая принимает любой тип RDD,...
Я новичок в Avro и пытаюсь смоделировать RPC, но вместо того, чтобы начинать с файла протокола Avro...
Я должен импортировать данные, используя sqoop, в именах моих исходных столбцов между ними есть...
Я использую swagger-play2, и у меня есть эта аннотация: @ApiOperation(value = ""...
Я пытаюсь использовать тему Kafka, которая была сериализована в Avro, и мне нужно выяснить, как ее...
Я использую Scala 2.12 и импортировал необходимые библиотеки для "org.apache.avro". Я хочу создать...
Мне интересно, как я должен использовать KafkaAvroSerializer.Я установил confluent-schema-registry...
Я пытаюсь преобразовать JSON в JSON, используя JoltTransformRecord в Apache Nifi.Когда я пытаюсь...
Я использую avro1.8.2 + python3.7 (pip install avro-python3) для обработки формата AVRO. Вот пример...
Я собираюсь использовать приемник Apache Flume Avro для отправки сериализованных объектов Avro, но...
У меня есть Scala 2.12 и я импортировал библиотеку avro4s, следуя ссылке для моего требования. В...
Это относится к Apache Nifi. У меня есть фиксированная схема, которую мне нужно использовать. Файл...
Попытка сгенерировать json по схеме avro.Один из элементов таков: { "name":...