79303520

Date: 2024-12-23 15:30:45
Score: 0.5
Natty:
Report link

For Java Spark, a solution along the lines of JavaAPISuite.mapPartitions():

rdd.mapPartitions(itr -> Collections.singletonList(Iterators.size(itr)).iterator()).collect().toString());

Just to see:

rddSliced.foreachPartition(itr -> System.out.println(Iterators.size(itr)));
Reasons:
  • Low length (0.5):
  • Has code block (-0.5):
  • Low reputation (0.5):
Posted by: Aloke