apache_beam.yaml.yaml_mapping module¶

This module defines the basic MapToFields operation.

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]¶

class apache_beam.yaml.yaml_mapping.SqlMappingProvider(sql_provider=None)[source]¶

Bases: apache_beam.yaml.yaml_provider.Provider

available()[source]¶

cache_artifacts()[source]¶

provided_transforms() → Iterable[str][source]¶

create_transform(typ: str, args: Mapping[str, Any], yaml_create_transform: Callable[[Mapping[str, Any], Iterable[apache_beam.pvalue.PCollection]], apache_beam.transforms.ptransform.PTransform]) → apache_beam.transforms.ptransform.PTransform[source]¶

underlying_provider()[source]¶

to_json()[source]¶

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