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.is_literal(expr: str) → bool[source]

apache_beam.yaml.yaml_mapping.validate_generic_expression(expr_dict: dict, input_fields: Collection[str], allow_cmp: bool, error_field: str) → None[source]

apache_beam.yaml.yaml_mapping.validate_generic_expressions(base_type, config, input_pcolls) → None[source]

apache_beam.yaml.yaml_mapping.py_value_to_js_dict(py_value)[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.PaneInfoTuple(is_first, is_last, timing, index, nonspeculative_index)[source]

Bases: NamedTuple

Create new instance of PaneInfoTuple(is_first, is_last, timing, index, nonspeculative_index)

is_first: bool: Alias for field number 0

is_last: bool: Alias for field number 1

timing: str: Alias for field number 2

index: int: Alias for field number 3

nonspeculative_index: int: Alias for field number 4

classmethod from_pane_info(pane_info)[source]

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