Skip to content

Commit

Permalink
Introduce remote store hash algo in customData in IndexMetadata
Browse files Browse the repository at this point in the history
Signed-off-by: Ashish Singh <[email protected]>
  • Loading branch information
ashking94 committed Mar 30, 2024
1 parent 8426e14 commit 631694e
Show file tree
Hide file tree
Showing 25 changed files with 623 additions and 265 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
import org.opensearch.core.rest.RestStatus;
import org.opensearch.index.IndexService;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.remote.RemoteStorePathType;
import org.opensearch.index.remote.RemoteStoreEnums.PathType;
import org.opensearch.index.shard.IndexShard;
import org.opensearch.indices.IndicesService;
import org.opensearch.indices.replication.common.ReplicationType;
Expand Down Expand Up @@ -283,7 +283,7 @@ public void testRemoteStoreCustomDataOnIndexCreationAndRestore() {

indexDocuments(client, indexName1, randomIntBetween(5, 10));
ensureGreen(indexName1);
validateRemoteStorePathType(indexName1, RemoteStorePathType.FIXED);
validatePathType(indexName1, PathType.FIXED);

logger.info("--> snapshot");
SnapshotInfo snapshotInfo = createSnapshot(snapshotRepoName, snapshotName1, new ArrayList<>(Arrays.asList(indexName1)));
Expand All @@ -300,14 +300,12 @@ public void testRemoteStoreCustomDataOnIndexCreationAndRestore() {
.get();
assertEquals(RestStatus.ACCEPTED, restoreSnapshotResponse.status());
ensureGreen(restoredIndexName1version1);
validateRemoteStorePathType(restoredIndexName1version1, RemoteStorePathType.FIXED);
validatePathType(restoredIndexName1version1, PathType.FIXED);

client(clusterManagerNode).admin()
.cluster()
.prepareUpdateSettings()
.setTransientSettings(
Settings.builder().put(CLUSTER_REMOTE_STORE_PATH_PREFIX_TYPE_SETTING.getKey(), RemoteStorePathType.HASHED_PREFIX)
)
.setTransientSettings(Settings.builder().put(CLUSTER_REMOTE_STORE_PATH_PREFIX_TYPE_SETTING.getKey(), PathType.HASHED_PREFIX))
.get();

restoreSnapshotResponse = client.admin()
Expand All @@ -319,24 +317,24 @@ public void testRemoteStoreCustomDataOnIndexCreationAndRestore() {
.get();
assertEquals(RestStatus.ACCEPTED, restoreSnapshotResponse.status());
ensureGreen(restoredIndexName1version2);
validateRemoteStorePathType(restoredIndexName1version2, RemoteStorePathType.HASHED_PREFIX);
validatePathType(restoredIndexName1version2, PathType.HASHED_PREFIX);

// Create index with cluster setting cluster.remote_store.index.path.prefix.type as hashed_prefix.
indexSettings = getIndexSettings(1, 0).build();
createIndex(indexName2, indexSettings);
ensureGreen(indexName2);
validateRemoteStorePathType(indexName2, RemoteStorePathType.HASHED_PREFIX);
validatePathType(indexName2, PathType.HASHED_PREFIX);

// Validating that custom data has not changed for indexes which were created before the cluster setting got updated
validateRemoteStorePathType(indexName1, RemoteStorePathType.FIXED);
validatePathType(indexName1, PathType.FIXED);
}

private void validateRemoteStorePathType(String index, RemoteStorePathType pathType) {
private void validatePathType(String index, PathType pathType) {
ClusterState state = client().admin().cluster().prepareState().execute().actionGet().getState();
// Validate that the remote_store custom data is present in index metadata for the created index.
Map<String, String> remoteCustomData = state.metadata().index(index).getCustomData(IndexMetadata.REMOTE_STORE_CUSTOM_KEY);
assertNotNull(remoteCustomData);
assertEquals(pathType.toString(), remoteCustomData.get(RemoteStorePathType.NAME));
assertEquals(pathType.toString(), remoteCustomData.get(PathType.NAME));
}

public void testRestoreInSameRemoteStoreEnabledIndex() throws IOException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,8 +88,10 @@
import org.opensearch.index.mapper.MapperService;
import org.opensearch.index.mapper.MapperService.MergeReason;
import org.opensearch.index.query.QueryShardContext;
import org.opensearch.index.remote.RemoteStorePathType;
import org.opensearch.index.remote.RemoteStorePathTypeResolver;
import org.opensearch.index.remote.RemoteStoreEnums.PathHashAlgorithm;
import org.opensearch.index.remote.RemoteStoreEnums.PathType;
import org.opensearch.index.remote.RemoteStorePathStrategy;
import org.opensearch.index.remote.RemoteStorePathStrategyResolver;
import org.opensearch.index.shard.IndexSettingProvider;
import org.opensearch.index.translog.Translog;
import org.opensearch.indices.IndexCreationException;
Expand Down Expand Up @@ -171,7 +173,7 @@ public class MetadataCreateIndexService {
private AwarenessReplicaBalance awarenessReplicaBalance;

@Nullable
private final RemoteStorePathTypeResolver remoteStorePathTypeResolver;
private final RemoteStorePathStrategyResolver remoteStorePathStrategyResolver;

public MetadataCreateIndexService(
final Settings settings,
Expand Down Expand Up @@ -204,8 +206,8 @@ public MetadataCreateIndexService(

// Task is onboarded for throttling, it will get retried from associated TransportClusterManagerNodeAction.
createIndexTaskKey = clusterService.registerClusterManagerTask(ClusterManagerTaskKeys.CREATE_INDEX_KEY, true);
remoteStorePathTypeResolver = isRemoteDataAttributePresent(settings)
? new RemoteStorePathTypeResolver(clusterService.getClusterSettings())
remoteStorePathStrategyResolver = isRemoteDataAttributePresent(settings)
? new RemoteStorePathStrategyResolver(clusterService.getClusterSettings())
: null;
}

Expand Down Expand Up @@ -554,7 +556,7 @@ IndexMetadata buildAndValidateTemporaryIndexMetadata(
tmpImdBuilder.setRoutingNumShards(routingNumShards);
tmpImdBuilder.settings(indexSettings);
tmpImdBuilder.system(isSystem);
addRemoteStorePathTypeInCustomData(tmpImdBuilder, true);
addRemoteStorePathStrategyInCustomData(tmpImdBuilder, true);

// Set up everything, now locally create the index to see that things are ok, and apply
IndexMetadata tempMetadata = tmpImdBuilder.build();
Expand All @@ -569,19 +571,27 @@ IndexMetadata buildAndValidateTemporaryIndexMetadata(
* @param tmpImdBuilder index metadata builder.
* @param assertNullOldType flag to verify that the old remote store path type is null
*/
public void addRemoteStorePathTypeInCustomData(IndexMetadata.Builder tmpImdBuilder, boolean assertNullOldType) {
if (remoteStorePathTypeResolver != null) {
public void addRemoteStorePathStrategyInCustomData(IndexMetadata.Builder tmpImdBuilder, boolean assertNullOldType) {
if (remoteStorePathStrategyResolver != null) {
// It is possible that remote custom data exists already. In such cases, we need to only update the path type
// in the remote store custom data map.
Map<String, String> existingRemoteCustomData = tmpImdBuilder.removeCustom(IndexMetadata.REMOTE_STORE_CUSTOM_KEY);
Map<String, String> remoteCustomData = existingRemoteCustomData == null
? new HashMap<>()
: new HashMap<>(existingRemoteCustomData);
// Determine the path type for use using the remoteStorePathResolver.
String newPathType = remoteStorePathTypeResolver.getType().toString();
String oldPathType = remoteCustomData.put(RemoteStorePathType.NAME, newPathType);
RemoteStorePathStrategy newPathStrategy = remoteStorePathStrategyResolver.get();
String oldPathType = remoteCustomData.put(PathType.NAME, newPathStrategy.getType().name());
String oldHashAlgorithm = remoteCustomData.put(PathHashAlgorithm.NAME, newPathStrategy.getHashAlgorithm().name());
assert !assertNullOldType || Objects.isNull(oldPathType);
logger.trace(() -> new ParameterizedMessage("Added new path type {}, replaced old path type {}", newPathType, oldPathType));
logger.trace(
() -> new ParameterizedMessage(

Check warning on line 588 in server/src/main/java/org/opensearch/cluster/metadata/MetadataCreateIndexService.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/cluster/metadata/MetadataCreateIndexService.java#L588

Added line #L588 was not covered by tests
"Added newPathStrategy={}, replaced oldPathType={} oldHashAlgorithm={}",
newPathStrategy,
oldPathType,
oldHashAlgorithm
)
);
tmpImdBuilder.putCustom(IndexMetadata.REMOTE_STORE_CUSTOM_KEY, remoteCustomData);
}
}
Expand Down
48 changes: 48 additions & 0 deletions server/src/main/java/org/opensearch/common/hash/FNV1a.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,48 @@
/*
* SPDX-License-Identifier: Apache-2.0
*
* The OpenSearch Contributors require contributions made to
* this file be licensed under the Apache-2.0 license or a
* compatible open source license.
*/

package org.opensearch.common.hash;

import java.nio.charset.StandardCharsets;

/**
* Provides hashing function using FNV1a hash function. @see <a href="http://www.isthe.com/chongo/tech/comp/fnv/#FNV-1">FNV author's website</a>.
* 32 bit Java port of http://www.isthe.com/chongo/src/fnv/hash_32a.c
* 64 bit Java port of http://www.isthe.com/chongo/src/fnv/hash_64a.c
*
* @opensearch.internal
*/
public class FNV1a {

Check warning on line 20 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L20

Added line #L20 was not covered by tests
private static final long FNV_OFFSET_BASIS_32 = 0x811c9dc5L;
private static final long FNV_PRIME_32 = 0x01000193L;

private static final long FNV_OFFSET_BASIS_64 = 0xcbf29ce484222325L;
private static final long FNV_PRIME_64 = 0x100000001b3L;

// FNV-1a hash computation for 32-bit hash
public static long hash32(String input) {
long hash = FNV_OFFSET_BASIS_32;
byte[] bytes = input.getBytes(StandardCharsets.UTF_8);

Check warning on line 30 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L29-L30

Added lines #L29 - L30 were not covered by tests
for (byte b : bytes) {
hash ^= (b & 0xFF);
hash *= FNV_PRIME_32;

Check warning on line 33 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L32-L33

Added lines #L32 - L33 were not covered by tests
}
return hash;

Check warning on line 35 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L35

Added line #L35 was not covered by tests
}

// FNV-1a hash computation for 64-bit hash
public static long hash64(String input) {
long hash = FNV_OFFSET_BASIS_64;
byte[] bytes = input.getBytes(StandardCharsets.UTF_8);

Check warning on line 41 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L40-L41

Added lines #L40 - L41 were not covered by tests
for (byte b : bytes) {
hash ^= (b & 0xFF);
hash *= FNV_PRIME_64;

Check warning on line 44 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L43-L44

Added lines #L43 - L44 were not covered by tests
}
return hash;

Check warning on line 46 in server/src/main/java/org/opensearch/common/hash/FNV1a.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/common/hash/FNV1a.java#L46

Added line #L46 was not covered by tests
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -509,7 +509,7 @@ public synchronized IndexShard createShard(
RemoteStoreNodeAttribute.getRemoteStoreSegmentRepo(this.indexSettings.getNodeSettings()),
this.indexSettings.getUUID(),
shardId,
this.indexSettings.getRemoteStorePathType()
this.indexSettings.getRemoteStorePathStrategy()

Check warning on line 512 in server/src/main/java/org/opensearch/index/IndexService.java

View check run for this annotation

Codecov / codecov/patch

server/src/main/java/org/opensearch/index/IndexService.java#L512

Added line #L512 was not covered by tests
);
}
remoteStore = new Store(shardId, this.indexSettings, remoteDirectory, lock, Store.OnClose.EMPTY, path);
Expand Down
17 changes: 12 additions & 5 deletions server/src/main/java/org/opensearch/index/IndexSettings.java
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,9 @@
import org.opensearch.core.common.unit.ByteSizeUnit;
import org.opensearch.core.common.unit.ByteSizeValue;
import org.opensearch.core.index.Index;
import org.opensearch.index.remote.RemoteStorePathType;
import org.opensearch.index.remote.RemoteStoreEnums.PathHashAlgorithm;
import org.opensearch.index.remote.RemoteStoreEnums.PathType;
import org.opensearch.index.remote.RemoteStorePathStrategy;
import org.opensearch.index.translog.Translog;
import org.opensearch.indices.replication.common.ReplicationType;
import org.opensearch.ingest.IngestService;
Expand Down Expand Up @@ -1908,10 +1910,15 @@ public void setDocIdFuzzySetFalsePositiveProbability(double docIdFuzzySetFalsePo
this.docIdFuzzySetFalsePositiveProbability = docIdFuzzySetFalsePositiveProbability;
}

public RemoteStorePathType getRemoteStorePathType() {
public RemoteStorePathStrategy getRemoteStorePathStrategy() {
Map<String, String> remoteCustomData = indexMetadata.getCustomData(IndexMetadata.REMOTE_STORE_CUSTOM_KEY);
return remoteCustomData != null && remoteCustomData.containsKey(RemoteStorePathType.NAME)
? RemoteStorePathType.parseString(remoteCustomData.get(RemoteStorePathType.NAME))
: RemoteStorePathType.FIXED;
if (remoteCustomData != null
&& remoteCustomData.containsKey(PathType.NAME)
&& remoteCustomData.containsKey(PathHashAlgorithm.NAME)) {
PathType pathType = PathType.parseString(remoteCustomData.get(PathType.NAME));
PathHashAlgorithm pathHashAlgorithm = PathHashAlgorithm.parseString(remoteCustomData.get(PathHashAlgorithm.NAME));
return new RemoteStorePathStrategy(pathType, pathHashAlgorithm);
}
return new RemoteStorePathStrategy(PathType.FIXED);
}
}

This file was deleted.

Loading

0 comments on commit 631694e

Please sign in to comment.