|
42 | 42 | import java.io.IOException; |
43 | 43 | import java.time.Instant; |
44 | 44 | import java.util.Arrays; |
45 | | -import java.util.HashSet; |
46 | 45 | import java.util.List; |
47 | 46 | import java.util.Locale; |
48 | 47 | import java.util.Map; |
49 | 48 | import java.util.Objects; |
50 | 49 | import java.util.function.BooleanSupplier; |
51 | 50 | import java.util.stream.Collectors; |
| 51 | +import java.util.stream.Stream; |
| 52 | + |
| 53 | +import static java.util.stream.Collectors.toSet; |
52 | 54 |
|
53 | 55 | /** |
54 | 56 | * "Mode" that controls which behaviors and settings an index supports. |
@@ -139,16 +141,7 @@ void validateWithOtherSettings(Map<Setting<?>, Object> settings) { |
139 | 141 | throw new IllegalArgumentException(error(IndexMetadata.INDEX_ROUTING_PARTITION_SIZE_SETTING)); |
140 | 142 | } |
141 | 143 |
|
142 | | - Settings settingsWithIndexMode; |
143 | | - if (IndexSettings.TSDB_SYNTHETIC_ID_FEATURE_FLAG) { |
144 | | - settingsWithIndexMode = Settings.builder() |
145 | | - .put(IndexSettings.MODE.getKey(), getName()) |
146 | | - // Default values of some index sort settings depend of the feature flag and USE_SYNTHETIC_ID setting |
147 | | - .put(IndexSettings.USE_SYNTHETIC_ID.getKey(), (Boolean) settings.get(IndexSettings.USE_SYNTHETIC_ID)) |
148 | | - .build(); |
149 | | - } else { |
150 | | - settingsWithIndexMode = Settings.builder().put(IndexSettings.MODE.getKey(), getName()).build(); |
151 | | - } |
| 144 | + var settingsWithIndexMode = Settings.builder().put(IndexSettings.MODE.getKey(), getName()).build(); |
152 | 145 |
|
153 | 146 | for (Setting<?> unsupported : TIME_SERIES_UNSUPPORTED) { |
154 | 147 | if (false == Objects.equals(unsupported.getDefault(settingsWithIndexMode), settings.get(unsupported))) { |
@@ -467,22 +460,20 @@ private static CompressedXContent createDefaultMapping(boolean includeHostName) |
467 | 460 | IndexSortConfig.INDEX_SORT_MISSING_SETTING |
468 | 461 | ); |
469 | 462 |
|
470 | | - static final List<Setting<?>> VALIDATE_WITH_SETTINGS; |
471 | | - static { |
472 | | - var settings = new HashSet<Setting<?>>(); |
473 | | - settings.add(IndexMetadata.INDEX_NUMBER_OF_SHARDS_SETTING); |
474 | | - settings.add(IndexMetadata.INDEX_ROUTING_PARTITION_SIZE_SETTING); |
475 | | - settings.add(IndexMetadata.INDEX_ROUTING_PATH); |
476 | | - settings.add(IndexMetadata.INDEX_DIMENSIONS); |
477 | | - settings.add(IndexSettings.LOGSDB_ROUTE_ON_SORT_FIELDS); |
478 | | - settings.add(IndexSettings.TIME_SERIES_START_TIME); |
479 | | - settings.add(IndexSettings.TIME_SERIES_END_TIME); |
480 | | - if (IndexSettings.TSDB_SYNTHETIC_ID_FEATURE_FLAG) { |
481 | | - settings.add(IndexSettings.USE_SYNTHETIC_ID); |
482 | | - } |
483 | | - settings.addAll(TIME_SERIES_UNSUPPORTED); |
484 | | - VALIDATE_WITH_SETTINGS = List.copyOf(settings); |
485 | | - } |
| 463 | + static final List<Setting<?>> VALIDATE_WITH_SETTINGS = List.copyOf( |
| 464 | + Stream.concat( |
| 465 | + Stream.of( |
| 466 | + IndexMetadata.INDEX_NUMBER_OF_SHARDS_SETTING, |
| 467 | + IndexMetadata.INDEX_ROUTING_PARTITION_SIZE_SETTING, |
| 468 | + IndexMetadata.INDEX_ROUTING_PATH, |
| 469 | + IndexMetadata.INDEX_DIMENSIONS, |
| 470 | + IndexSettings.LOGSDB_ROUTE_ON_SORT_FIELDS, |
| 471 | + IndexSettings.TIME_SERIES_START_TIME, |
| 472 | + IndexSettings.TIME_SERIES_END_TIME |
| 473 | + ), |
| 474 | + TIME_SERIES_UNSUPPORTED.stream() |
| 475 | + ).collect(toSet()) |
| 476 | + ); |
486 | 477 |
|
487 | 478 | private final String name; |
488 | 479 |
|
|
0 commit comments