You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by Anton Kravchenko <kr...@gmail.com> on 2017/05/26 15:00:17 UTC

df.rdd.foreachPartition(convert_to_sas_single_partition)

def convert_to_sas_single_partition(ipartition: Iterator[Row]): Unit = {

for (irow <- ipartition) {