beam_nuggets.transforms.unique_id module

class beam_nuggets.transforms.unique_id.AssignUniqueId(id_key='id', *unused_args, **unused_kwargs)[source]

Bases: apache_beam.transforms.core.DoFn

process(element)[source]
Parameters:element (dict) –