Как изменить элементы с фиксированным числом при потоковой передаче искры - PullRequest
0 голосов
/ 28 августа 2018

Здравствуйте, я новичок в потоковом воспроизведении Я хочу изменить фиксированное количество элементов в потоке и оставить все как есть.

Допустим, у нас есть DStream [(Int, Int)]

((1,0), (2,0), (3,0), (4,0), (5,0), (6,0), (7,0), (8,0 ), (9,0), (10,0))

Я хочу изменить три из них, желательно первые три, но наугад это нормально. Я хочу, чтобы выходной поток был похож на

((1,1), (2,1), (3,1), (4,0), (5,0), (6,0), (7,0), (8,0 ), (9,0), (10,0))

Возможно ли это с картой или мне нужно взять takeSample

...