Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for setScroll (0.09 sec)

  1. src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java

            final String actualIndex = index + "." + type.toLowerCase(Locale.ENGLISH);
            try {
                SearchResponse response = client.prepareSearch().setIndices(actualIndex).setScroll(settings.getScrollTimeout())
                        .setQuery(QueryBuilders.termQuery(FieldNames.ARRAY_KEY, key)).setSize(500).execute()
                        .actionGet(settings.getSearchTimeout());
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            }
    
            final List<SuggestItem> updateItems = new ArrayList<>();
            SearchResponse response = client.prepareSearch(index).setSize(500).setScroll(settings.getScrollTimeout())
                    .setQuery(QueryBuilders.rangeQuery(FieldNames.DOC_FREQ).gte(1)).execute().actionGet(settings.getSearchTimeout());
            String scrollId = response.getScrollId();
            try {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java

            });
        }
    
        protected void delegateBulkRequest(final ConditionBean cb, Function<SearchHits, Boolean> handler) {
            final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()).setScroll(scrollForCursor).setSize(sizeForCursor);
            final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb;
            if (esCb.getPreference() != null) {
                builder.setPreference(esCb.getPreference());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

            sessionCache.clear();
        }
    
        @Override
        public void updateSessionId(final String oldSessionId, final String newSessionId) {
            SearchResponse response = getClient().get(c -> c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout))
                    .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize)
                    .execute());
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

            });
        }
    
        protected void delegateBulkRequest(final ConditionBean cb, Function<SearchHits, Boolean> handler) {
            final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()).setScroll(scrollForCursor).setSize(sizeForCursor);
            final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb;
            if (esCb.getPreference() != null) {
                builder.setPreference(esCb.getPreference());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

            });
        }
    
        protected void delegateBulkRequest(final ConditionBean cb, Function<SearchHits, Boolean> handler) {
            final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()).setScroll(scrollForCursor).setSize(sizeForCursor);
            final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb;
            if (esCb.getPreference() != null) {
                builder.setPreference(esCb.getPreference());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                final QueryBuilder queryBuilder) {
            try {
                SearchResponse response = client.prepareSearch(index).setQuery(queryBuilder).setSize(500).setScroll(settings.getScrollTimeout())
                        .execute().actionGet(settings.getSearchTimeout());
                String scrollId = response.getScrollId();
                try {
                    while (scrollId != null) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

            SearchResponse response = client.prepareSearch(analyzerSettingsIndexName)
                    .setQuery(QueryBuilders.termQuery(FieldNames.ANALYZER_SETTINGS_TYPE, FIELD_ANALYZER_MAPPING))
                    .setScroll(settings.getScrollTimeout()).execute().actionGet(settings.getSearchTimeout());
            String scrollId = response.getScrollId();
            try {
                while (scrollId != null) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            return this;
        }
    
        public int deleteByQuery(final String index, final String type, final QueryBuilder queryBuilder) {
            SearchResponse response =
                    get(c -> c.prepareSearch(index).setScroll(scrollForDelete).setSize(sizeForDelete).setQuery(queryBuilder).execute());
            String scrollId = response.getScrollId();
            int count = 0;
            try {
                while (scrollId != null) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

        }
    
        public void delete(final Consumer<SearchRequestBuilder> callback) {
            SearchResponse response = getClient().get(c -> {
                final SearchRequestBuilder builder = c.prepareSearch(index).setScroll(new TimeValue(scrollTimeout)).setSize(scrollSize);
                callback.accept(builder);
                return builder.execute();
            });
            String scrollId = response.getScrollId();
            try {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K bytes
    - Viewed (0)
Back to top