Hi again,
On Thu, Dec 18, 2014 at 6:43 PM, Tobias Pfeiffer <t...@preferred.jp> wrote:
>
> tmpRdd.foreachPartition(iter => {
> iter.map(item => {
> println("xyz: " + item)
> })
> })
>Uh, with iter.foreach(...) it works... the reason being apparently that iter.map() returns itself an iterator, is thus evaluated lazily (in this case: never), while iter.foreach() is evaluated immediately. Thanks Tobias
