- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for prepareDelete (0.07 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
client.delete(request, listener); } @Override public DeleteRequestBuilder prepareDelete() { return client.prepareDelete(); } @Override public DeleteRequestBuilder prepareDelete(final String index, final String id) { return client.prepareDelete(index, id); } @Override public ActionFuture<BulkResponse> bulk(final BulkRequest request) {
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/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) {
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/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) {
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 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) {
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/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());
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 15.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
validate(form, messages -> {}, this::asIndexHtml); verifyToken(this::asIndexHtml); searchEngineClient.admin() .indices() .prepareDelete(// fessConfig.getIndexDocumentCrawlerIndex() + ".queue", // fessConfig.getIndexDocumentCrawlerIndex() + ".data", //
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 18K bytes - Viewed (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(); });
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (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) {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 34.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/Suggester.java
return list.isEmpty(); }).forEach(s -> { if (logger.isInfoEnabled()) { logger.info("Delete index: {}", s); } client.admin().indices().prepareDelete(s).execute().actionGet(suggestSettings.getIndicesTimeout()); }); } /** * Creates a new SuggestIndexer for indexing suggestions. * @return A SuggestIndexer instance. */
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 20.7K bytes - Viewed (3) -
src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java
.actionGet(this.settings.getIndicesTimeout()); } /** * Deletes the analyzer settings. */ protected void deleteAnalyzerSettings() { client.admin().indices().prepareDelete(analyzerSettingsIndexName).execute().actionGet(settings.getIndicesTimeout()); } /** * Creates analyzer settings with string settings and mappings. * @param settings The settings in string format.
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 26.5K bytes - Viewed (0)