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.
PS: Resending to nabble email due to spam issues.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/How-to-run-an-action-and-get-output-tp20781.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
