From ffeaa9011908097a727c0f749c6e16acd3836901 Mon Sep 17 00:00:00 2001
From: Mine4106 <37037296+Mine4106@users.noreply.github.com>
Date: Sun, 29 Jun 2025 10:59:48 +0530
Subject: [PATCH] Update readwriter.py

Fixed the documentation
---
 python/pyspark/sql/streaming/readwriter.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/python/pyspark/sql/streaming/readwriter.py b/python/pyspark/sql/streaming/readwriter.py
index 34af8cd9b070e..8121dd609950e 100644
--- a/python/pyspark/sql/streaming/readwriter.py
+++ b/python/pyspark/sql/streaming/readwriter.py
@@ -1549,7 +1549,7 @@ def foreach(self, f: Union[Callable[[Row], None], "SupportsProcess"]) -> "DataSt
         ...     def close(self, error):
         ...         print("Closed with error: %s" % str(error))
         ...
-        >>> q = df.writeStream.foreach(print_row).start()
+        >>> q = df.writeStream.foreach(RowPrinter()).start()
         >>> time.sleep(3)
         >>> q.stop()
         """