Spark API編程動手實戰-01-以本地模式進行Spark API實戰map、filter和collect

首先以spark的本地模式測試spark API,以local的方式運行spark-shell: 先從parallelize入手吧: map操作後結果:   下面看下 filter操作: filter執行結果: 我們用最正宗的scala函數式編程的風格: 執行結果: 從結果 可以看出來,與之前那種分步奏方式結果是一樣的 但採用這種方式,即是複合scala風格的寫法,也是符合spark的應用程序風格
相關文章
相關標籤/搜索