assertEquals(data1.getUrl(), data2.getUrl());
        assertEquals(data1.getWeight(), data2.getWeight(), 0.001f);

        assertEquals(data2.getMethod(), data3.getMethod());
        assertEquals(data2.getUrl(), data3.getUrl());
        assertEquals(data2.getWeight(), data3.getWeight(), 0.001f);
    }

    public void test_overwritingValues() {

        final OpenSearchUrlQueue first = urlQueueService.poll(sessionId);
        assertNotNull(first);
        // Weight should be highest
        assertTrue(first.getWeight() >= 1);

        urlQueueService.delete(sessionId);
    }

    public void test_offerAll_emptyListTx() {
        final String sessionId = "offer_session1";
        final List<OpenSearchUrlQueue> emptyList = new ArrayList<>();

                }
                throw new ExtractException("Failed to extract the content using available extractors.");
            }

            @Override
            public int getWeight() {
                return extractors[0].getWeight();
            }
        };
    }

    /**
     * Retrieves all extractors for the specified key.
     * @param key The key associated with the extractors.

    /**
     * Returns the weight of the extractor.
     * The default implementation returns a weight of 1.
     *
     * @return the weight of the extractor
     */
    default int getWeight() {
        return 1;
    }

              } else if (map.isExpired(e, now)) {
                // This is a duplicate check, as preWriteCleanup already purged expired
                // entries, but let's accommodate an incorrect expiration queue.
                enqueueNotification(
                    entryKey, hash, value, valueReference.getWeight(), RemovalCause.EXPIRED);

                .modifier(FieldValueFactorFunction.Modifier.LOG2P)
                .setWeight(1.0F)));
        flist.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(ScoreFunctionBuilders.fieldValueFactorFunction(FieldNames.QUERY_FREQ)
                .missing(0.1f)
                .modifier(FieldValueFactorFunction.Modifier.LOG2P)
                .setWeight(1.0F)));
        flist.add(new FunctionScoreQueryBuilder.FilterFunctionBuilder(

    /**
     * Constructs a new MarkdownExtractor and initializes the parser.
     */
    public MarkdownExtractor() {
        super();
        initializeParser();
    }

    @Override
    public int getWeight() {
        return 2; // Higher priority than TikaExtractor (weight=1)
    }

    /**
     * Initializes the Markdown parser with extensions.
     */
    protected void initializeParser() {

         *
         * @param weight the weight to set
         * @return the current RequestDataContext instance
         */
        public RequestDataContext weight(final float weight) {
            data.setWeight(weight);
            return this;
        }

        /**
         * Builds and returns the constructed RequestData object.
         *
         * @return the constructed RequestData object
         */

    /**
     * Constructs a new CsvExtractor.
     */
    public CsvExtractor() {
        super();
    }

    @Override
    public int getWeight() {
        return 2; // Higher priority than TikaExtractor (weight=1)
    }

    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {
        validateInputStream(in);

    protected int maxArrayElements = 100;

    /**
     * Constructs a new JsonExtractor.
     */
    public JsonExtractor() {
        super();
    }

    @Override
    public int getWeight() {
        return 2; // Higher priority than TikaExtractor (weight=1)
    }

    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {
        validateInputStream(in);