{"attributes":{"description":"","kibanaSavedObjectMeta":{"searchSourceJSON":"{\"query\":{\"query\":\"\",\"language\":\"kuery\"},\"filter\":[],\"indexRefName\":\"kibanaSavedObjectMeta.searchSourceJSON.index\"}"},"title":"search-query-counts-per-sec","uiStateJSON":"{}","version":1,"visState":"{\"title\":\"search-query-counts-per-sec\",\"type\":\"histogram\",\"params\":{\"type\":\"hi...

            .filter(
                sourceSet -> sourceSet.getName().equals(SourceSet.MAIN_SOURCE_SET_NAME)
                    || sourceSet.getName().equals(SourceSet.TEST_SOURCE_SET_NAME)
            )
            .map(sourceSet -> sourceSet.getOutput().getClassesDirs())
            .reduce(FileCollection::plus)
            .orElse(getProject().files())
            .filter(File::exists);
    }

				return
			}
		case "b":
			z.bucket, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "bucket")
				return
			}
		case "flt":
			z.filter, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "filter")
				return
			}
		case "id":
			z.id, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "id")
				return
			}
		case "err":

                        .filter(container -> container.element != null),
                // Profile builds
                root.child(PROFILES).stream()
                        .flatMap(profiles -> profiles.children(PROFILE))
                        .map(profile -> new BuildContainer(profile.child(BUILD).orElse(null), "profile build"))
                        .filter(container -> container.element != null));

        return stream(ex_q).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
    }

    @Override
    public Map<String, String[]> getFields() {
        return fields;
    }

    @Override
    public String[] getLanguages() {
        return stream(lang).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
    }

//go:build !(windows || js || wasip1)

package main

import (
	"regexp"
	"strings"
	"testing"
)

func TestExitCodeFilter(t *testing.T) {
	// Write text to the filter one character at a time.
	var out strings.Builder
	f, exitStr := newExitCodeFilter(&out)
	// Embed a "fake" exit code in the middle to check that we don't get caught on it.
	pre := "abc" + exitStr + "123def"

        assertEquals(BoolQueryBuilder.class, queryBuilder.getClass());

        called.set(false);
        final AtomicBoolean calledFirst = new AtomicBoolean(false);
        queryProcessor.addFilter(new QueryProcessor.Filter() {
            @Override
            public QueryBuilder execute(QueryContext context, Query query, float boost, FilterChain chain) {
                calledFirst.set(true);
                assertFalse(called.get());

     * @param items The suggest items to index
     * @param badWords The list of bad words to filter against
     * @return The SuggestIndexResponse
     */
    public SuggestIndexResponse index(final String index, final SuggestItem[] items, final String[] badWords) {
        final SuggestItem[] filteredItems = Stream.of(items).filter(item -> !item.isBadWord(badWords)).toArray(SuggestItem[]::new);

        if (logger.isDebugEnabled()) {

     *
     * @param searchRequestType the type of search request
     * @param seed the seed value for popular word generation
     * @param tags array of tags to filter results
     * @param roles array of roles to filter results
     * @param fields array of fields to search in
     * @param excludes array of words to exclude from results
     * @return list of popular words matching the criteria
     */

    @TaskAction
    public void executeTask() {
        findAndDeleteFiles(
            this.gitWrapper,
            files -> files.stream().filter(each -> each.delete() == false).collect(Collectors.toSet()),
            QualifiedVersion.of(VersionProperties.getElasticsearch()),
            this.getChangelogs().getFiles(),
            this.dryRun,
            this.rootDir
        );
    }

    @VisibleForTesting