Resultados da pesquisa a pedido "spark-avro"

1 a resposta

Como converter avro aninhado GenericRecord para Row

Eu tenho um código para converter meu registro avro para Row usando a funçãoavroToRowConverter() directKafkaStream.foreachRDD(rdd -> { JavaRDD<Row> newRDD= rdd.map(x->{ Injection<GenericRecord, byte[]> recordInjection ...