beam_nuggets.transforms.unique_id module

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

Bases: apache_beam.transforms.core.DoFn

process(element)

Parameters:element (dict) –