RDD¶
Empty RDD with predefined schema¶
val rdd = sparkContext.emptyRDD[Apple]
List of primitives¶
val data = List(1, 2, 3)
val rdd = sparkContext.parallelize(data)
List of entities¶
val expected = Apple("Green", 120)
val rdd = sparkContext.parallelize(List(expected))
Example: RDDCreationSpec.scala