我正在使用kafka avro记录并创建genericrecord流。现在,为了进行一些计算,我想将genericord转换为pojo对象。我已经从模式中使用avro maven插件生成了一个类。
但是我无法将泛型记录转换为这个生成的类对象。
请帮我怎么做。我想知道如何在下面的代码中实现convertopojo函数。
public void flatMap(Tuple2<Long, GenericRecord> recordTuple2, Collector<Tuple4<Long, Long, Long, Long>> collector) throws Exception {
GenericRecord record = recordTuple2.f1;
String event_name = record.get("event_name").toString();
if (event_name.equals("search_list_keyless")) {
SearchListKeyelss object = ConvertoPojo(record)
}
}
暂无答案!
目前还没有任何答案,快来回答吧!