Hi all, I had a question: if I have an RDD containing mutable values, and I run a function over the RDD which mucks with the mutable values, what happens? What happens in the case of a cogroup? e.g.:
inputRdd.cogroup(inputRdd2).flatMapValues(functionThatModifiesValues()) Will this result in undefined behavior? Is it a best practice then to make sure functionThatModifiesValues() performs a defensive copy if necessary? Thanks, Allen -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/RDD-values-and-defensive-copying-tp6336.html Sent from the Apache Spark User List mailing list archive at Nabble.com.
