热门
1)由一个已经存在的Scala集合创建。
val rdd1 = sc.parallelize(Array(1,2,3,4,5,6,7,8))
2)由外部存储系统的数据集创建,包括本地的文件系统,还有所有Hadoop支持的数据集,比如HDFS、Cassandra、HBase等
HDFS
Cassandra
HBase
val rdd2 = sc.textFile("hdfs://node1.itcast.cn:9000/words.txt")