Skip to content

Commit 0f0200a

Browse files
committed
Remove constructor used only in tests
1 parent 8887609 commit 0f0200a

File tree

5 files changed

+33
-24
lines changed

5 files changed

+33
-24
lines changed

server/src/main/java/org/elasticsearch/action/search/SearchShardIterator.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -39,19 +39,6 @@ public final class SearchShardIterator implements Comparable<SearchShardIterator
3939
private final TimeValue searchContextKeepAlive;
4040
private final PlainIterator<String> targetNodesIterator;
4141

42-
/**
43-
* Creates a {@link SearchShardIterator} instance that iterates over a subset of the given shards
44-
* for a given <code>shardId</code>.
45-
*
46-
* @param clusterAlias the alias of the cluster where the shard is located
47-
* @param shardId shard id of the group
48-
* @param shards shards to iterate
49-
* @param originalIndices the indices that the search request originally related to (before any rewriting happened)
50-
*/
51-
public SearchShardIterator(@Nullable String clusterAlias, ShardId shardId, List<ShardRouting> shards, OriginalIndices originalIndices) {
52-
this(clusterAlias, shardId, shards.stream().map(ShardRouting::currentNodeId).toList(), originalIndices, null, null, false, false);
53-
}
54-
5542
/**
5643
* Creates a {@link SearchShardIterator} instance that iterates over a subset of the given shards
5744
* for a given <code>shardId</code>.

server/src/test/java/org/elasticsearch/action/search/AbstractSearchAsyncActionTests.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ private AbstractSearchAsyncAction<SearchPhaseResult> createAction(
8282
null,
8383
request,
8484
listener,
85-
Collections.singletonList(new SearchShardIterator(null, new ShardId("index", "_na", 0), Collections.emptyList(), null)),
85+
Collections.singletonList(new SearchShardIterator(null, new ShardId("index", "_na", 0), Collections.emptyList(), null, false)),
8686
timeProvider,
8787
ClusterState.EMPTY_STATE,
8888
null,
@@ -153,7 +153,8 @@ public void testBuildShardSearchTransportRequest() {
153153
clusterAlias,
154154
new ShardId(new Index("name", "foo"), 1),
155155
Collections.emptyList(),
156-
new OriginalIndices(new String[] { "name", "name1" }, IndicesOptions.strictExpand())
156+
new OriginalIndices(new String[] { "name", "name1" }, IndicesOptions.strictExpand()),
157+
false
157158
);
158159
ShardSearchRequest shardSearchTransportRequest = action.buildShardSearchRequest(iterator, 10);
159160
assertEquals(IndicesOptions.strictExpand(), shardSearchTransportRequest.indicesOptions());

server/src/test/java/org/elasticsearch/action/search/SearchAsyncActionTests.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -640,7 +640,8 @@ public void testSkipUnavailableSearchShards() throws InterruptedException {
640640
null,
641641
new ShardId(index, 0),
642642
Collections.emptyList(),
643-
originalIndices
643+
originalIndices,
644+
false
644645
);
645646
// Skip all the shards
646647
searchShardIterator.skip(true);
@@ -760,7 +761,7 @@ static List<SearchShardIterator> getShardsIter(
760761
}
761762
Collections.shuffle(started, random());
762763
started.addAll(initializing);
763-
list.add(new SearchShardIterator(null, new ShardId(index, i), started, originalIndices));
764+
list.add(new SearchShardIterator(null, new ShardId(index, i), started, originalIndices, false));
764765
}
765766
return list;
766767
}

server/src/test/java/org/elasticsearch/action/search/SearchShardIteratorTests.java

Lines changed: 26 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,13 @@ private static List<ShardRouting> randomShardRoutings(ShardId shardId, int numRe
4545

4646
public void testShardId() {
4747
ShardId shardId = new ShardId(randomAlphaOfLengthBetween(5, 10), randomAlphaOfLength(10), randomInt());
48-
SearchShardIterator searchShardIterator = new SearchShardIterator(null, shardId, Collections.emptyList(), OriginalIndices.NONE);
48+
SearchShardIterator searchShardIterator = new SearchShardIterator(
49+
null,
50+
shardId,
51+
Collections.emptyList(),
52+
OriginalIndices.NONE,
53+
false
54+
);
4955
assertSame(shardId, searchShardIterator.shardId());
5056
}
5157

@@ -55,7 +61,7 @@ public void testGetOriginalIndices() {
5561
new String[] { randomAlphaOfLengthBetween(3, 10) },
5662
IndicesOptions.fromOptions(randomBoolean(), randomBoolean(), randomBoolean(), randomBoolean())
5763
);
58-
SearchShardIterator searchShardIterator = new SearchShardIterator(null, shardId, Collections.emptyList(), originalIndices);
64+
SearchShardIterator searchShardIterator = new SearchShardIterator(null, shardId, Collections.emptyList(), originalIndices, false);
5965
assertSame(originalIndices, searchShardIterator.getOriginalIndices());
6066
}
6167

@@ -66,7 +72,8 @@ public void testGetClusterAlias() {
6672
clusterAlias,
6773
shardId,
6874
Collections.emptyList(),
69-
OriginalIndices.NONE
75+
OriginalIndices.NONE,
76+
false
7077
);
7178
assertEquals(clusterAlias, searchShardIterator.getClusterAlias());
7279
}
@@ -164,15 +171,22 @@ public void testCompareTo() {
164171
for (String uuid : uuids) {
165172
ShardId shardId = new ShardId(index, uuid, i);
166173
shardIterators.add(
167-
new SearchShardIterator(null, shardId, randomShardRoutings(shardId), OriginalIndicesTests.randomOriginalIndices())
174+
new SearchShardIterator(
175+
null,
176+
shardId,
177+
randomShardRoutings(shardId),
178+
OriginalIndicesTests.randomOriginalIndices(),
179+
false
180+
)
168181
);
169182
for (String cluster : clusters) {
170183
shardIterators.add(
171184
new SearchShardIterator(
172185
cluster,
173186
shardId,
174187
randomShardRoutings(shardId),
175-
OriginalIndicesTests.randomOriginalIndices()
188+
OriginalIndicesTests.randomOriginalIndices(),
189+
false
176190
)
177191
);
178192
}
@@ -217,6 +231,12 @@ public void testCompareToEqualItems() {
217231
private static SearchShardIterator randomSearchShardIterator() {
218232
String clusterAlias = randomBoolean() ? null : randomAlphaOfLengthBetween(5, 10);
219233
ShardId shardId = new ShardId(randomAlphaOfLengthBetween(5, 10), randomAlphaOfLength(10), randomIntBetween(0, Integer.MAX_VALUE));
220-
return new SearchShardIterator(clusterAlias, shardId, randomShardRoutings(shardId), OriginalIndicesTests.randomOriginalIndices());
234+
return new SearchShardIterator(
235+
clusterAlias,
236+
shardId,
237+
randomShardRoutings(shardId),
238+
OriginalIndicesTests.randomOriginalIndices(),
239+
false
240+
);
221241
}
222242
}

server/src/test/java/org/elasticsearch/action/search/TransportSearchActionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ private static SearchShardIterator createSearchShardIterator(
158158
) {
159159
ShardId shardId = new ShardId(index, id);
160160
List<ShardRouting> shardRoutings = SearchShardIteratorTests.randomShardRoutings(shardId);
161-
return new SearchShardIterator(clusterAlias, shardId, shardRoutings, originalIndices);
161+
return new SearchShardIterator(clusterAlias, shardId, shardRoutings, originalIndices, false);
162162
}
163163

164164
private static ResolvedIndices createMockResolvedIndices(

0 commit comments

Comments
 (0)