Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for IndexRequestBuilder (0.06 sec)

  1. src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

                source.put("field1", "test" + i);
                source.put("field2", i);
                IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE);
                indexRequestBuilder.setIndex(indexName).setId(String.valueOf(i)).setCreate(true).setSource(source);
                bulkRequestBuilder.add(indexRequestBuilder);
            }
            bulkRequestBuilder.execute().actionGet();
            runner.refresh();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java

            }
    
            return 1;
        }
    
        protected IndexRequestBuilder createUpdateRequest(final EsAbstractEntity esEntity) {
            final IndexRequestBuilder builder =
                    client.prepareIndex().setIndex(asEsIndex()).setId(esEntity.asDocMeta().id()).setSource(toSource(esEntity));
            final RequestOptionCall<IndexRequestBuilder> indexOption = esEntity.asDocMeta().indexOption();
            if (indexOption != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 21 04:02:44 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriter.java

                    final IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE, index);
                    indexRequestBuilder.setId(item.getId())
                            .setOpType(IndexRequest.OpType.INDEX)
                            .setSource(item.getUpdatedSource(getResponse.getSourceAsMap()));
                    bulkRequestBuilder.add(indexRequestBuilder);
                } else {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java

            }
    
            return 1;
        }
    
        protected IndexRequestBuilder createUpdateRequest(final EsAbstractEntity esEntity) {
            final IndexRequestBuilder builder =
                    client.prepareIndex().setIndex(asEsIndex()).setId(esEntity.asDocMeta().id()).setSource(toSource(esEntity));
            final RequestOptionCall<IndexRequestBuilder> indexOption = esEntity.asDocMeta().indexOption();
            if (indexOption != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 21 04:02:44 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

            }
    
            return 1;
        }
    
        protected IndexRequestBuilder createUpdateRequest(final EsAbstractEntity esEntity) {
            final IndexRequestBuilder builder =
                    client.prepareIndex().setIndex(asEsIndex()).setId(esEntity.asDocMeta().id()).setSource(toSource(esEntity));
            final RequestOptionCall<IndexRequestBuilder> indexOption = esEntity.asDocMeta().indexOption();
            if (indexOption != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 21 04:02:44 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractEntity.java

            public Long primaryTerm() {
                return primaryTerm;
            }
    
            public DocMeta indexOption(RequestOptionCall<IndexRequestBuilder> builder) {
                this.indexOption = builder;
                return this;
            }
    
            public RequestOptionCall<IndexRequestBuilder> indexOption() {
                return indexOption;
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

                Map<String, Object> source = Collections.singletonMap("content", "test");
                IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE);
                indexRequestBuilder.setIndex(indexName).setId(String.valueOf(i)).setCreate(true).setSource(source);
                bulkRequestBuilder.add(indexRequestBuilder);
            }
            bulkRequestBuilder.execute().actionGet();
            runner.refresh();
    
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java

                public BulkResponse addAll(final String index, final List<Map<String, Object>> docList,
                        final BiConsumer<Map<String, Object>, IndexRequestBuilder> options) {
                    sentIndex.set(index);
                    docList.forEach(x -> options.accept(x, new IndexRequestBuilder(this, IndexAction.INSTANCE)));
                    sentDocList.addAll(docList);
                    return new BulkResponse(new BulkItemResponse[0], documentSizeByQuery);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 29.3K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

    import org.opensearch.action.get.MultiGetRequestBuilder;
    import org.opensearch.action.get.MultiGetResponse;
    import org.opensearch.action.index.IndexRequest;
    import org.opensearch.action.index.IndexRequestBuilder;
    import org.opensearch.action.index.IndexResponse;
    import org.opensearch.action.search.ClearScrollRequest;
    import org.opensearch.action.search.ClearScrollRequestBuilder;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                final BiConsumer<Map<String, Object>, IndexRequestBuilder> options) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();
            for (final Map<String, Object> doc : docList) {
                final Object id = doc.remove(fessConfig.getIndexFieldId());
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
Back to top