Передача двух RDD на внешний исполняемый файл - PullRequest
0 голосов
/ 12 апреля 2020

Я запускаю такой исполняемый файл:

temp_pipe = val_combineRDD.pipe("/home/executable + " -1 " + val_combineRDD.map(lambda x: x[0]) + " -2 " + val_combineRDD.map(lambda x: x[1]))

, который не работает с ошибкой:

"TypeError: can only concatenate str (not "PipelinedRDD") to str"

Val_combineRDD - это кортеж, который выглядит как (x,y) и я хочу, чтобы x передавался флагу 1, а y передавался флагу 2.

Как мне заставить это работать?

...