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.

                user.setSurname(user.getName());
            }

            ComponentUtil.getAuthenticationManager().insert(user);

            userBhv.insertOrUpdate(user, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });

            if (logger.isInfoEnabled()) {
                logger.info("User {} completed successfully: username={}, id={}", isUpdate ? "update" : "create", username, user.getId());

     * @param scheduledJob The scheduled job to delete.
     */
    public void delete(final ScheduledJob scheduledJob) {
        scheduledJobBhv.delete(scheduledJob, op -> {
            op.setRefreshPolicy(Constants.TRUE);
        });
        ComponentUtil.getJobHelper().remove(scheduledJob);
    }

    /**
     * Sets up the list condition for the scheduled job query.

        badWordBhv.insertOrUpdate(badWord, op -> op.setRefreshPolicy(Constants.TRUE));

    }

    /**
     * Deletes a bad word.
     * @param badWord The bad word to delete.
     */
    public void delete(final BadWord badWord) {

        badWordBhv.delete(badWord, op -> op.setRefreshPolicy(Constants.TRUE));

    }

    /**

     *
     * @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

                    .setIndex(index)
                    .setId(id)
                    .setSource(source)
                    .setOpType(opType)
                    .setRefreshPolicy(RefreshPolicy.IMMEDIATE)
                    .execute());
            setId(target, id);
            return response;
        } catch (final OpenSearchStatusException e) {

                                bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId()));
                            }
                            return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute();
                        });
                        if (response.hasFailures()) {
                            logger.warn(response.buildFailureMessage());
                        }

        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.
     */

                            upsertMap.put(fessConfig.getIndexFieldFavoriteCount(), 1);
                            builder.setUpsert(upsertMap);
                            builder.setRefreshPolicy(Constants.TRUE);
                        });

                        writeJsonResponse(HttpServletResponse.SC_CREATED, escapeJsonKeyValue(RESULT_FIELD, "created"));

                    })

        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();