// Case where the initial dataMap also contains overwrite keys
        dataMap.put("m", "M0");
        dataMap.put("n.overwrite", "N0_old");

        Map<String, Object> responseDataMap = new HashMap<>();
        responseDataMap.put("m.overwrite", "M1");
        responseDataMap.put("n.overwrite", "N1");
        responseDataMap.put("p", "P1");

        indexUpdateCallback.mergeResponseData(dataMap, responseDataMap);

    unfiltered.put("foo", 55556);
    unfiltered.put("badkey", 1);
    return Multimaps.filterEntries(unfiltered, ENTRY_PREDICATE);
  }

  private static final Predicate<String> KEY_PREDICATE = key -> !Objects.equals(key, "badkey");

  public void testFilterKeys() {
    Multimap<String, Integer> unfiltered = HashMultimap.create();
    unfiltered.put("foo", 55556);
    unfiltered.put("badkey", 1);

  }

  @Test fun taskFailsWithUncheckedException() {
    queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) {
      log.put("failing task running")
      throw RuntimeException("boom!")
    }

    queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) {
      log.put("normal task running")
      return@schedule -1L
    }

    queue.idleLatch().await(500, TimeUnit.MILLISECONDS)

        Map<String, Object> innerMap = new HashMap<>();
        innerMap.put("innerKey", "innerValue");
        nestedParams.put("nested", innerMap);

        assertNotNull(queryRescorer.evaluate(nestedParams));

        // Test without nested parameters
        Map<String, Object> flatParams = new HashMap<>();
        flatParams.put("flat", "value");
        assertNull(queryRescorer.evaluate(flatParams));
    }

        for (Element element : keys) {
          map.put(element, element);
        }
        return map;
      }
    },
    LinkedHM {
      @Override
      Map<Element, Element> create(Collection<Element> keys) {
        Map<Element, Element> map = new LinkedHashMap<>();
        for (Element element : keys) {
          map.put(element, element);
        }
        return map;
      }
    },

        context.put("thread", Thread.currentThread().getName());
        context.put("threadId", Thread.currentThread().getId());

        String sessionId = MDC.get("sessionId");
        if (sessionId != null) {
            context.put("sessionId", sessionId);
        }
        String userId = MDC.get("userId");
        if (userId != null) {
            context.put("userId", userId);
        }
    }

// has delete marker replication or delete replication (MinIO extension to allow deletes where version id
// is specified) enabled.
// Similar to bucket replication for PUT operation, soft delete (a.k.a setting delete marker) and
// permanent deletes (by specifying a version ID in the delete operation) have three states "Pending", "Complete"

        source.put(FieldNames.TEXT, "parsed text");
        source.put(FieldNames.QUERY_FREQ, 75L);
        source.put(FieldNames.DOC_FREQ, 35L);
        source.put(FieldNames.USER_BOOST, 2.0f);
        source.put(FieldNames.READING_PREFIX + "0", Arrays.asList("reading1", "reading2"));
        source.put(FieldNames.READING_PREFIX + "1", Arrays.asList("reading3"));
        source.put(FieldNames.FIELDS, Arrays.asList("field1"));

                map.put("id", item.getEncodedId());
                map.put("path", item.getPath());
                map.put("name", item.getName());
                map.put("hashCode", item.hashCode());
                map.put("size", item.getSize());
                map.put("directory", item.isDirectory());
                if (!item.isDirectory()) {
                    map.put("lastModified", item.getLastModified());

        Map<String, Object> params = new HashMap<>();
        params.put("string_param", "test_value");
        params.put("int_param", 42);
        params.put("double_param", 3.14);
        params.put("boolean_param", true);

        Map<String, String> nestedMap = new HashMap<>();
        nestedMap.put("nested_key", "nested_value");
        params.put("nested_param", nestedMap);