[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Passing parameter to DoFn in Python

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:

how would the class definition be updated?
class SampleFn(beam.DoFn):
  def process(self,element):