From df76583ed1316f7acb9f887841fbc5d7294991a4 Mon Sep 17 00:00:00 2001 From: saksham65 <112824661+Saksham65@users.noreply.github.com> Date: Thu, 30 Jan 2025 15:29:31 +0530 Subject: [PATCH] Saksham/demoqa fixes (#7989) GitOrigin-RevId: 6a54fe6d5bfc293c018dba3ccdc5cd2601f25786 --- docs/2.developers/4.user-guide/10.introduction/50.concepts.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/2.developers/4.user-guide/10.introduction/50.concepts.md b/docs/2.developers/4.user-guide/10.introduction/50.concepts.md index 83259e40..492982eb 100644 --- a/docs/2.developers/4.user-guide/10.introduction/50.concepts.md +++ b/docs/2.developers/4.user-guide/10.introduction/50.concepts.md @@ -309,7 +309,7 @@ class InputSchema(pw.Schema): input_table = pw.io.kafka.read(kafka_settings, schema=InputSchema, topic="topic1", format="json") filtered_table = input_table.filter(input_table.age >= 0) result_table = filtered_table.reduce(sum_age = pw.reducers.sum(filtered_table.age)) -pw.io.kafka.write(table, kafka_settings, topic="topic2", format="json") +pw.io.kafka.write(result_table, kafka_settings, topic="topic2", format="json") pw.run() ```