Spark基礎轉換及行動操作(python實驗)

注意:實驗前先引入包from pyspark.context import SparkContext ,還需配置 sc = SparkContext('local', 'test') ,然後才能用sc做操作。 一、常見的轉換操作 1、map() : 將函數應用於RDD中的每個元素,將返回值構成新的RDD 2、flatMap() :將函數應用於RDD 中的每個元素,將返回的迭代器的所有內容構成新的R
相關文章
相關標籤/搜索