apache_beam.yaml.yaml_io module

This module contains the Python implementations for the builtin IOs.

They are referenced from standard_io.py.

Note that in the case that they overlap with other (likely Java) implementations of the same transforms, the configs must be kept in sync.

apache_beam.yaml.yaml_io.read_from_text(path: str)

apache_beam.yaml.yaml_io.write_to_text(pcoll, path: str)

apache_beam.yaml.yaml_io.read_from_bigquery(query=None, table=None, row_restriction=None, fields=None)

apache_beam.yaml.yaml_io.write_to_bigquery(table, *, create_disposition='CREATE_IF_NEEDED', write_disposition='WRITE_APPEND', error_handling=None)

apache_beam.yaml.yaml_io.io_providers()