Dear all,

I want to implement some sequential algorithm on RDD.

For example:

val conf = new SparkConf()
  conf.setMaster("local[2]").
  setAppName("SequentialSuite")
val sc = new SparkContext(conf)
val rdd = sc.
   parallelize(Array(1, 3, 2, 7, 1, 4, 2, 5, 1, 8, 9), 2).
   sortBy(x => x, true)
rdd.foreach(println)

I want to see the ordered number on my screen, but it shows unordered
integers. The two partitions execute the println simultaneously.

How do I make the RDD execute a function globally sequential?

Best,
Wush

Reply via email to