- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for IndexRequestBuilder (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)