org.apache.spark.streaming.kafka
Interface HasOffsetRanges

public interface HasOffsetRanges

:: Experimental :: Represents any object that has a collection of OffsetRanges. 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

offsetRanges

OffsetRange[] offsetRanges()