Hazelcast Jet RemoteMap 接收器是否在远程地图上进行 putTransient 调用？

Question

我有 2 个 Hazelcast 集群，均由同一个地图商店支持。 我正在尝试从一个集群 Imap 获取一些数据并将其推送到第二个集群的地图。 我想知道的是，这是否会在远程地图上发出

put

或

putTransient

调用？

Answer 1

它调用 map.putAllAsync() 进行远程地图。 参见WriteMapP.java中的代码

https://github.com/hazelcast/hazelcast/blob/master/hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteMapP.java#L140

private boolean submitPending() {
  if (buffer.isEmpty()) {
    return true;
  }
  if (!tryAcquirePermit()) {
    return false;
  }
  setCallback(map.putAllAsync(buffer));
  resetBuffer();
  return true;
}