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/

Reply via email to