From 5a0569ce693c635c5fa12b2de33ed3643ce888e3 Mon Sep 17 00:00:00 2001 From: manugarri Date: Tue, 7 Feb 2017 21:45:33 -0800 Subject: [PATCH] [MINOR][DOC] Remove parenthesis in readStream() on kafka structured streaming doc There is a typo in http://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html#creating-a-kafka-source-stream , python example n1 uses `readStream()` instead of `readStream` Just removed the parenthesis. Author: manugarri Closes #16836 from manugarri/fix_kafka_python_doc. --- docs/structured-streaming-kafka-integration.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/structured-streaming-kafka-integration.md b/docs/structured-streaming-kafka-integration.md index 9b82e8e744..8b2f51a378 100644 --- a/docs/structured-streaming-kafka-integration.md +++ b/docs/structured-streaming-kafka-integration.md @@ -90,7 +90,7 @@ ds3.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)") # Subscribe to 1 topic ds1 = spark - .readStream() + .readStream .format("kafka") .option("kafka.bootstrap.servers", "host1:port1,host2:port2") .option("subscribe", "topic1") @@ -108,7 +108,7 @@ ds2.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)") # Subscribe to a pattern ds3 = spark - .readStream() + .readStream .format("kafka") .option("kafka.bootstrap.servers", "host1:port1,host2:port2") .option("subscribePattern", "topic.*")