我想将包含Avro对象(例如MyAvroClsass的对象)的javaRDD转换为java spark中的数据框。我低于错误
Cannot have circular references in bean class, but got the circular reference of class class org.apache.avro.Schema
Run Code Online (Sandbox Code Playgroud)
码:
Run Code Online (Sandbox Code Playgroud)JavaRDD<Row> test; Dataset<Row> outputDF = sparksession.createDataFrame(test.rdd(),<MyAvroClsass>.class);