final String timeout = fessConfig.getCrawlerHotthreadTimeout();
        final String type = fessConfig.getCrawlerHotthreadType();
        try {
            final SearchEngineClient esClient = ComponentUtil.getSearchEngineClient();
            final NodesHotThreadsResponse response = esClient.admin()
                    .cluster()
                    .prepareNodesHotThreads()
                    .setIgnoreIdleThreads(ignoreIdleThreads)

    /**
     * Executes the ping job.
     *
     * @return the execution result
     */
    public String execute() {
        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();

        final StringBuilder resultBuf = new StringBuilder();

        final List<LogNotificationEvent> events = helper.drainAll();
        if (events.isEmpty()) {
            return;
        }

        try {
            final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
            final String hostname = ComponentUtil.getSystemHelper().getHostname();
            final String indexName = resolveIndexName();

            ensureIndexExists(client, indexName);

        final long startTime = systemHelper.getCurrentTimeAsLong();
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();

        if (logger.isDebugEnabled()) {
            logger.debug("Adding document: url={}", dataMap.get(fessConfig.getIndexFieldUrl()));
        }

        //   required check

     * @return the number of documents processed
     */
    public static long scroll(final String index, final Function<SearchHit, Boolean> callback) {
        final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
        return client.<SearchHit> scrollSearch(index, searchRequestBuilder -> true, (searchResponse, hit) -> hit,
                hit -> callback.apply(hit));
    }

    /**

        }

        if (!fessConfig.hasNotification()) {
            return "No notification targets configured.";
        }

        final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
        final String indexName = fessConfig.getIndexLogIndex() + ".notification_queue";

        if (!client.existsIndex(indexName)) {
            return "No log notifications.";
        }

     *
     * @return a string containing the execution result or error messages
     */
    public String execute() {
        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

        final StringBuilder resultBuf = new StringBuilder();

        final String exportPath = fessConfig.getIndexExportPath();

            final OptionalThing<FessUserBean> userBean) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        return ComponentUtil.getSearchEngineClient()
                .search(fessConfig.getIndexDocumentSearchIndex(), createSearchCondition(query, params, userBean),
                        (searchRequestBuilder, execTime, searchResponse) -> {

        buf.append("},");
    }

    private void appendFesenStats(final StringBuilder buf) {
        String stats = null;
        try {
            final SearchEngineClient esClient = ComponentUtil.getSearchEngineClient();
            final NodesStatsResponse response = esClient.admin().cluster().prepareNodesStats().all().execute().actionGet(10000L);
            final XContentBuilder builder = XContentFactory.jsonBuilder();

     * @param runtime The action runtime.
     */
    public void setupAdminHtmlData(final TypicalAction action, final ActionRuntime runtime) {
        runtime.registerData("developmentMode", ComponentUtil.getSearchEngineClient().isEmbedded());
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final String installationLink = fessConfig.getOnlineHelpInstallation();