Skip to content

Commit c994a7c

Browse files
nagaarjun-pnagaarjun_p
authored andcommitted
Update readwriter.py
Fixed the documentation
1 parent 14d5c67 commit c994a7c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/pyspark/sql/streaming/readwriter.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1549,7 +1549,7 @@ def foreach(self, f: Union[Callable[[Row], None], "SupportsProcess"]) -> "DataSt
15491549
... def close(self, error):
15501550
... print("Closed with error: %s" % str(error))
15511551
...
1552-
>>> q = df.writeStream.foreach(print_row).start()
1552+
>>> q = df.writeStream.foreach(RowPrinter()).start()
15531553
>>> time.sleep(3)
15541554
>>> q.stop()
15551555
"""

0 commit comments

Comments
 (0)