SCALA ITERATOR(迭代器) 技术教程文章

java – Scala Seq.grouped吃了我的迭代器【代码】

作为一名C#程序员,我对Java / Scala迭代器设计有一个粗略的理解. 我试图(懒惰 – 因为源可能很大)从RecordReader(在某些第三方库)中读取记录.我需要每100条记录做一些额外的工作.for (group <- reader.iterator.zipWithIndex.grouped(100)) {for ((record, i) <- group) {println(i + "|" + record.key)}// ... }这给了我每次重复的最后记录. 如果我不使用分组,它工作正常,我得到每个记录.我错过了关于延迟流式传输或Java迭代器的一...