- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 150 for sessionIds (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)