Does Hazelcast Jet remoteMap sink make a putTransient call on the remote map?

Question

I have 2 Hazelcast clusters both backed by same map Store. I am trying to get some data from one cluster Imap and push it to the map of the second cluster. What I want to know is if this makes a put or putTransient call on the remote map?

Answer 1

It calls map.putAllAsync() for remote map. See the code in 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;
}