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 = {