Skip to content
Snippets Groups Projects
Commit 1723e348 authored by cody koeninger's avatar cody koeninger Committed by Tathagata Das
Browse files

[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
parent 0a078303
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment