mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java [125:134]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public boolean upsertAll(String tableName, String partitionKey, Map<String, String> all,
            Duration ttl) throws IOException {
            store.putIfAbsent(tableName, new ConcurrentHashMap<>());
            SortedMap<String, String> items =
                store.get(tableName)
                    .getOrDefault(partitionKey, new ConcurrentSkipListMap<>(Comparator.reverseOrder()));
            items.putAll(all);
            store.get(tableName).put(partitionKey, items);
            return true;
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/InMemoryStore.java [61:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public boolean upsertAll(String tableName, String partitionKey, Map<String, String> all,
                             Duration ttl) throws IOException {
        store.putIfAbsent(tableName, new ConcurrentHashMap<>());
        SortedMap<String, String> items =
                store.get(tableName)
                        .getOrDefault(partitionKey, new ConcurrentSkipListMap<>(Comparator.reverseOrder()));
        items.putAll(all);
        store.get(tableName).put(partitionKey, items);
        return true;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -