У меня есть требование для потоковой передачи, когда мне нужно преобразовать GenericRecord в DatFrame, чтобы я мог использовать EXPLODE и другие функции, доступные в DF.Итак, во-первых, я смотрю, как конвертировать GenericRecord в DF.
Я проверил приведенный ниже URL, который помогает в преобразовании записи в DF.Но я не могу понять, как добавить класс SchemaConverterUtils к объекту avro.
Как преобразовать RDD [GenericRecord] в фрейм данных в scala?
Это дает мне файл только для чтения, когда я пытаюсь редактировать.Я новичок в Scala / Java.Не могли бы вы помочь мне понять, как это сделать.
Спасибо