apache_beam.portability.api.org.apache.beam.model.pipeline.v1.external_transforms_pb2_urns module

class apache_beam.portability.api.org.apache.beam.model.pipeline.v1.external_transforms_pb2_urns.Annotations

Bases: object

class Enum

Bases: object

CONFIG_ROW_KEY = ('', 'config_row', , )

CONFIG_ROW_SCHEMA_KEY = ('', 'config_row_schema', , )

SCHEMATRANSFORM_URN_KEY = ('', 'schematransform_urn', , )

MANAGED_UNDERLYING_TRANSFORM_URN_KEY = ('', 'managed_underlying_transform_urn', , )

class apache_beam.portability.api.org.apache.beam.model.pipeline.v1.external_transforms_pb2_urns.ExpansionMethods

Bases: object

class Enum

Bases: object

JAVA_CLASS_LOOKUP = ('beam:expansion:payload:java_class_lookup:v1', '', , )

SCHEMA_TRANSFORM = ('beam:expansion:payload:schematransform:v1', '', , )

class apache_beam.portability.api.org.apache.beam.model.pipeline.v1.external_transforms_pb2_urns.ManagedTransforms

Bases: object

class Urns

Bases: object

ICEBERG_READ = ('beam:schematransform:org.apache.beam:iceberg_read:v1', '', , )

ICEBERG_WRITE = ('beam:schematransform:org.apache.beam:iceberg_write:v1', '', , )

KAFKA_READ = ('beam:schematransform:org.apache.beam:kafka_read:v1', '', , )

KAFKA_WRITE = ('beam:schematransform:org.apache.beam:kafka_write:v1', '', , )

BIGQUERY_READ = ('beam:schematransform:org.apache.beam:bigquery_storage_read:v1', '', , )

BIGQUERY_WRITE = ('beam:schematransform:org.apache.beam:bigquery_write:v1', '', , )

ICEBERG_CDC_READ = ('beam:schematransform:org.apache.beam:iceberg_cdc_read:v1', '', , )

POSTGRES_READ = ('beam:schematransform:org.apache.beam:postgres_read:v1', '', , )

POSTGRES_WRITE = ('beam:schematransform:org.apache.beam:postgres_write:v1', '', , )

MYSQL_READ = ('beam:schematransform:org.apache.beam:mysql_read:v1', '', , )

MYSQL_WRITE = ('beam:schematransform:org.apache.beam:mysql_write:v1', '', , )

SQL_SERVER_READ = ('beam:schematransform:org.apache.beam:sql_server_read:v1', '', , )

SQL_SERVER_WRITE = ('beam:schematransform:org.apache.beam:sql_server_write:v1', '', , )