私はこのコードスニペットを持っています:
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
is aは、is 、isSeq[Seq[String]]
をbatchGet
返します。List[T]
T
tablez
output
Seq[TableZ]