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

可以使用Flink的过滤函数（Filter Function）来实现该功能。具体实现代码如下：

DataStream<MyData> inputStream = ...; // 输入数据流
DataStream<MyData> filteredStream = inputStream.filter(new FilterFunction<MyData>() {
    @Override
    public boolean filter(MyData value) throws Exception {
        return value.getPage() != null; // 判断是否包含page字段
    }
});

其中，MyData为数据类型，包含page字段。filter函数的参数为一个实现了FilterFunction接口的匿名内部类，该接口中只有一个方法filter，参数为输入数据类型，返回值为布尔类型，表示是否保留该数据。在这里，我们判断是否包含page字段，如果包含则返回true，否则返回false，即丢弃该数据。最终得到的filteredStream即为过滤后的数据流