ShuffleMapTask

This type of task is mainly for shuffle. It iterates on the RDD iterator and write to different partition to be used by reduce task. The destination partition is decided by the key of the RDD[K, V].

results matching ""

    No results matching ""