Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for getPid (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top