Spark的WordCount產生多少個RDD

不少的同學在面試中會被問到:這樣的一句標準的sparkcore的wordcount的代碼到底能要產生幾個RDD呢。相信大家對於一個標準的WordCount的代碼一定不陌生: sc.textFile( "hdfs://myha01/wc/input/words.txt") .flatMap(_.split( " ")) .map((_, 1
相關文章
相關標籤/搜索