outputs = split(...).map(process).collect()

Since to return a

List[str]

which is what my

split

generator

yields

instead of what my

map

returns. Am I missing something basic here? what if i want to collect all outputs of process and send it to another op?

Hi Diego. If you want to collect all outputs of

process

and send it to another op, you could do something like:

other_op(split(...).map(process).collect())