//                                                                   Map Communication
    //                                                                   =================
    @Override
    public void acceptPrimaryKeyMap(Entity entity, Map<String, ? extends Object> primaryKeyMap) {
    }

    @Override
    public void acceptAllColumnMap(Entity entity, Map<String, ? extends Object> allColumnMap) {
    }

    @Override

        // Config-defined "anchor" also appears as extra field
        assertTrue(extraFieldNames.contains("anchor"));

        @SuppressWarnings("unchecked")
        final Map<String, String> extraFieldTypes = (Map<String, String>) renderData.getDataMap().get("extraFieldTypes");
        assertNotNull(extraFieldTypes);
        assertEquals("text", extraFieldTypes.get("custom_metadata"));

    }

    /**
     * Calculates the memory size of a document data map.
     * This is useful for monitoring memory usage during indexing operations.
     *
     * @param dataMap the document data as a map of field names to values
     * @return the estimated memory size in bytes
     */
    public long calculateDocumentSize(final Map<String, Object> dataMap) {
        return MemoryUtil.sizeOf(dataMap);
    }

  vararg caCerts: X509Certificate,
) : TrustRootIndex {
  private val subjectToCaCerts: Map<X500Principal, Set<X509Certificate>>

  init {
    val map = mutableMapOf<X500Principal, MutableSet<X509Certificate>>()
    for (caCert in caCerts) {
      map.getOrPut(caCert.subjectX500Principal) { mutableSetOf() }.add(caCert)
    }
    this.subjectToCaCerts = map
  }

  override fun findByIssuerAndSignature(cert: X509Certificate): X509Certificate? {

    private Field findCachedField(Class<?> beanType, String fieldName) {
        Map<String, Field> classFieldCache = FIELD_CACHE.computeIfAbsent(beanType, this::buildFieldCache);
        return classFieldCache.get(fieldName);
    }

    /**
     * Build field cache for a class.
     */
    private Map<String, Field> buildFieldCache(Class<?> beanType) {
        Map<String, Field> fieldMap = new HashMap<>();

        JsonPath jsonPath = JsonPath.from(response);
        assertTrue(jsonPath.getInt("record_count") >= 0);

        List<Map<String, Object>> labels = jsonPath.getList("data");
        if (labels != null && !labels.isEmpty()) {
            Map<String, Object> firstLabel = labels.get(0);
            assertTrue(firstLabel.containsKey("label"), "Label should have 'label' property");

     * @param title the raw title text to process
     * @param dataMap additional data map (not currently used)
     * @return the normalized title, or empty string if title is null
     */
    public String getTitle(final ResponseData responseData, final String title, final Map<String, Object> dataMap) {
        if (title == null) {
            return StringUtil.EMPTY; // empty
        }

            // Verify the request offset equals the skip value (2)
            ArgumentCaptor<Smb2ReadRequest> cap = ArgumentCaptor.forClass(Smb2ReadRequest.class);
            verify(mockTree).send(cap.capture(), any(RequestParam.class));
            Smb2ReadRequest req = cap.getValue();

            // Reflectively inspect the private 'offset' field to assert it used the advanced fp

    private Map<String, String> createMergedProperties(MavenExecutionRequest request) {
        // this throwaway map is really ONLY to get config from (profiles + env + system + user)
        Map<String, String> mergedProps = new HashMap<>();
        mergedProps.putAll(getPropertiesFromRequestedProfiles(request));
        mergedProps.putAll(new HashMap<String, String>((Map) request.getSystemProperties()));

.
 | map(select(.unitTests) | .name)
 | to_entries
 | group_by(.key % 10)
 | map({
     name: map(.value) | join(", "),
     tasks: map(.value + ":test") | join(" "),