fix defaults

Signed-off-by: Jeffrey Kinard <[email protected]>

sdks/python/apache_beam/yaml/yaml_io.py

@@ -78,10 +78,10 @@ def read_from_text(
   or specified delimiter.
 
   Args:
-    delimiter (str): Delimiter to split records.
-    path (str): The file path to read from as a local file path or a
+      delimiter (str): Delimiter to split records.
+      path (str): The file path to read from as a local file path or a
         GCS ``gs://`` path. The path can contain glob
-      characters such as ``*`` and ``?``.
+        characters such as ``*`` and ``?``.
   """
   return beam_io.ReadFromText(
       file_pattern=path,
@@ -146,7 +146,7 @@ def read_from_csv(
         GCS ``gs://`` path. The path can contain glob
         characters such as ``*`` and ``?``.
   """
-  return ReadFromCsv(path=path, comment=comment, sep=delimiter, **kwargs)
+  return ReadFromCsv(path=path, comment=comment, delimiter=delimiter, **kwargs)
 
 
 def write_to_csv(path: str, delimiter: Optional[str] = ",", **kwargs):
@@ -192,7 +192,7 @@ def write_to_json(path: str, **kwargs):
   return WriteToJson(path=path, **kwargs)
 
 
-def read_from_parquet(path: str, **kwargs):
+def read_from_parquet(path: str, as_rows: bool = True, **kwargs):
   """Read a set of Parquet files defined by a given file pattern.
 
         For more information about possible arguments, see
@@ -202,7 +202,7 @@ def read_from_parquet(path: str, **kwargs):
             path (str): The file path to read from as a local file path or a
               GCS ``gs://`` path.
           """
-  return ReadFromParquet(file_pattern=path, as_rows=True, **kwargs)
+  return ReadFromParquet(file_pattern=path, as_rows=as_rows, **kwargs)
 
 
 def write_to_parquet(path: str, **kwargs):
@@ -220,7 +220,7 @@ def write_to_parquet(path: str, **kwargs):
   return WriteToParquet(file_path_prefix=path, **kwargs)
 
 
-def read_from_avro(path: str, **kwargs):
+def read_from_avro(path: str, as_rows: bool = True, **kwargs):
   """Reads records from avro files into Beam rows.
 
     Records that are of simple types will be
@@ -236,7 +236,7 @@ def read_from_avro(path: str, **kwargs):
       path (str): The file path to read from as a local file path or a
         GCS ``gs://`` path.
     """
-  return ReadFromAvro(file_pattern=path, as_rows=True, **kwargs)
+  return ReadFromAvro(file_pattern=path, as_rows=as_rows, **kwargs)
 
 
 def write_to_avro(path: str, **kwargs):