ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[MINOR][DOC] Remove parenthesis in readStream() on kafka structured streaming doc

Browse source 
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 <manuel.garrido.pena@gmail.com>

Closes #16836 from manugarri/fix_kafka_python_doc.
This commit is contained in:
manugarri 2017-02-07 21:45:33 -08:00 committed by Shixiong Zhu
parent 266c1e7309
commit 5a0569ce69
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
docs/structured-streaming-kafka-integration.md
View file

@ -90,7 +90,7 @@ ds3.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)")
# Subscribe to 1 topic # Subscribe to 1 topic
ds1 = spark ds1 = spark
.readStream() .readStream
.format("kafka") .format("kafka")
.option("kafka.bootstrap.servers", "host1:port1,host2:port2") .option("kafka.bootstrap.servers", "host1:port1,host2:port2")
.option("subscribe", "topic1") .option("subscribe", "topic1")
@ -108,7 +108,7 @@ ds2.selectExpr("CAST(key AS STRING)", "CAST(value AS STRING)")
# Subscribe to a pattern # Subscribe to a pattern
ds3 = spark ds3 = spark
.readStream() .readStream
.format("kafka") .format("kafka")
.option("kafka.bootstrap.servers", "host1:port1,host2:port2") .option("kafka.bootstrap.servers", "host1:port1,host2:port2")
.option("subscribePattern", "topic.*") .option("subscribePattern", "topic.*")