This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new b39089870e7 Remove unused ToRow, GroupByKey, mark WithSchema as
experimental. (#28504)
b39089870e7 is described below
commit b39089870e72c5b901fbd9dbd75f72a55927fff4
Author: Robert Bradshaw <[email protected]>
AuthorDate: Tue Sep 19 17:04:25 2023 -0700
Remove unused ToRow, GroupByKey, mark WithSchema as experimental. (#28504)
---
sdks/python/apache_beam/yaml/yaml_provider.py | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py
b/sdks/python/apache_beam/yaml/yaml_provider.py
index 382dcfd97dc..d01852a69c3 100644
--- a/sdks/python/apache_beam/yaml/yaml_provider.py
+++ b/sdks/python/apache_beam/yaml/yaml_provider.py
@@ -549,15 +549,9 @@ def create_builtin_provider():
'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', ))
