Hi,Say we have an operation that writes something to an external resource and gets some output. For example: val doSomething(entry:SomeEntry, session:Session) : SomeOutput = { val result = session.SomeOp(entry) SomeOutput(entry.Key, result.SomeProp)} I could use a transformation for rdd.map, but in case of failures, the map would run on another executor for the same rdd. I could do rdd.foreach, but that returns unit. Is there something like a foreach that can return values? Thanks, Ashic.
- How to run an action and get output? Ashic Mahtab
- Re: How to run an action and get output? Tobias Pfeiffer