public Map plan()

in core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanner.java [85:100]

• 15 lines of code
• 5 McCabe index (conditional complexity)

    public Map<UUID, LeadResponse> plan() {
        Lazy<UUID, MutableLongList> toCommit = findToCommitPerNode();
        Lazy<UUID, MutableLongList> toRemove = takeToRemoveAsLazyMap();
        Map<UUID, LeadResponse> result = new HashMap<>(toCommit.keySet().size());

        for (Map.Entry<UUID, MutableLongList> entry : toCommit) {
            LongList toRemoveList = toRemove.containsKey(entry.getKey()) ? toRemove.get(entry.getKey()) : null;
            result.put(entry.getKey(), new LeadResponse(entry.getValue(), toRemoveList));
        }
        for (Map.Entry<UUID, MutableLongList> entry : toRemove) {
            if (!result.containsKey(entry.getKey())) {
                result.put(entry.getKey(), new LeadResponse(null, entry.getValue()));
            }
        }
        return result;
    }