[源码解析] 当 Java Stream 遇见 Flink.collect(Collectors.toList());
调用时候涉及到的部分调用栈如下:
makeSink:180, ReduceOps$3 (java.util.stream)
makeSink :177, ReduceOps$3 (java.util.stream)
evaluateSequential:708, ReduceOps$ReduceOp (java.util.stream)
evaluate :234, AbstractPipeline (java.util.stream)
collect:499, ReferencePipeline (java.util.stream)
main:20, (java.util.stream)
evaluate:234, AbstractPipeline (java.util.stream)
collect:499, ReferencePipeline )
evaluate:233, AbstractPipeline (java.util.stream)
collect:499, ReferencePipeline (java.util.stream)