我有一个数据图表
1 2
1 4
4 1
4 2
4 3
3 2
2 3
但是我找不到一种方法把它转换成一列的数据集
1
2
1
4
4
1
...
这是我的代码,我使用scala listbuffer,但是在flink数据集中找不到一种方法
val params: ParameterTool = ParameterTool.fromArgs(args)
val env = ExecutionEnvironment.getExecutionEnvironment
env.getConfig.setGlobalJobParameters(params)
val text = env.readTextFile(params.get("input"))
val tupleText = text.map { line =>
val arr = line.split(" ")
(arr(0), arr(1))
}
var x: Seq[(String, String)] = tupleText.collect()
var tempList = new ListBuffer[String]
x.foreach(line => {
tempList += line._1
tempList += line._2
})
tempList.foreach(println)
1条答案
按热度按时间zynd9foi1#
你可以用它来做
flatMap
: