如何从Elasticsearch中检索存储的Scala可变集



嗨,我正在踩一个ID字段,一个弹性搜索中的Scala可变设置,例如这种方式

var genreIdSet = scala.collection.mutable.Set[Int]()
genreIdSet+=1
genreIdSet+=2
genreIdSet+=3
bulkRequest.add(client.prepareIndex("testdb","test","123")
        .setSource(jsonBuilder()
                   .startObject()
                       .field("uuid","123")
                       .field("GenreIdSet",genreIdSet)
                   .endObject()    
        )
)

现在我想检索此文档是代码

val get=client.prepareGet("testdb","test","123")
        .setOperationThreaded(false)
        .setFields("uuid","GenreIdSet")
        .execute()
        .actionGet()
    id=get.getField("uuid").getValue.toString().toInt
    var a=get.getField("GenreIdSet").getValue.toString

我将获得以下输出

ID is 123
GenreIdSet is Set(1, 2, 3)

我想穿越此集合并将其值(例如:1 2 3)存储在新的Scala Mutable集合中,我该如何实现此目的,请帮助我,我也是Elasticsearch的新手,并且我正在获得Elasticsearch Java API的帮助。请帮助谢谢

您可以使用数组方法

在elasticsearch中插入scala可变集
var genreIdSet = scala.collection.mutable.Set[Int]()
genreIdSet+=1
genreIdSet+=2
genreIdSet+=3
var xb:XContentBuilder=XContentFactory.jsonBuilder().startObject().field("uuid",artistImpl.getUuid)
      xb.startArray("GetGenreIdSet")
      for(n<-genreIdSet)
      {
          xb.value(n)  
      }
      xb.endArray()
      xb.endObject()

val bulkRequest=client.prepareBulk()
bulkRequest.add(client.prepareIndex("testdb","test","123")
        .setSource(xb)
)

检索此数组并将其值存储到新的Scala可变集中,这是代码

 id=get.getField("uuid").getValue.toString().toInt
        var a=get.getField("GetGenreIdSet").getValues.toArray()
           for(number<-a)
           {
               genreIdSet+=number.toString().toInt
           }

最新更新