- Sort Score
- Num 10 results
- Language All
Results 21 - 28 of 28 for prepareDelete (0.07 seconds)
-
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java
return response.getResult() == Result.DELETED ? 1 : 0; } protected DeleteRequestBuilder createDeleteRequest(final EsAbstractEntity esEntity) { final DeleteRequestBuilder builder = client.prepareDelete().setIndex(asEsIndex()).setId(esEntity.asDocMeta().id()); final RequestOptionCall<DeleteRequestBuilder> deleteOption = esEntity.asDocMeta().deleteOption(); if (deleteOption != null) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 27 07:01:25 GMT 2025 - 26.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/LogNotificationJob.java
} } final BulkRequestBuilder bulkDelete = client.prepareBulk(); for (final String docId : docIds) { bulkDelete.add(client.prepareDelete().setIndex(indexName).setId(docId)); } bulkDelete.execute().actionGet(fessConfig.getIndexSearchTimeout()); // Delete any remaining events beyond the search size limit (discard overflow)Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 9.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java
return response.getResult() == Result.DELETED ? 1 : 0; } protected DeleteRequestBuilder createDeleteRequest(final EsAbstractEntity esEntity) { final DeleteRequestBuilder builder = client.prepareDelete().setIndex(asEsIndex()).setId(esEntity.asDocMeta().id()); final RequestOptionCall<DeleteRequestBuilder> deleteOption = esEntity.asDocMeta().deleteOption(); if (deleteOption != null) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 27 07:01:25 GMT 2025 - 26.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java
return response.getResult() == Result.DELETED ? 1 : 0; } protected DeleteRequestBuilder createDeleteRequest(final EsAbstractEntity esEntity) { final DeleteRequestBuilder builder = client.prepareDelete().setIndex(asEsIndex()).setId(esEntity.asDocMeta().id()); final RequestOptionCall<DeleteRequestBuilder> deleteOption = esEntity.asDocMeta().deleteOption(); if (deleteOption != null) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 27 07:01:25 GMT 2025 - 26.4K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
when(mockScrollResponse.getHits()).thenReturn(mockScrollHits); // Setup bulk delete when(mockClient.prepareBulk()).thenReturn(mockBulkBuilder); when(mockClient.prepareDelete()).thenReturn(mockDeleteBuilder); when(mockDeleteBuilder.setIndex("test-index")).thenReturn(mockDeleteBuilder); when(mockDeleteBuilder.setId("doc1")).thenReturn(mockDeleteBuilder);
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Mon Jan 12 06:25:38 GMT 2026 - 16.9K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
final BulkRequestBuilder bulkBuilder = c.prepareBulk(); for (final OpenSearchUrlQueue uq : urlQueueList) { bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId())); } return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute(); });
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 16.9K bytes - Click Count (1) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
*/ protected void deleteFromArray(final String index, final String type, final String id) { final String actualIndex = index + "." + type.toLowerCase(Locale.ENGLISH); try { client.prepareDelete().setIndex(actualIndex).setId(id).execute().actionGet(settings.getIndexTimeout()); client.admin().indices().prepareRefresh().setIndices(actualIndex).execute().actionGet(settings.getIndicesTimeout());Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 15.8K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
protected boolean delete(final String sessionId, final String url) { final String id = getId(sessionId, url); try { final DeleteResponse response = getClient().get(c -> c.prepareDelete().setIndex(index).setId(id).setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute()); return response.getResult() == Result.DELETED; } catch (final Exception e) {
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 34.3K bytes - Click Count (0)