如何在Couchbase Java SDK 3.x中使用Scala中的JsonDocument？

omvjsjqw 于 2023-06-29 发布在 Scala

关注(0)|答案(1)|浏览(131)

我正在尝试从Couchbase Java-sdk 2.7.23迁移到3.x。无法在Scala中使用以下命令解析flatMap。
从Couchbase获取多个文档时无法解析flatMap（）

val reactiveCollection = bucket.scope("default").collection("default").reactive()
val docsToFetch = util.Arrays.asList("doc1", "doc2").toList

val fetchedResult: List[GetResult] = Flux.fromIterable(docsToFetch)
  .flatMap(key => reactiveCollection.get(key))
  .collectList()
  .block()

scala

来源：https://stackoverflow.com/questions/76570252/how-to-use-jsondocument-in-scala-with-couchbase-java-sdk-3-x

1条答案

按热度按时间

xa9qqrwz1#

flatMap函数没有任何问题。你需要做的唯一的事情就是把java列表转换成scala列表，如下所示

val reactiveCollection = bucket.scope("default").collection("default").reactive
  val docsToFetch: util.List[String] = java.util.Arrays.asList("doc1", "doc2")

  import scala.collection.JavaConverters._

  val fetchedResult: List[GetResult] = Flux.fromIterable(docsToFetch)
    .flatMap { key => reactiveCollection.get(key) }
    .collectList()
    .block().asScala.toList

赞(0）回复(0）举报 2023-06-29

我来回答

如何在Couchbase Java SDK 3.x中使用Scala中的JsonDocument？

1条答案

相关问题

热门标签

最新问答