Flink DataStream 源码

DataStream<String> input = ...;
DataStream<Integer> parsed = input.map(new MapFunction<String, Integer>() {
    @Override
    public Integer map(String value) {
        return Integer.parseInt(value);
    }
});

添加一个Map算子，类运转流程图如下。

DataStream类嵌套关系图
每次在DataStream添加Operator就会如下图，通过Transformer类将Operator串联起来

注意 : SingleOutputStreamOperator 是一个DataStream

例外：我一直觉得Operator应该翻译成运算符😁
�