Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 150 for sessionIds (0.08 sec)

  1. src/main/java/org/codelibs/fess/job/PythonJob.java

            if (sessionId == null) { // create session id
                sessionId = RandomStringUtils.randomAlphabetic(15);
            }
            resultBuf.append("Session Id: ").append(sessionId).append("\n");
            if (jobExecutor != null) {
                jobExecutor.addShutdownListener(() -> ComponentUtil.getProcessHelper().destroyProcess(sessionId));
            }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

            Map<String, AccessResultImpl<Long>> arMap = sessionMap.get(sessionId);
            if (arMap == null) {
                arMap = new HashMap<>();
                sessionMap.put(sessionId, arMap);
            }
            return arMap;
        }
    
        public synchronized void deleteAccessResultMap(final String sessionId) {
            sessionMap.remove(sessionId);
        }
    
        public synchronized void deleteAllAccessResultMap() {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/config/exentity/CrawlingInfo.java

        private static final long serialVersionUID = 1L;
    
        private List<CrawlingInfoParam> crawlingInfoParamList;
    
        public CrawlingInfo() {
        }
    
        public CrawlingInfo(final String sessionId) {
            setSessionId(sessionId);
        }
    
        public String getId() {
            return asDocMeta().id();
        }
    
        public void setId(final String id) {
            asDocMeta().id(id);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsCrawlingInfoCQ.java

            TermQueryBuilder builder = regTermQ("sessionId", sessionId);
            if (opLambda != null) {
                opLambda.callback(builder);
            }
        }
    
        public void setSessionId_NotEqual(String sessionId) {
            setSessionId_NotTerm(sessionId, null);
        }
    
        public void setSessionId_NotTerm(String sessionId) {
            setSessionId_NotTerm(sessionId, null);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/PathMappingHelper.java

            pathMappingMap.remove(sessionId);
        }
    
        public List<PathMapping> getPathMappingList(final String sessionId) {
            if (sessionId == null) {
                return null;
            }
            return pathMappingMap.get(sessionId);
        }
    
        public String replaceUrl(final String sessionId, final String url) { // for crawling
            final List<PathMapping> pathMappingList = getPathMappingList(sessionId);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java

        public String getCanonicalSessionId(final String sessionId) {
            final int idx = sessionId.indexOf('-');
            if (idx >= 0) {
                return sessionId.substring(0, idx);
            }
            return sessionId;
        }
    
        public synchronized void store(final String sessionId, final boolean create) {
            CrawlingInfo crawlingInfo = create ? null : getCrawlingInfoService().getLast(sessionId);
            if (crawlingInfo == null) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

        void updateSessionId(String oldSessionId, String newSessionId);
    
        void add(String sessionId, String url);
    
        void insert(QUEUE urlQueue);
    
        void delete(String sessionId);
    
        void deleteAll();
    
        void offerAll(String sessionId, List<QUEUE> newUrlQueueList);
    
        QUEUE poll(String sessionId);
    
        void saveSession(String sessionId);
    
        boolean visited(QUEUE urlQueue);
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

            excludeFilterCache.invalidate(sessionId);
        }
    
        @Override
        public List<Pattern> getIncludeUrlPatternList(final String sessionId) {
            try {
                return includeFilterCache.get(sessionId);
            } catch (final ExecutionException e) {
                throw new CrawlerSystemException(e);
            }
        }
    
        @Override
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsCrawlingInfoCA.java

        public void setSessionId_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) {
            setSessionId_Terms("sessionId", opLambda, null);
        }
    
        public void setSessionId_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsCrawlingInfoCA> aggsLambda) {
            setSessionId_Terms("sessionId", opLambda, aggsLambda);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 31.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java

                cb.query().docMeta().setId_Equal(crawlingInfoPager.id);
            }
            // TODO Long, Integer, String supported only.
            if (StringUtil.isNotBlank(crawlingInfoPager.sessionId)) {
                cb.query().setSessionId_Match(crawlingInfoPager.sessionId);
            }
            cb.query().addOrderBy_CreatedTime_Desc();
        }
    
        protected void setupStoreCondition(final CrawlingInfo crawlingInfo) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top