This is an automated email from the ASF dual-hosted git repository. lresende pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/bahir.git
commit 971a88e66ed43d1d4c0e9346cce95caf0e5019ea Author: Luciano Resende <[email protected]> AuthorDate: Tue Jun 11 14:49:37 2019 +0200 Fix warnings about undeclared variables on javadoc --- .../scala/org/apache/spark/sql/mqtt/HdfsBasedMQTTStreamSource.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sql-streaming-mqtt/src/main/scala/org/apache/spark/sql/mqtt/HdfsBasedMQTTStreamSource.scala b/sql-streaming-mqtt/src/main/scala/org/apache/spark/sql/mqtt/HdfsBasedMQTTStreamSource.scala index fd39557..d6aab23 100644 --- a/sql-streaming-mqtt/src/main/scala/org/apache/spark/sql/mqtt/HdfsBasedMQTTStreamSource.scala +++ b/sql-streaming-mqtt/src/main/scala/org/apache/spark/sql/mqtt/HdfsBasedMQTTStreamSource.scala @@ -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 = {
