beam_nuggets.transforms.json_ module

class beam_nuggets.transforms.json_.ParseJson(only_keys=None, *unused_args, **unused_kwargs)

Bases: apache_beam.transforms.core.DoFn

process(element)

Parameters:element (dict) –