Skip to content

Commit 216fe0e

Browse files
committed
Fixed wrong links
1 parent 76eaeb4 commit 216fe0e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

docs/streaming-custom-receivers.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ JavaDStream<String> words = lines.flatMap(new FlatMapFunction<String, String>()
186186
...
187187
{% endhighlight %}
188188

189-
The full source code is in the example [JavaCustomReceiver.java](https://github.com/apache/spark/blob/master/examples/src/main/java/org/apache/spark/streaming/examples/JavaCustomReceiver.java).
189+
The full source code is in the example [JavaCustomReceiver.java](https://github.com/apache/spark/blob/master/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java).
190190

191191
</div>
192192
</div>
@@ -215,7 +215,7 @@ And a new input stream can be created with this custom actor as
215215
val lines = ssc.actorStream[String](Props(new CustomActor()), "CustomReceiver")
216216
{% endhighlight %}
217217

218-
See [ActorWordCount.scala](https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala)
218+
See [ActorWordCount.scala](https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala)
219219
for an end-to-end example.
220220

221221

0 commit comments

Comments
 (0)