From 1e7cf9d9f67652594645caf43a0de6473cb8dd2f Mon Sep 17 00:00:00 2001 From: Ankita Kumar Date: Fri, 21 Mar 2025 13:29:04 -0400 Subject: [PATCH 1/4] Make ShardSplittingQuery public --- .../org/elasticsearch/index/shard/ShardSplittingQuery.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/elasticsearch/index/shard/ShardSplittingQuery.java b/server/src/main/java/org/elasticsearch/index/shard/ShardSplittingQuery.java index 94a29258f3202..28b63ffff3e66 100644 --- a/server/src/main/java/org/elasticsearch/index/shard/ShardSplittingQuery.java +++ b/server/src/main/java/org/elasticsearch/index/shard/ShardSplittingQuery.java @@ -52,13 +52,13 @@ * It can be used to split a shard into N shards marking every document that doesn't belong into the shard * as deleted. See {@link org.apache.lucene.index.IndexWriter#deleteDocuments(Query...)} */ -final class ShardSplittingQuery extends Query { +public final class ShardSplittingQuery extends Query { private final IndexMetadata indexMetadata; private final IndexRouting indexRouting; private final int shardId; private final BitSetProducer nestedParentBitSetProducer; - ShardSplittingQuery(IndexMetadata indexMetadata, int shardId, boolean hasNested) { + public ShardSplittingQuery(IndexMetadata indexMetadata, int shardId, boolean hasNested) { this.indexMetadata = indexMetadata; this.indexRouting = IndexRouting.fromIndexMetadata(indexMetadata); this.shardId = shardId; From 233cea9e89addc7ecb6abfc7d03f87bce3fab089 Mon Sep 17 00:00:00 2001 From: Ankita Kumar Date: Mon, 24 Mar 2025 11:27:13 -0400 Subject: [PATCH 2/4] commit --- .../org/elasticsearch/index/engine/InternalEngine.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java index 2f6f698620662..9706441909873 100644 --- a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java +++ b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java @@ -95,6 +95,7 @@ import org.elasticsearch.index.seqno.SequenceNumbers; import org.elasticsearch.index.shard.ShardId; import org.elasticsearch.index.shard.ShardLongFieldRange; +import org.elasticsearch.index.shard.ShardSplittingQuery; import org.elasticsearch.index.store.Store; import org.elasticsearch.index.translog.Translog; import org.elasticsearch.index.translog.TranslogConfig; @@ -3550,4 +3551,10 @@ T performActionWithDirectoryReader(SearcherScope scope, CheckedFunction Date: Mon, 24 Mar 2025 13:27:38 -0400 Subject: [PATCH 3/4] flush --- .../main/java/org/elasticsearch/index/engine/InternalEngine.java | 1 + 1 file changed, 1 insertion(+) diff --git a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java index 9706441909873..4d8ba9572a91f 100644 --- a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java +++ b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java @@ -3555,6 +3555,7 @@ T performActionWithDirectoryReader(SearcherScope scope, CheckedFunction Date: Wed, 4 Jun 2025 23:42:31 -0400 Subject: [PATCH 4/4] remove print --- .../java/org/elasticsearch/index/engine/InternalEngine.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java index b3990f7d15a5e..0d42283282fa3 100644 --- a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java +++ b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java @@ -3613,7 +3613,7 @@ protected long estimateMergeBytes(MergePolicy.OneMerge merge) { } public void deleteByQuery(ShardSplittingQuery query) throws Exception { - System.out.println("Delete documents using ShardSplitQuery"); + // System.out.println("Delete documents using ShardSplitQuery"); indexWriter.deleteDocuments(query); indexWriter.flush(); indexWriter.commit();