Skip to content

Commit ca19078

Browse files
committed
Minor change
1 parent f746951 commit ca19078

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

docs/streaming-custom-receivers.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ This starts with implementing a **Receiver**
1616
([Scala doc](api/scala/index.html#org.apache.spark.streaming.receiver.Receiver),
1717
[Java doc](api/java/org/apache/spark/streaming/receiver/Receiver.html)).
1818
A custom receiver must extend this abstract class by implementing two methods
19+
1920
- `onStart()`: Things to do to start receiving data.
2021
- `onStop()`: Things to do to stop receiving data.
2122

docs/streaming-programming-guide.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -762,7 +762,7 @@ that no data gets lost due to any kind of failure. This leads to two kinds of re
762762
for reliable sources, one may implement an unreliable receiver that do not go into the complexity
763763
of acknowledging correctly.
764764

765-
The details of how to write a reliable receiver is discussed in the
765+
The details of how to write a reliable receiver are discussed in the
766766
[Custom Receiver Guide](streaming-custom-receivers.html).
767767

768768
***

0 commit comments

Comments
 (0)