diff options
| author | Henry Saputra <henry@platfora.com> | 2014-02-11 14:46:22 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-02-11 14:46:22 -0800 |
| commit | ba38d9892ec922ff11f204cd4c1b8ddc90f1bd55 (patch) | |
| tree | 14c98c382dbec4098f5b5a601215d40aad89abf2 /docs | |
| parent | 4afe6ccf40223699c13665b1ed5e98d1604d3247 (diff) | |
| download | spark-ba38d9892ec922ff11f204cd4c1b8ddc90f1bd55.tar.gz spark-ba38d9892ec922ff11f204cd4c1b8ddc90f1bd55.tar.bz2 spark-ba38d9892ec922ff11f204cd4c1b8ddc90f1bd55.zip | |
Merge pull request #577 from hsaputra/fix_simple_streaming_doc.
SPARK-1075 Fix doc in the Spark Streaming custom receiver closing bracket in the class constructor
The closing parentheses in the constructor in the first code block example is reversed:
diff --git a/docs/streaming-custom-receivers.md b/docs/streaming-custom-receivers.md
index 4e27d65..3fb540c 100644
— a/docs/streaming-custom-receivers.md
+++ b/docs/streaming-custom-receivers.md
@@ -14,7 +14,7 @@ This starts with implementing NetworkReceiver(api/streaming/index.html#org.apa
The following is a simple socket text-stream receiver.
{% highlight scala %}
class SocketTextStreamReceiver(host: String, port: Int(
+ class SocketTextStreamReceiver(host: String, port: Int)
extends NetworkReceiverString
{
protected lazy val blocksGenerator: BlockGenerator =
Author: Henry Saputra <henry@platfora.com>
Closes #577 and squashes the following commits:
6508341 [Henry Saputra] SPARK-1075 Fix doc in the Spark Streaming custom receiver.
Diffstat (limited to 'docs')
| -rw-r--r-- | docs/streaming-custom-receivers.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-custom-receivers.md b/docs/streaming-custom-receivers.md index 4e27d6559c..3fb540c9fb 100644 --- a/docs/streaming-custom-receivers.md +++ b/docs/streaming-custom-receivers.md @@ -14,7 +14,7 @@ This starts with implementing [NetworkReceiver](api/streaming/index.html#org.apa The following is a simple socket text-stream receiver. {% highlight scala %} - class SocketTextStreamReceiver(host: String, port: Int( + class SocketTextStreamReceiver(host: String, port: Int) extends NetworkReceiver[String] { protected lazy val blocksGenerator: BlockGenerator = |