You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2019/06/12 20:32:07 UTC

[bahir] 02/02: Fix warnings about undeclared variables on javadoc

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 <lr...@apache.org>
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 = {