spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t...@apache.org
Subject spark git commit: [DOCS] [STREAMING] make the existing parameter docs for OffsetRange ac…
Date Thu, 06 Aug 2015 21:37:36 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-1.5 3997dd3fd -> 8ecfb05e3


[DOCS] [STREAMING] make the existing parameter docs for OffsetRange ac…

…tually visible

Author: cody koeninger <cody@koeninger.org>

Closes #7995 from koeninger/doc-fixes and squashes the following commits:

87af9ea [cody koeninger] [Docs][Streaming] make the existing parameter docs for OffsetRange
actually visible

(cherry picked from commit 1723e34893f9b087727ea0e5c8b335645f42c295)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/8ecfb05e
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/8ecfb05e
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/8ecfb05e

Branch: refs/heads/branch-1.5
Commit: 8ecfb05e370bc80cd74bb99dc8dd9459a855312f
Parents: 3997dd3
Author: cody koeninger <cody@koeninger.org>
Authored: Thu Aug 6 14:37:25 2015 -0700
Committer: Tathagata Das <tathagata.das1565@gmail.com>
Committed: Thu Aug 6 14:37:33 2015 -0700

----------------------------------------------------------------------
 .../scala/org/apache/spark/streaming/kafka/OffsetRange.scala | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/8ecfb05e/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
index f326e7f..2f8981d 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
@@ -42,16 +42,16 @@ trait HasOffsetRanges {
  * :: Experimental ::
  * Represents a range of offsets from a single Kafka TopicAndPartition. Instances of this
class
  * can be created with `OffsetRange.create()`.
+ * @param topic Kafka topic name
+ * @param partition Kafka partition id
+ * @param fromOffset Inclusive starting offset
+ * @param untilOffset Exclusive ending offset
  */
 @Experimental
 final class OffsetRange private(
-    /** Kafka topic name */
     val topic: String,
-    /** Kafka partition id */
     val partition: Int,
-    /** inclusive starting offset */
     val fromOffset: Long,
-    /** exclusive ending offset */
     val untilOffset: Long) extends Serializable {
   import OffsetRange.OffsetRangeTuple
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message