Using data streamer for local entries update

[djm132]

Hi,

Is it safe to parallel update local node entries with data streamer ? Here
is the benchmark code, it seems that addData() much faster than individual
put().


val res = Node.ignite.compute(project.indexNodes).broadcast<Long> {
  var n = 0L
  Node.ignite.dataStreamer<String, IndexRecord>(project.index.name).use { ds
->
    ds.allowOverwrite(true)
    project.index.localEntries(CachePeekMode.PRIMARY).forEach { it ->
      it.value.status = IndexRecordStatus.COMPLETED
      ds.addData(it.value.reqKey, it.value)
      n++
    }
  }

  println("Updated $n records")
  n
}




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/