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) → google.protobuf.struct_pb2.Struct

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