Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 28 of 28 for prepareDelete (0.07 seconds)

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