Remove unused ToRow, GroupByKey, mark WithSchema as experimental. (#2…

…8504)
apache · Sep 20, 2023 · b390898 · b390898
1 parent 845dfc5
commit b390898
Showing 1 changed file with 1 addition and 7 deletions.
diff --git 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', ))