Skip to content
Permalink
Browse files
Fix warnings about undeclared variables on javadoc
  • Loading branch information
lresende committed Jun 12, 2019
1 parent 843cd71 commit 971a88e66ed43d1d4c0e9346cce95caf0e5019ea
Showing 1 changed file with 3 additions and 3 deletions.
@@ -321,9 +321,9 @@ class HdfsBasedMQTTStreamSource(
}

/**
* Returns the data that is between the offsets (`start`, `end`].
* The batch return the data in file ${checkpointPath}/receivedMessages/${end}.
* `Start` and `end` value have the relationship: `end value` = `start valud` + 1,
* Returns the data that is between the offsets (`start`, `end`).
* The batch return the data in file {checkpointPath}/receivedMessages/{end}.
* `Start` and `end` value have the relationship: `end value` = `start value` + 1,
* if `start` is not None.
*/
override def getBatch(start: Option[Offset], end: Offset): DataFrame = {

0 comments on commit 971a88e

Please sign in to comment.