我應該使用咖喱功能嗎？

Question

我有這樣的代碼片段：

val chunks = blob.map(_.id).distinct.grouped(100).toSeq 
val output = (for (chunk <- chunks) yield { 
    MyDataStore.batchGet("tablez", chunk.asJava, classOf[TableZ], true).asScala }).flatten 

我想將其轉換成作爲參數blob.map(_.id).distinct和MyDataStore.batchGet("tablez", chunk.asJava, classOf[TableZ], true).asScala

我想，也許咖喱的功能，但不能確定語法的通用方法。

只是爲了澄清，chunks是Seq[Seq[String]]，batchGet返回List[T]其中T是tablez，output是Seq[TableZ]。

Answer 1

我覺得下面的工作：

def getInGroups[T,U](ids: Seq[T], groupSize: Int = 100)(getter: Seq[T] => Seq[U]): Seq[U] = { 
    ids.grouped(groupSize).flatMap{ chunk => getter(chunk) }.toSeq 
} 

稱其爲

getInGroups(blob.map(_.id).distinct){ chunk => 
    MyDataStore.batchGet("tablez", chunk.asJava, classOf[TableZ], true).asScala 
}