Hi
Quick question here,
I know that .foreach is not idempotent.  I am wondering if collect() is 
idempotent? Meaning that once I've collect()-ed if spark node crashes I can't 
get the same values from the stream ever again.

Thanks
-Adrian

Reply via email to