java - 使用 Apache flink 和 Spring boot 将 DataStream 类型的对象从 Controller 传递到 View 时出错

Question

我是 flink 新手，在使用 Spring boot 和 thymeleaf 在网页 View 中显示 DataStream (Apache flink) 类型的对象时遇到问题。是否可以将此 DataStream 对象转换为要传递给 View 的列表？当我将 DataStream 对象作为参数传递给 View 时，如下所示:

List<String> inputFeed = Serializefeed(entries);
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<String> feeds = env.fromCollection(inputFeed);
DataStream<String> AnnotatedFeed = feeds.map(new MapFunction<String, String>() {
        @Override
        public String map(String SingleFeed) throws Exception {
            /**
                Some operations on the Stream
             **/
        }
    }).setParallelism(10);
    model.addAttribute("feedsAnnotated",AnnotatedFeed);
    env.execute("Rss feed Annotater example");

    return "AnnotatedFeed";
}

并使用 AnnotatedFeed.print() 将其显示在 View 中；我收到一个异常:方法调用:尝试在空上下文对象上调用方法 print() 。那么，我如何将 DataStream 存储到可以传递给 View 的对象中，有什么帮助吗？

Answer 1

以下是我通过将数据流保存在集合中然后将该集合传递到我的 View 来解决该问题的方法:

Iterator<Object> iter = DataStreamUtils.collect(datastream);
List<Object> list = Lists.newArrayList(iter);