如何在星火更换字写程序(How to write program in Spark to repla

2019-10-21 11:39发布

很容易的Hadoop使用.replace()例如

String[] valArray = value.toString().replace("\N", "")

但忽略了最低在星火的工作,我写在斯卡拉星火壳像下面

val outFile=inFile.map(x=>x.replace("\N",""))

那么,如何处理呢?

Answer 1:

出于某种原因,您的x是一个Array[String] 。 你怎么会这样? 您可以.toString.replace如果你喜欢它,但你想要的(反正会给Java中的错误输出),将可能不会得到你; 你可能想要做地图的另一层, inFile.map(x => x.map(_.replace("\N","")))



文章来源: How to write program in Spark to replace word