Hi all, Is it possible to pass a string parameter with DoFn function and what would be the syntax?
The call should look something like that: beam.ParDo(SampleFn(samplePath)) how would the class definition be updated? class SampleFn(beam.DoFn): def process(self,element): Thanks, -- Eila www.orielresearch.org https://www.meetup.com/Deep-Learning-In-Production/