Ngone51 commented on a change in pull request #31590: URL: https://github.com/apache/spark/pull/31590#discussion_r579305425
########## File path: docs/structured-streaming-programming-guide.md ########## @@ -2365,6 +2367,119 @@ When the streaming query is started, Spark calls the function or the object’s See [SPARK-28650](https://issues.apache.org/jira/browse/SPARK-28650) for more details. If you need deduplication on output, try out `foreachBatch` instead. +#### Streaming Table APIs +Since Spark 3.1, you can also use `DataStreamReader.table()` and `DataStreamWriter.toTable()` to read and write streaming DataFrames as tables: Review comment: How about: ```suggestion Since Spark 3.1, you can also use `DataStreamReader.table()` to read tables as streaming DataFrames and use `DataStreamWriter.toTable()` to write streaming DataFrames as tables: ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
