Utility functions for efficiently processing with the job API
apache_beam.runners.job.utils.
dict_to_struct
struct_to_dict