Java-friendliness is the usual reason, though I don't know if that's the reason here.
On Fri, Jul 8, 2016 at 10:42 AM, Mikael Ståldal <mikael.stal...@magine.com> wrote: > Is there any particular reason for the offsetRanges parameter to > KafkaUtils.createRDD is Array[OffsetRange]? Why not Seq[OffsetRange]? > > > http://spark.apache.org/docs/latest/api/scala/org/apache/spark/streaming/kafka/KafkaUtils$.html > > > https://github.com/apache/spark/blob/master/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala#L248 > > -- > [image: MagineTV] > > *Mikael Ståldal* > Senior software developer > > *Magine TV* > mikael.stal...@magine.com > Grev Turegatan 3 | 114 46 Stockholm, Sweden | www.magine.com > > Privileged and/or Confidential Information may be contained in this > message. If you are not the addressee indicated in this message > (or responsible for delivery of the message to such a person), you may not > copy or deliver this message to anyone. In such case, > you should destroy this message and kindly notify the sender by reply > email. >
