We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 29fabb1 commit 5167f01Copy full SHA for 5167f01
streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala
@@ -116,7 +116,7 @@ private[streaming] class BlockGenerator(
116
117
/**
118
* Push a single data item into the buffer. After buffering the data, the
119
- * `BlockGeneratorListnere.onAddData` callback will be called. All received data items
+ * `BlockGeneratorListener.onAddData` callback will be called. All received data items
120
* will be periodically pushed into BlockManager.
121
*/
122
def addDataWithCallback(data: Any, metadata: Any) = synchronized {
0 commit comments