Remove unused ToRow, mark WithSchema as experimental.

apache · Sep 18, 2023 · 80f765b · 80f765b
1 parent 881c597
commit 80f765b
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py b/sdks/python/apache_beam/yaml/yaml_provider.py
@@ -522,12 +522,7 @@ 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,