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: dict) → Struct

apache_beam.runners.job.utils.struct_to_dict(struct_obj: Struct) → dict