diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py b/sdks/python/apache_beam/yaml/yaml_provider.py index 382dcfd97dca..d01852a69c39 100644 --- a/sdks/python/apache_beam/yaml/yaml_provider.py +++ b/sdks/python/apache_beam/yaml/yaml_provider.py @@ -549,15 +549,9 @@ def _parse_window_spec(spec): 'PyFilter': lambda keep: beam.Filter( python_callable.PythonCallableWithSource(keep)), 'PyTransform': fully_qualified_named_transform, - 'PyToRow': lambda fields: beam.Select( - **{ - name: python_callable.PythonCallableWithSource(fn) - for (name, fn) in fields.items() - }), - 'WithSchema': with_schema, + 'WithSchemaExperimental': with_schema, 'Flatten': Flatten, 'WindowInto': WindowInto, - 'GroupByKey': beam.GroupByKey, }, no_input_transforms=('Create', ))