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
