From 0e3fe9c0ba46f044179f7d60b5eee2edb7927580 Mon Sep 17 00:00:00 2001 From: Harish <52824770+HarishS-code@users.noreply.github.com> Date: Tue, 9 Jan 2024 22:17:01 +0530 Subject: [PATCH] Update 01-streaming-word-count.py overwrite replaces the record throwing assert error , updated it to append method for correct asserts --- Notebooks/01-streaming-word-count.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Notebooks/01-streaming-word-count.py b/Notebooks/01-streaming-word-count.py index d72d560..d9ca1ad 100644 --- a/Notebooks/01-streaming-word-count.py +++ b/Notebooks/01-streaming-word-count.py @@ -25,7 +25,7 @@ def getWordCount(self, qualityDF): def overwriteWordCount(self, wordCountDF): ( wordCountDF.write .format("delta") - .mode("overwrite") + .mode("append") .saveAsTable("word_count_table") )