Skip to content

Commit 7ab5075

Browse files
cwperksMaciejMierzwa
authored andcommitted
Switch from ImmutableOpenMap to Map in AliasExistsMatcher (#2725)
* Remove references to ObjectObjectCursor Signed-off-by: Craig Perkins <cwperx@amazon.com> Signed-off-by: Maciej Mierzwa <dev.maciej.mierzwa@gmail.com>
1 parent 0b6f8db commit 7ab5075

File tree

4 files changed

+7
-32
lines changed

4 files changed

+7
-32
lines changed

src/integrationTest/java/org/opensearch/test/framework/matcher/AliasExistsMatcher.java

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -10,15 +10,13 @@
1010
package org.opensearch.test.framework.matcher;
1111

1212
import java.util.Collection;
13-
import java.util.HashMap;
1413
import java.util.List;
1514
import java.util.Map;
1615
import java.util.Set;
1716
import java.util.concurrent.ExecutionException;
1817
import java.util.stream.Collectors;
1918
import java.util.stream.StreamSupport;
2019

21-
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
2220
import org.hamcrest.Description;
2321
import org.hamcrest.TypeSafeDiagnosingMatcher;
2422

@@ -44,11 +42,7 @@ protected boolean matchesSafely(Client client, Description mismatchDescription)
4442
try {
4543
GetAliasesResponse response = client.admin().indices().getAliases(new GetAliasesRequest(aliasName)).get();
4644

47-
final Map<String, List<AliasMetadata>> aliases = new HashMap<>();
48-
for (ObjectObjectCursor<String, List<AliasMetadata>> cursor : response.getAliases()) {
49-
aliases.put(cursor.key, cursor.value);
50-
}
51-
45+
Map<String, List<AliasMetadata>> aliases = response.getAliases();
5246
Set<String> actualAliasNames = StreamSupport.stream(spliteratorUnknownSize(aliases.values().iterator(), IMMUTABLE), false)
5347
.flatMap(Collection::stream)
5448
.map(AliasMetadata::getAlias)
@@ -61,7 +55,7 @@ protected boolean matchesSafely(Client client, Description mismatchDescription)
6155
return true;
6256
} catch (InterruptedException | ExecutionException e) {
6357
mismatchDescription.appendText("Error occurred during checking if cluster contains alias ")
64-
.appendValue(e);
58+
.appendValue(e);
6559
return false;
6660
}
6761
}

src/integrationTest/java/org/opensearch/test/framework/matcher/ClusterContainTemplateWithAliasMatcher.java

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,12 @@
99
*/
1010
package org.opensearch.test.framework.matcher;
1111

12-
import java.util.HashMap;
1312
import java.util.Map;
1413
import java.util.Set;
1514
import java.util.stream.Collectors;
1615
import java.util.stream.Stream;
1716
import java.util.stream.StreamSupport;
1817

19-
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
2018
import org.hamcrest.Description;
2119
import org.hamcrest.TypeSafeDiagnosingMatcher;
2220

@@ -57,13 +55,7 @@ protected boolean matchesSafely(Client client, Description mismatchDescription)
5755
private Set<String> getAliases(GetIndexTemplatesResponse response) {
5856
return response.getIndexTemplates()
5957
.stream()
60-
.map(metadata -> {
61-
Map<String, AliasMetadata> aliases = new HashMap<>();
62-
for (ObjectObjectCursor<String, AliasMetadata> cursor : metadata.getAliases()) {
63-
aliases.put(cursor.key, cursor.value);
64-
}
65-
return aliases;
66-
})
58+
.map(metadata -> metadata.getAliases())
6759
.flatMap(aliasMap -> aliasNames(aliasMap))
6860
.collect(Collectors.toSet());
6961
}

src/integrationTest/java/org/opensearch/test/framework/matcher/GetSettingsResponseContainsIndicesMatcher.java

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,11 @@
99
*/
1010
package org.opensearch.test.framework.matcher;
1111

12-
import java.util.HashMap;
13-
import java.util.Map;
14-
15-
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
1612
import org.hamcrest.Description;
1713
import org.hamcrest.TypeSafeDiagnosingMatcher;
1814

1915
import org.opensearch.action.admin.indices.settings.get.GetSettingsResponse;
16+
import org.opensearch.common.collect.ImmutableOpenMap;
2017
import org.opensearch.common.settings.Settings;
2118

2219
import static java.util.Objects.isNull;
@@ -35,15 +32,12 @@ class GetSettingsResponseContainsIndicesMatcher extends TypeSafeDiagnosingMatche
3532
@Override
3633
protected boolean matchesSafely(GetSettingsResponse response, Description mismatchDescription) {
3734

38-
final Map<String, Settings> indexToSettings = new HashMap<>();
39-
for (ObjectObjectCursor<String, Settings> cursor : response.getIndexToSettings()) {
40-
indexToSettings.put(cursor.key, cursor.value);
41-
}
35+
final ImmutableOpenMap<String, Settings> indexToSettings = response.getIndexToSettings();
4236
for (String index : expectedIndices) {
4337
if (!indexToSettings.containsKey(index)) {
4438
mismatchDescription
4539
.appendText("Response contains settings of indices: ")
46-
.appendValue(indexToSettings.keySet());
40+
.appendValue(indexToSettings.keys());
4741
return false;
4842
}
4943
}

src/main/java/org/opensearch/security/privileges/PrivilegesEvaluator.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import java.util.ArrayList;
3030
import java.util.Arrays;
3131
import java.util.Collections;
32-
import java.util.HashMap;
3332
import java.util.HashSet;
3433
import java.util.Iterator;
3534
import java.util.List;
@@ -38,7 +37,6 @@
3837
import java.util.StringJoiner;
3938
import java.util.regex.Pattern;
4039

41-
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
4240
import com.google.common.collect.ImmutableSet;
4341
import com.google.common.collect.Sets;
4442
import org.apache.logging.log4j.LogManager;
@@ -674,10 +672,7 @@ public Iterator<IndexMetadata> iterator() {
674672

675673
final List<AliasMetadata> filteredAliases = new ArrayList<AliasMetadata>();
676674

677-
final Map<String, AliasMetadata> aliases = new HashMap<>();
678-
for (ObjectObjectCursor<String, AliasMetadata> cursor : indexMetaData.getAliases()) {
679-
aliases.put(cursor.key, cursor.value);
680-
}
675+
final Map<String, AliasMetadata> aliases = indexMetaData.getAliases();
681676

682677
if(aliases != null && aliases.size() > 0) {
683678
if (isDebugEnabled) {

0 commit comments

Comments
 (0)