Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for OpenSearchAccessException (0.14 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/exception/OpenSearchAccessException.java

     */
    package org.codelibs.fess.crawler.exception;
    
    public class OpenSearchAccessException extends CrawlerSystemException {
    
        private static final long serialVersionUID = 1L;
    
        public OpenSearchAccessException(final String message) {
            super(message);
        }
    
        public OpenSearchAccessException(final String message, final Throwable cause) {
            super(message, cause);
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 1010 bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

                throw new OpenSearchAccessException("Failed to convert " + target + " to JSON.", e);
            }
        }
    
        protected RefreshResponse refresh() {
            try {
                return getClient().get(c -> c.admin().indices().prepareRefresh(index).execute());
            } catch (final Exception e) {
                throw new OpenSearchAccessException("Failed to refresh.", e);
            }
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchAccessResultData.java

     */
    package org.codelibs.fess.crawler.entity;
    
    import java.io.IOException;
    import java.util.Map;
    
    import org.codelibs.core.misc.Base64Util;
    import org.codelibs.fess.crawler.exception.OpenSearchAccessException;
    import org.opensearch.core.xcontent.ToXContent;
    import org.opensearch.core.xcontent.XContentBuilder;
    
    public class OpenSearchAccessResultData extends AccessResultDataImpl<String> implements ToXContent {
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

    import org.codelibs.fess.crawler.entity.AccessResult;
    import org.codelibs.fess.crawler.entity.OpenSearchUrlQueue;
    import org.codelibs.fess.crawler.entity.UrlQueue;
    import org.codelibs.fess.crawler.exception.OpenSearchAccessException;
    import org.codelibs.fess.crawler.service.UrlQueueService;
    import org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig;
    import org.opensearch.action.DocWriteRequest.OpType;
    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. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

    import org.codelibs.core.beans.util.BeanUtil;
    import org.codelibs.fess.crawler.entity.OpenSearchAccessResult;
    import org.codelibs.fess.crawler.entity.OpenSearchAccessResultData;
    import org.codelibs.fess.crawler.exception.OpenSearchAccessException;
    import org.codelibs.fess.crawler.service.DataService;
    import org.codelibs.fess.crawler.util.AccessResultCallback;
    import org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

    import org.apache.commons.lang3.RandomUtils;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.fesen.client.HttpClient;
    import org.codelibs.fess.crawler.exception.OpenSearchAccessException;
    import org.opensearch.OpenSearchException;
    import org.opensearch.action.ActionRequest;
    import org.opensearch.action.ActionType;
    import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
Back to top