为什么数据流不打印转换？

Question

List<Integer> lst = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)                .collect(Collectors.toList());StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();DataStream<Integer> dataStream = env.fromCollection(lst);dataStream.flatMap(new FlatMapFunction<Integer, Integer>() {    @Override    public void flatMap(Integer integer, Collector<Integer> collector) throws Exception {        collector.collect(new Integer(integer.intValue() + 1));    }});dataStream.print();env.execute("Executing list");这最终打印：10> 49> 38> 212> 611> 54> 101> 72> 83> 97> 1我假设我在FlatMap函数的某处或打印的某处犯了错误。我试图映射它，以便每个元素因为递增 1

Answer 1

dataStream.flatMap(...).print()

不是

数据流.flatMap(...) 数据流.print()

Answer 2

dataStream.flatMap(...)返回转换后的流，但不修改原始dataStream. 您需要将其重写为

dataStream.flatMap(...).print();

或作为

DataStream<Integer> transformed = dataStream.flatMap(...);
transformed.print();