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()