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.                                    

Reply via email to