Ниже мой RDD val title = movies.map(f=>(f.toString().split("::")(0)
Я пытаюсь использовать эту схему avro { "type": "record", "name":...
У меня есть простая схема avro, и я добавил одно новое поле в схему avro, указав значение по...
У меня есть следующая схема Avro: { "name": "schema_name", "type":...
Я работаю над confluent-4.1.1 с помощью ksql cli.Могу ли я создать поток для вложенного формата...
Я пытаюсь преобразовать Gradle в Maven. Структура проекта test |____ test1 |____ pom.xml |____...
Необходимо извлечь схему таблицы (используя колонки description \ list) в файл .txt или .csv, а...
У меня есть файл, в котором двоичный файл avro добавлен рядом друг с другом.Я хотел бы прочитать...
Я запустил коннектор kafka, используя следующую команду: ./bin/connect-standalone...
Краткое объяснение того, чего я хочу достичь: я хочу сделать функциональные тесты для топологии...
Я пытаюсь принять jsonSerde в качестве входных данных от тем и должен обработать запись и должен...
Я использую сливной коннектор hdfs-приемника, я вставляю данные в формате avro. Я хочу сжать данные...
Я хочу создать некоторые общие данные в теме kafka, используя apache nifi, и я хочу, чтобы эти...
Я работаю над внедрением avro mapping для механизма потоковой обработки.Я новичок в Avro и все еще...
У меня есть конкретный класс, который я сериализирую в байтовом массиве для отправки в тему Кафки
Мой код ниже выдает ошибки row.key и row.value при чтении формата AVRO от производителя при...
В моей схеме Avro у меня есть поле с именем myenum типа enum: { "name":...
У меня есть Python 3.6 и установлен Avro 1.8.2 https://avro.apache.org/docs/1.8
Я сейчас изучаю Apache AVRO, и некоторые моменты мне не ясны. Допустим, у меня уже есть следующий...
Я попытался создать таблицу в Hive и хотел экспортировать ее в формате Avro. В конце концов я хочу...
У меня есть файл json, который мне нужно преобразовать в Avro с помощью apache beam. [{...
Я написал скрипт для преобразования диапазона файлов avro с различными схемами из байтов...
Я извлекаю данные из Oracle, используя python 2.7 и fastavro.Я генерирую схему на основе типа...
Я создал службу XSOdata в SAP HANA, и внешняя система нуждается в формате AVRO, а не в формате JSON
Я не могу импортировать пакеты данных avro и XML в eclipse.Я скачал файл jar spark-avro_2.11-4.0.0...