DataStreamSource<String> source = environment.addSource(new YjxxtCustomSourceRich("data/secret.txt")).setParallelism(7);
时间: 2024-05-31 10:10:56 浏览: 107
Unity3d读写格式为<key></key><string></string>类型的xml
这段代码是使用 Flink 框架中的 DataStream API 从文件中读取数据,并将读取到的数据作为字符串类型的数据流输入到 Flink 程序中。
具体来说,这段代码首先创建了一个 `YjxxtCustomSourceRich` 类型的数据源,该数据源会读取 `data/secret.txt` 文件中的数据。然后使用 `setParallelism` 方法设置了并行度为 7,即在 Flink 集群中会创建 7 个并行的任务来读取该文件中的数据。
最后,将该数据源添加到 Flink 程序中,使其成为数据流处理的起点。
阅读全文