|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface HasOffsetRanges
:: Experimental ::
Represents any object that has a collection of OffsetRange
s. This can be used access the
offset ranges in RDDs generated by the direct Kafka DStream (see
KafkaUtils.createDirectStream()
).
KafkaUtils.createDirectStream(...).foreachRDD { rdd =>
val offsetRanges = rdd.asInstanceOf[HasOffsetRanges].offsetRanges
...
}
Method Summary | |
---|---|
OffsetRange[] |
offsetRanges()
|
Method Detail |
---|
OffsetRange[] offsetRanges()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |