org.apache.spark.streaming.kafka

Interface HasOffsetRanges

public interface HasOffsetRanges

Represents any object that has a collection of OffsetRanges. This can be used to 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

Methods

Modifier and Type	Method and Description
OffsetRange[]	offsetRanges()

Method Detail

offsetRanges

OffsetRange[] offsetRanges()