apache_beam.yaml.yaml_mapping module¶

This module defines the basic MapToFields operation.

apache_beam.yaml.yaml_mapping.normalize_mapping(spec)[source]¶: Normalizes various fields for mapping transforms.

apache_beam.yaml.yaml_mapping.py_value_to_js_dict(py_value)[source]¶

class apache_beam.yaml.yaml_mapping.ErrorHandlingConfig(output)[source]¶

Bases: tuple

Create new instance of ErrorHandlingConfig(output,)

output¶: Alias for field number 0

apache_beam.yaml.yaml_mapping.exception_handling_args(error_handling_spec)[source]¶

apache_beam.yaml.yaml_mapping.maybe_with_exception_handling(inner_expand)[source]¶

apache_beam.yaml.yaml_mapping.maybe_with_exception_handling_transform_fn(transform_fn)[source]¶

apache_beam.yaml.yaml_mapping.is_expr(v)[source]¶

apache_beam.yaml.yaml_mapping.normalize_fields(pcoll, fields, drop=(), append=False, language='generic')[source]¶

apache_beam.yaml.yaml_mapping.create_mapping_providers()[source]¶