Spark——RDD操做詳解

1、基本RDD 一、針對各個元素的轉化操做 最經常使用的轉化操做是map()和filter()。轉化操做map()J接收一個函數,把這個函數用於RDD中的每個元素,將函數的返回結果做爲結果RDD中對應元素。而轉化操做filter()則接收一個函數,將RDD知足該函數的元素放入新的RDD中返回。map()的返回值類型不須要和輸入類型同樣。 從一個RDD變成另一個RDD。lazy,懶執行 。好比根據謂
相關文章
相關標籤/搜索