Spark 經常使用案例

數據過濾清洗數據 //textFile() 加載數據 val data = sc.textFile("/spark/seven.txt") //filter 過濾長度小於0， 過濾不包含GET與POST的URL val filtered = data.filter(_.length() > 0).filter(line => (line.indexOf("GET") >

>>阅读原文<<