From ea313ae236d8ace7a553434093aea9d6bea2b0b6 Mon Sep 17 00:00:00 2001 From: manugarri Date: Tue, 7 Feb 2017 17:50:43 +0100 Subject: [PATCH 1/2] remove parenthesis in readStream() on kafka structured streaming doc --- docs/structured-streaming-kafka-integration.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/structured-streaming-kafka-integration.md b/docs/structured-streaming-kafka-integration.md index 9b82e8e7449a1..0a382ab8af0aa 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") From 5d50a31ec4d02140947d848923963d4291ea1979 Mon Sep 17 00:00:00 2001 From: manugarri Date: Tue, 7 Feb 2017 18:44:33 +0100 Subject: [PATCH 2/2] remove another typo in the doc --- docs/structured-streaming-kafka-integration.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/structured-streaming-kafka-integration.md b/docs/structured-streaming-kafka-integration.md index 0a382ab8af0aa..8b2f51a378dc7 100644 --- a/docs/structured-streaming-kafka-integration.md +++ b/docs/structured-streaming-kafka-integration.md @@ -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.*")