Nested block

[Tong Li Ken]

Hi, 

I am using treehugger to generate spark streaming code and i have some issue to generate this block of codes.

Can anyone help?

dstream.foreachRDD { (rdd, time) =>
  rdd.foreachPartition { partitionIterator =>
    val partitionId = TaskContext.get.partitionId()
    val uniqueId = generateUniqueId(time.milliseconds, partitionId)
    // use this uniqueId to transactionally commit the data in partitionIterator
  }
}