Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for setRefreshPolicy (0.09 sec)

  1. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

                    list.removeAll(matchedList);
                    elevateWordToLabelBhv.batchInsert(newList, op -> {
                        op.setRefreshPolicy(Constants.TRUE);
                    });
                    elevateWordToLabelBhv.batchDelete(list, op -> {
                        op.setRefreshPolicy(Constants.TRUE);
                    });
                }
            }
        }
    
        /**
         * Deletes an elevate word from the system.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

         */
        public void store(final CrawlingInfo crawlingInfo) {
            setupStoreCondition(crawlingInfo);
    
            crawlingInfoBhv.insertOrUpdate(crawlingInfo, op -> op.setRefreshPolicy(Constants.TRUE));
    
        }
    
        /**
         * Deletes a crawling information record and all its associated parameters.
         * First deletes all related CrawlingInfoParam records, then deletes the main record
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/JobHelper.java

         *
         * @param jobLog the job log entry to store
         */
        public void store(final JobLog jobLog) {
            ComponentUtil.getComponent(JobLogBhv.class).insertOrUpdate(jobLog, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
        }
    
        /**
         * Starts a monitor task for tracking job execution.
         *
         * @param jobLog the job log to monitor
         * @return the timeout task for monitoring
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

                        .setIndex(index)
                        .setId(id)
                        .setSource(source)
                        .setOpType(opType)
                        .setRefreshPolicy(RefreshPolicy.IMMEDIATE)
                        .execute());
                setId(target, id);
                return response;
            } catch (final OpenSearchStatusException e) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                                    bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId()));
                                }
    
                                return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute();
                            });
                            if (response.hasFailures()) {
                                logger.warn(response.buildFailureMessage());
                            }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

            final SearchLogBhv searchLogBhv = ComponentUtil.getComponent(SearchLogBhv.class);
            searchLogBhv.batchUpdate(searchLogList, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
        }
    
        /**
         * Processes the click log queue.
         *
         * @param queue The click log queue.
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 26.3K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            runner.client()
                    .prepareIndex()
                    .setIndex(suggester.settings().analyzer().getAnalyzerSettingsIndexName())
                    .setSource(analyzerMapping)
                    .setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL)
                    .execute()
                    .actionGet();
            suggester.settings().analyzer().init();
    
            SuggestSettings settings = suggester.settings();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
Back to top