ShuffleReader is an abstraction of shuffle block readers that can read combined key-value records for a reduce task.
Reading Combined Records (for Reduce Task)¶
read(): Iterator[Product2[K, C]]
- CoGroupedRDD, ShuffledRDD, and SubtractedRDD are requested to compute a partition (for a
ShuffledRowRDD(Spark SQL) is requested to