因为Spark并行的处理数据,所以你不能在自己的driver program中计数到底是处理到第几个。Spark提供了zipWithIndex可以给你提供索引号。这个索引号是全局有序和唯一的。因为Spark并行的处理数据,所以你不能在自己的driver program中计数到底是处理到
因为Spark并行的处理数据,所以你不能在自己的driver program中计数到底是处理到第几个。Spark提供了zipWithIndex可以给你提供索引号。这个索引号是全局有序和唯一的。因为Spark并行的处理数据,所以你不能在自己的driver program中计数到底是处理到