apache_beam.runners.job.utils module

Utility functions for efficiently processing with the job API

apache_beam.runners.job.utils.dict_to_struct(dict_obj)

apache_beam.runners.job.utils.struct_to_dict(struct_obj)