- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for prepareBulk (0.13 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
public void bulk(final BulkRequest request, final ActionListener<BulkResponse> listener) { client.bulk(request, listener); } @Override public BulkRequestBuilder prepareBulk() { return client.prepareBulk(); } @Override public ActionFuture<GetResponse> get(final GetRequest request) { return client.get(request); } @Override
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 19.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
count++; } assertEquals(num, count); } private void addDocument(String indexName, Client client, int num) { BulkRequestBuilder bulkRequestBuilder = client.prepareBulk(); for (int i = 0; i < num; i++) { final Map<String, Object> source = new HashMap<>(); source.put("field1", "test" + i); source.put("field2", i);
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 8.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
public void bulk(final BulkRequest request, final ActionListener<BulkResponse> listener) { client.bulk(request, listener); } @Override public BulkRequestBuilder prepareBulk() { return client.prepareBulk(); } @Override public ActionFuture<GetResponse> get(final GetRequest request) { return client.get(request); } @Override
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Oct 20 02:08:03 UTC 2024 - 86.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriter.java
public SuggestWriterResult write(final Client client, final SuggestSettings settings, final String index, final SuggestItem[] items, final boolean update) { final BulkRequestBuilder bulkRequestBuilder = client.prepareBulk(); final SuggestItem[] mergedItems = mergeItems(items); if (mergedItems.length == 0) { return new SuggestWriterResult(); } for (final SuggestItem item : mergedItems) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
return 0L; } final SearchEngineClient client = ComponentUtil.getSearchEngineClient(); if (bulkRequestBuilder == null) { bulkRequestBuilder = client.prepareBulk(); } final String index = fessConfig.getIndexDocumentUpdateIndex(); for (final String id : ids) { bulkRequestBuilder.add(client.prepareUpdate().setIndex(index).setId(id)
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
} protected <T> BulkResponse doInsertAll(final List<T> list, final OpType opType) { try { return getClient().get(c -> { final BulkRequestBuilder bulkRequest = c.prepareBulk(); for (final T target : list) { final String id = getId(getSessionId(target), getUrl(target)); try (final XContentBuilder source = getXContentBuilder(target)) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0)