spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zsxw...@apache.org
Subject spark git commit: [MINOR][DOC] Remove parenthesis in readStream() on kafka structured streaming doc
Date Wed, 08 Feb 2017 05:46:49 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-2.1 706d6c154 -> 4d040297f


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

Closes #16836 from manugarri/fix_kafka_python_doc.

(cherry picked from commit 5a0569ce693c635c5fa12b2de33ed3643ce888e3)
Signed-off-by: Shixiong Zhu <shixiong@databricks.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4d040297
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4d040297
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4d040297

Branch: refs/heads/branch-2.1
Commit: 4d040297f55243703463ea71d5302bb46ea0bf3f
Parents: 706d6c1
Author: manugarri <manuel.garrido.pena@gmail.com>
Authored: Tue Feb 7 21:45:33 2017 -0800
Committer: Shixiong Zhu <shixiong@databricks.com>
Committed: Tue Feb 7 21:46:41 2017 -0800

----------------------------------------------------------------------
 docs/structured-streaming-kafka-integration.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/4d040297/docs/structured-streaming-kafka-integration.md
----------------------------------------------------------------------
diff --git a/docs/structured-streaming-kafka-integration.md b/docs/structured-streaming-kafka-integration.md
index 2458bb5..208845f 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.*")


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message