*
     * @return the session identifier
     */
    String getSessionId();

    /**
     * Sets the session identifier.
     *
     * @param sessionId the session identifier
     */
    void setSessionId(String sessionId);

    /**
     * Returns the rule identifier.
     *
     * @return the rule identifier
     */
    String getRuleId();

    /**
     * Sets the rule identifier.
     *

     */
    @Override
    public void offerAll(final String sessionId, final List<OpenSearchUrlQueue> urlQueueList) {
        if (logger.isDebugEnabled()) {
            logger.debug("Offering URL: Session ID: {}, UrlQueue: {}", sessionId, urlQueueList);
        }
        final List<UrlQueue<String>> targetList = new ArrayList<>(urlQueueList.size());
        for (final UrlQueue<String> urlQueue : urlQueueList) {

        // Default constructor
    }

    /**
     * Queue index name.
     */
    protected String queueIndex = ".crawler.queue";

    /**
     * Data index name.
     */
    protected String dataIndex = ".crawler.data";

    /**
     * Filter index name.
     */
    protected String filterIndex = ".crawler.filter";

    /**
     * Number of shards for the queue index.
     */

     */
    @Override
    public boolean equals(final Object obj) {
        return factory.equals(obj);
    }

    /**
     * Returns a string representation of this wrapper.
     * @return A string representation.
     */
    @Override
    public String toString() {
        return "CrawlerClientFactoryWrapper{" + "factory=" + factory + '}';
    }

     * Normalizes the given text.
     * @param text The text to normalize
     * @param field The field name
     * @param langs The language
     * @return The normalized text
     */
    String normalize(String text, String field, String... langs);

    /**
     * Retrieves the location (URL) of the sitemap.
     *
     * @return the location of the sitemap as a String.
     */
    String getLoc();

    /**
     * Retrieves the last modification date of the sitemap.
     *
     * @return A string representing the last modification date.
     */
    String getLastmod();

        return searchResponse.getHits().getTotalHits().value();
    }

    private String getSearchAlias(final String index) {
        return index;
    }

    private String getUpdateAlias(final String index) {
        return index + ".update";
    }

    private String createIndexName(final String index) {
        return index + '.' + ZonedDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));

String[] tags = new String[]{"technology", "search"};
String[] roles = new String[]{"admin", "user"};

SuggestItem item = new SuggestItem(
    new String[]{"Search Engine", "検索エンジン"}, // text variations
    readings,                                      // pronunciation readings
    1,                                            // boost score
    tags,                                         // categorization tags

        address = System.getProperty(HTTP_ADDRESS, "localhost:9200").trim();
        final String targets = System.getProperty(TARGET_INDICES);
        if (StringUtil.isNotBlank(targets)) {
            targetIndices = Arrays.stream(targets.split(",")).map(String::trim).toArray(n -> new String[n]);
        }
    }

    /**
     * Sets the address of the OpenSearch instance.
     * @param address The address.
     */

    /**
     * The encoding for text.
     */
    protected String encoding = Constants.UTF_8;

    /**
     * Creates a new TextExtractor instance.
     */
    public TextExtractor() {
        super();
    }

    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {
        if (in == null) {