genericord到pojo

pnwntuvh  于 2021-06-26  发布在  Flink
关注(0)|答案(0)|浏览(229)

我正在使用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)
        }

        }

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题