- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for getPid (0.03 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
for (final T target : list) { final String id = getId(getSessionId(target), getUrl(target)); try (final XContentBuilder source = getXContentBuilder(target)) { bulkRequest.add(c.prepareIndex().setIndex(index).setId(id).setSource(source).setOpType(opType)); } setId(target, id); }
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 34.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java
final BulkRequestBuilder bulkRequest = client.prepareBulk(); for (final SearchHit hit : hits) { bulkRequest.add(client.prepareDelete().setIndex(asEsIndex()).setId(hit.getId())); } count += hits.length; final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 26.4K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/entity/AccessResultImplTest.java
intResult.setId(42); assertEquals(Integer.valueOf(42), intResult.getId()); AccessResultImpl<String> stringResult = new AccessResultImpl<>(); stringResult.setId("result-id-123"); assertEquals("result-id-123", stringResult.getId()); AccessResultImpl<Long> longResult = new AccessResultImpl<>(); longResult.setId(987654321L);Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 13 13:29:22 UTC 2025 - 13.4K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/entity/UrlQueueImplTest.java
queue.setId(123L); assertEquals(Long.valueOf(123L), queue.getId()); queue.setId(null); assertNull(queue.getId()); } public void test_idWithStringType() { // Test ID getter/setter with String UrlQueueImpl<String> queue = new UrlQueueImpl<>(); queue.setId("id123"); assertEquals("id123", queue.getId()); }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 13 13:29:22 UTC 2025 - 9.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ElevateWordService.java
public void store(final ElevateWord elevateWord) { final boolean isNew = elevateWord.getId() == null; final String[] labelTypeIds = elevateWord.getLabelTypeIds(); elevateWordBhv.insertOrUpdate(elevateWord, op -> { op.setRefreshPolicy(Constants.TRUE); }); final String elevateWordId = elevateWord.getId(); if (labelTypeIds != null) { if (isNew) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 18.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/exentity/WebAuthentication.java
logger.warn("Web Config {} does not exist.", getWebConfigId(), e); } } return webConfig; } public String getId() { return asDocMeta().id(); } public void setId(final String id) { asDocMeta().id(id); } public Long getVersionNo() { return asDocMeta().version(); }
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Nov 24 04:23:08 UTC 2025 - 6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriterTest.java
GetResponse getResponse1 = runner.client().prepareGet().setIndex(suggester.getIndex()).setId(item.getId()).get(TimeValue.timeValueSeconds(30)); assertTrue(getResponse1.isExists()); SuggestWriterResult result = writer.delete(runner.client(), suggester.settings(), suggester.getIndex(), item.getId()); assertNotNull(result); assertFalse(result.hasFailure());Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 18.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/UserService.java
final String username = user.getName(); final boolean isUpdate = StringUtil.isNotBlank(user.getId()); if (logger.isDebugEnabled()) { logger.debug("User {} operation initiated: username={}, id={}", isUpdate ? "update" : "create", username, user.getId() != null ? user.getId() : "new"); } try { if (StringUtil.isBlank(user.getSurname())) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Nov 24 02:07:40 UTC 2025 - 9.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java
final BulkRequestBuilder bulkRequest = client.prepareBulk(); for (final SearchHit hit : hits) { bulkRequest.add(client.prepareDelete().setIndex(asEsIndex()).setId(hit.getId())); } count += hits.length; final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/JobHelper.java
ComponentUtil.getComponent(ScheduledJobBhv.class) .selectByPK(scheduledJob.getId()) .ifPresent(e -> params.put(Constants.SCHEDULED_JOB, e)) .orElse(() -> { logger.warn("Job {} is not found.", scheduledJob.getId()); }); return params; };
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.9K bytes - Viewed (0)