or you could group them a little differently in a map stage so that reduce only runs 1 per run