apache_beam.yaml.yaml_combine module

This module defines the basic Combine operation.

apache_beam.yaml.yaml_combine.normalize_combine(spec)

Expands various shorthand specs for combine (which can otherwise be quite verbose for simple cases.) We do this here so that it doesn’t need to be done per language. The following are all equivalent:

dest: fn_type

dest:
  value: dest
  fn: fn_type

dest:
  value: dest
  fn:
    type: fn_type

class apache_beam.yaml.yaml_combine.PyJsYamlCombine(group_by: Iterable[str], combine: Mapping[str, Mapping[str, Any]], language: Optional[str] = None)

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)

apache_beam.yaml.yaml_combine.create_combine_providers()