正在加载图片...
5.1.1RDD创建 (1)从本地文件系统中加载数据创建RDD scala> val lines= sc textFile ("file: usr/local/spark/mycode/rdd/word. txt") lines: org. apache. spark rdd RDD[String] file / usr/local/spark/mycode/rdd/word. txt MapPartitionsRDD[12] at textFile at <console>: 27 word. txt RDD(lines) Hadoop is good "Hadoop is good" Spark is fast sc textFile Spark is fast park is better Spark is better" 表示一个RDD元素 图从文件中加载数据生成RDD Spark编程基础》 厦门大学计算机科学系 林子雨 ziyulin@xmu.edu.cn《Spark编程基础》 厦门大学计算机科学系 林子雨 ziyulin@xmu.edu.cn 5.1.1 RDD创建 scala> val lines = sc.textFile("file:///usr/local/spark/mycode/rdd/word.txt") lines: org.apache.spark.rdd.RDD[String] = file:///usr/local/spark/mycode/rdd/word.txt MapPartitionsRDD[12] at textFile at <console>:27 word.txt RDD(lines) sc.textFile() Hadoop is good Spark is fast Spark is better "Hadoop is good" "Spark is fast" "Spark is better" 表示一个RDD元素 图 从文件中加载数据生成RDD (1)从本地文件系统中加载数据创建RDD
<<向上翻页向下翻页>>
©2008-现在 cucdc.com 高等教育资讯网 版权所有