- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for whale (0.12 sec)
-
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
dataCrawlingThreadList.add(dataCrawlingThread); dataCrawlingThreadStatusList.add(Constants.READY); } int startedCrawlerNum = 0; int activeCrawlerNum = 0; while (startedCrawlerNum < dataCrawlingThreadList.size()) { // Force to stop crawl if (systemHelper.isForceStop()) { for (final DataCrawlingThread crawlerThread : dataCrawlingThreadList) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java
} esCb.request().build(builder); SearchResponse response = esCb.build(builder).execute().actionGet(scrollSearchTimeout); String scrollId = response.getScrollId(); try { while (scrollId != null) { final SearchHits searchHits = getSearchHits(response); final SearchHit[] hits = searchHits.getHits(); if (hits.length == 0) { break;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/lang/StringUtil.java
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 21.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/exentity/DataConfig.java
final List<org.codelibs.fess.crawler.client.http.RequestHeader> rhList = new ArrayList<>(); int count = 1; String headerName = paramMap.get(CRAWLER_WEB_HEADER_PREFIX + count + ".name"); while (StringUtil.isNotBlank(headerName)) { final String headerValue = paramMap.get(CRAWLER_WEB_HEADER_PREFIX + count + ".value");
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
} fail("could not start job."); } protected static void waitJob(final String namePrefix) { Boolean isRunning = false; int count = 0; while (count < 300 && !isRunning) { // Wait until the crawler starts ThreadUtil.sleep(500); count++; final Map<String, Object> scheduler = getSchedulerItem(namePrefix);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMultipartRequestHandler.java
br.addElement("Boundary size is limited by Framework."); br.addElement("Too long boundary is treated as 404 because it's thought of as attack."); br.addElement(""); br.addElement("While, you can override the boundary limit size"); br.addElement(" in " + FessMultipartRequestHandler.class.getSimpleName() + "."); br.addItem("Content Type"); br.addElement(contentType);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
long updateTime = systemHelper.getCurrentTimeAsLong(); int errorCount = 0; int emptyListCount = 0; long cleanupTime = -1; while (!finishCrawling || !accessResultList.isEmpty()) { try { final int sessionIdListSize = finishedSessionIdList.size(); intervalControlHelper.setCrawlerRunning(true);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 24.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ViewHelper.java
} final Matcher matcher = Pattern.compile(pattern, Pattern.CASE_INSENSITIVE | Pattern.UNICODE_CASE).matcher(value); final StringBuffer buf = new StringBuffer(value.length() + 100); while (matcher.find()) { matcher.appendReplacement(buf, Matcher.quoteReplacement(highlightTagPre + matcher.group(0) + highlightTagPost)); } matcher.appendTail(buf);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 40.1K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java
try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) { long id = 0; String line = null; while ((line = reader.readLine()) != null) { // Remove comments final String replacedLine = line.replaceAll("#.*$", StringUtil.EMPTY).trim(); // Skip empty lines or comment lines
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 10.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/PluginHelper.java
final String repoContent = getRepositoryContent(url); final Matcher matcher = Pattern.compile("href=\"[^\"]*(" + artifactType.getId() + "[a-zA-Z0-9\\-]+)/?\"").matcher(repoContent); while (matcher.find()) { final String name = matcher.group(1); final String pluginUrl = url + (url.endsWith("/") ? name + "/" : "/" + name + "/"); try {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.8K bytes - Viewed (0)