spark RDD 小实验 测试

class SparkContext(clientDriver:String){ var scname = clientDriver } abstract class RDD(var  sc:SparkContext){ def persist(level:String){} }

class myRDD(var myRDDsc:SparkContext) extends RDD(myRDDsc:SparkContext) { var mysc=myRDDsc.scname override   def persist(level:String){   println(mysc  +"  "+"the bigdata saving" +"  "+level) } }

 

测试一下

 

scala> var noc =newSparkContext("2016'netbigdata")

noc: SparkContext = SparkContext@8a0d7d

 

scala> var dzhRDD=new myRDD(noc)

dzhRDD: myRDD = myRDD@1f7fb55

 

scala> dzhRDD.persist(" hdfs levelstoraging!!")

2016'netbigdata  the bigdata saving   hdfs level storaging!!

 

scala>