Flink 数据源并行度设置方法 - addSource 参数详解

在 Flink 中，可以通过调用 'addSource' 方法来添加数据源。可以通过以下方式设置并行度参数：

1. 在 'DataStreamSource' 对象上直接调用 'setParallelism' 方法，如下所示：

DataStreamSource<String> source = env.addSource(new MySource());
source.setParallelism(2);

2. 在 'addSource' 方法中传递并行度参数，如下所示：

DataStreamSource<String> source = env.addSource(new MySource()).setParallelism(2);

在这两种方式中，都可以设置并行度参数。但是，第一种方式需要对 'DataStreamSource' 对象进行额外的操作，而第二种方式则可以直接在 'addSource' 方法中设置并行度参数，更加简单方便。