43
43
public class RemoteMigrationIndexMetadataUpdater {
44
44
private final DiscoveryNodes discoveryNodes ;
45
45
private final RoutingTable routingTable ;
46
- private final Settings settings ;
46
+ private final Settings clusterSettings ;
47
47
private final IndexMetadata indexMetadata ;
48
48
private final Logger logger ;
49
49
50
50
public RemoteMigrationIndexMetadataUpdater (
51
51
DiscoveryNodes discoveryNodes ,
52
52
RoutingTable routingTable ,
53
53
IndexMetadata indexMetadata ,
54
- Settings settings ,
54
+ Settings clusterSettings ,
55
55
Logger logger
56
56
57
57
) {
58
58
this .discoveryNodes = discoveryNodes ;
59
59
this .routingTable = routingTable ;
60
- this .settings = settings ;
60
+ this .clusterSettings = clusterSettings ;
61
61
this .indexMetadata = indexMetadata ;
62
62
this .logger = logger ;
63
63
}
@@ -134,7 +134,7 @@ private boolean needsRemoteIndexSettingsUpdate(
134
134
public void maybeUpdateRemoteStorePathStrategy (IndexMetadata .Builder indexMetadataBuilder , String index ) {
135
135
if (indexHasRemotePathMetadata (indexMetadata ) == false ) {
136
136
logger .info ("Adding remote store path strategy for index [{}] during migration" , index );
137
- indexMetadataBuilder .putCustom (REMOTE_STORE_CUSTOM_KEY , createRemoteStorePathTypeMetadata (settings , discoveryNodes ));
137
+ indexMetadataBuilder .putCustom (REMOTE_STORE_CUSTOM_KEY , createRemoteStorePathTypeMetadata (clusterSettings , discoveryNodes ));
138
138
} else {
139
139
logger .debug ("Index {} already has remote store path strategy" , index );
140
140
}
@@ -143,18 +143,18 @@ public void maybeUpdateRemoteStorePathStrategy(IndexMetadata.Builder indexMetada
143
143
/**
144
144
* Generates the remote store path type information to be added to custom data of index metadata.
145
145
*
146
- * @param settings Current Cluster settings from {@link ClusterState}
146
+ * @param clusterSettings Current Cluster settings from {@link ClusterState}
147
147
* @param discoveryNodes Current {@link DiscoveryNodes} from the cluster state
148
148
* @return {@link Map} to be added as custom data in index metadata
149
149
*/
150
- private Map <String , String > createRemoteStorePathTypeMetadata (Settings settings , DiscoveryNodes discoveryNodes ) {
150
+ private Map <String , String > createRemoteStorePathTypeMetadata (Settings clusterSettings , DiscoveryNodes discoveryNodes ) {
151
151
Version minNodeVersion = discoveryNodes .getMinNodeVersion ();
152
152
PathType pathType = Version .CURRENT .compareTo (minNodeVersion ) <= 0
153
- ? CLUSTER_REMOTE_STORE_PATH_TYPE_SETTING .get (settings )
153
+ ? CLUSTER_REMOTE_STORE_PATH_TYPE_SETTING .get (clusterSettings )
154
154
: PathType .FIXED ;
155
155
PathHashAlgorithm pathHashAlgorithm = pathType == PathType .FIXED
156
156
? null
157
- : CLUSTER_REMOTE_STORE_PATH_HASH_ALGORITHM_SETTING .get (settings );
157
+ : CLUSTER_REMOTE_STORE_PATH_HASH_ALGORITHM_SETTING .get (clusterSettings );
158
158
Map <String , String > remoteCustomData = new HashMap <>();
159
159
remoteCustomData .put (PathType .NAME , pathType .name ());
160
160
if (Objects .nonNull (pathHashAlgorithm )) {
0 commit comments