ЛР
Size: a a a
ЛР
A🦕
.reduce
- чтобы он выполнялся сначала на нодах партиций / и только потом прилетал на драйвер aggregate
если seqOp
и combOp
- это одна операция. или тут просто reduce
хватитA🦕
mapPartitions
(и в нем reduce
на каждой тачке)reduce
на драйвереR
ЕГ
R
PK
EN
S
AN
EN
ES
АЖ
EN
t
t
АЖ
☭S
AC
PK