可以使用Flink的filter函数来过滤出包含有page字段的数据。具体实现可以参考以下代码:

DataStream<MyData> filteredData = sourceData.filter(new FilterFunction<MyData>() {
    @Override
    public boolean filter(MyData value) throws Exception {
        return value.getPage() != null; //判断page字段是否为空
    }
});

其中,MyData为数据类型,sourceData为输入数据流。在filter函数中,通过判断MyData对象中的page字段是否为空,决定是否保留该数据。最终得到的filteredData为包含有page字段的数据流。

flink从中过滤出包含有page字段的数据

原文地址: https://www.cveoy.top/t/topic/fD0N 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录