beam_nuggets.transforms.json_ module

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

Bases: apache_beam.transforms.core.DoFn

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