fix test_io.py

Author: jsai28

python/datafusion/io.py

@@ -64,8 +64,7 @@ def read_parquet(
     """
     if table_partition_cols is None:
         table_partition_cols = []
-    return DataFrame(
-        SessionContext.global_ctx().read_parquet(
+    return SessionContext.global_ctx().read_parquet(
             str(path),
             table_partition_cols,
             parquet_pruning,
@@ -74,7 +73,6 @@ def read_parquet(
             schema,
             file_sort_order,
         )
-    )
 
 
 def read_json(
@@ -106,16 +104,14 @@ def read_json(
     """
     if table_partition_cols is None:
         table_partition_cols = []
-    return DataFrame(
-        SessionContext.global_ctx().read_json(
+    return SessionContext.global_ctx().read_json(
             str(path),
             schema,
             schema_infer_max_records,
             file_extension,
             table_partition_cols,
             file_compression_type,
         )
-    )
 
 
 def read_csv(
@@ -157,8 +153,7 @@ def read_csv(
 
     path = [str(p) for p in path] if isinstance(path, list) else str(path)
 
-    return DataFrame(
-        SessionContext.global_ctx().read_csv(
+    return SessionContext.global_ctx().read_csv(
             path,
             schema,
             has_header,
@@ -168,7 +163,6 @@ def read_csv(
             table_partition_cols,
             file_compression_type,
         )
-    )
 
 
 def read_avro(
@@ -194,8 +188,6 @@ def read_avro(
     """
     if file_partition_cols is None:
         file_partition_cols = []
-    return DataFrame(
-        SessionContext.global_ctx().read_avro(
+    return SessionContext.global_ctx().read_avro(
             str(path), schema, file_partition_cols, file_extension
         )
-    )