public DistributedMember getOwnerForKey(InternalRegion r, KeyInfo key) {
    DistributedMember m = r.getOwnerForKey(key);
    if (m == null) {
      m = getCache().getDistributedSystem().getDistributedMember();
    }
    return m;
  }
For distributed transactions, this divides the user's removeAll operation into multiple per
bucket removeAll ops(with entries to be removed from that bucket) and then fires those using
using appropriate TXStateStub (for target that host the corresponding bucket)
geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnCoordinator.java