Initial Commit

LearningJournal · Jul 28, 2020 · 38caff6 · 38caff6
1 parent d795d05
commit 38caff6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/03-KafkaStreamDemo/KafkaStreamDemo.py b/03-KafkaStreamDemo/KafkaStreamDemo.py
@@ -68,7 +68,7 @@
         .withColumn("TotalValue", expr("LineItem.TotalValue")) \
         .drop("LineItem")
 
-    invoice_writer_query = explode_df.writeStream \
+    invoice_writer_query = flattened_df.writeStream \
         .format("json") \
         .queryName("Flattened Invoice Writer") \
         .outputMode("append") \