2回答

慕粉0909169327

2018-09-02

我写了一个，不是特别优雅，但是经测试能用，供你参考 val rdd1 = access.map... rdd1.filter(line=>{ val words = line.split("\t") !(words(1) == "-" || words(2) == "0") }).coalesce(1,false).saveAsTextFile("file:///D:/scalatest/formatoutput")

2

0

少帅521

提问者

2018-07-26

我想知道如何在代码编写使用filter（），如何操作，老师

0

2

慕粉0909169327

我写了一个，不是特别优雅，但是经测试能用，供你参考 val rdd1 = access.map... rdd1.filter(line=>{ val words = line.split("\t") !(words(1) == "-" || words(2) == "0") }).coalesce(1,false).saveAsTextFile("file:///D:/scalatest/formatoutput")

2018-08-30

共2条回复