}

    /**
     * Adds a filter to the query processing chain.
     * The filter chain is recreated after adding the filter.
     *
     * @param filter the filter to add
     */
    public void addFilter(final Filter filter) {
        filterList.add(filter);
        createFilterChain();
    }

    /**
     * Creates the filter chain by combining all registered filters.

    /**
     * Adds a boost function with a filter to modify document scoring during search.
     * This method adds a boost function that applies only to documents matching the filter.
     *
     * @param filter the query filter to determine which documents the boost applies to
     * @param scoreFunction the score function to add for boosting
     */
    public void addBoostFunction(final QueryBuilder filter, final ScoreFunctionBuilder<?> scoreFunction) {

        // Verify structure:
        // Offset 0-3: Completion Filter (4 bytes)
        // Offset 4-5: FID (2 bytes)
        // Offset 6: Watch Tree (1 byte)
        // Offset 7: Reserved (1 byte)
        assertEquals(8, bytesWritten);

        // Check completion filter
        assertEquals(0x12345678, SMBUtil.readInt4(dst, 10));

        // Check FID

        urlPatterns.add("http://sample.org/.*");

        urlFilterService.addIncludeUrlFilter(sessionId, urlPatterns);

        // Verify all filters are stored
        assertEquals(3L,
                fesenClient.prepareSearch("fess_crawler.filter")
                        .setQuery(QueryBuilders.termQuery("sessionId", sessionId))
                        .setSize(0)
                        .execute()

			Rules: []Rule{
				{
					Status:                  Enabled,
					Priority:                3,
					DeleteMarkerReplication: DeleteMarkerReplication{Status: Disabled},
					DeleteReplication:       DeleteReplication{Status: Disabled},
					Filter:                  Filter{},
				},
			},
		},

                    };
                    filters.add(new PredicateVersionFilter(predicate));
                } else {
                    throw new IllegalArgumentException("Unsupported filter expression: " + expression);
                }
            }
        }
        if (filters.isEmpty()) {
            return null;
        } else if (filters.size() == 1) {
            return filters.get(0);
        } else {

     * to process and store tracking information ONLY into local repository, not to any other place. This method
     * filters out currently built artifacts, as events are fired for them as well, but their resolved artifact
     * file would point to checked out source-tree, not the local repository.
     * <p>
     * Visible for testing.
     */

        }
        for (var i = 0; i < state.filters.extraQueries.length; i++) {
            params += '&ex_q=' + encodeURIComponent(state.filters.extraQueries[i]);
        }
        return params;
    }

    /**
     * Reset all filters
     */
    function resetFilters() {
        state.filters.labels = [];
        state.filters.extraQueries = [];

     * concurrent searches across multiple searchers and fuses the results.
     *
     * @param query the search query string
     * @param params search request parameters including pagination and filters
     * @param userBean optional user information for personalized search
     * @return list of search result documents with fused ranking scores
     */

        stream(conditions.get(SearchRequestParams.AS_OCCURRENCE))
                .of(stream -> stream.filter(this::isOccurrence).findFirst().ifPresent(q -> queryBuf.insert(0, q + ":")));

        stream(conditions.get(SearchRequestParams.AS_Q))
                .of(stream -> stream.filter(q -> StringUtil.isNotBlank(q) && q.length() <= maxQueryLength)
                        .forEach(q -> queryBuf.append(' ').append(q)));