Scala DataStream API: 将字符串集合写入文件

假设DataStream API已经被导入，并且已经定义好了名为'strStream'的字符串集合数据源，可以使用以下Scala语句将'strStream'中的元素输出到指定文件'/home/hadoop/output.txt'：

strStream.writeAsText('file:///home/hadoop/output.txt').setParallelism(1)

解释：

• 'writeAsText' 方法将DataStream中的元素写入到指定文件中，参数为文件路径。
• 'setParallelism' 方法设置并行度为1，确保只有一个并行实例将数据写入文件，避免文件冲突。