Hi!

In the Beam documentation I read, that a DoFn should never modify any value of 
an incoming element (retrieved via ProcessContext.element(.)). I'm wondering, 
when this would be a problem, if I don't have any object reuse behavior in my 
execution environment. Can you give a hint, where this might cause problems?

And a second question: How would I implement a DISTINCT transformation on a 
PCollection?

Thanks in advance,
Rico.

________________________________


GfK SE, Nuremberg, Germany, commercial register at the local court Amtsgericht 
Nuremberg HRB 25014; Management Board: Dr. Gerhard Hausruckinger (Speaker of 
the Management Board), Christian Diedrich (CFO), Matthias Hartmann, David 
Krajicek, Alessandra Cama; Chairman of the Supervisory Board: Ralf 
Klein-B?lting This email and any attachments may contain confidential or 
privileged information. Please note that unauthorized copying, disclosure or 
distribution of the material in this email is not permitted.

Reply via email to