2929import java .io .IOException ;
3030import java .util .List ;
3131import java .util .Map ;
32- import java .util .function .BiFunction ;
3332import java .util .function .Consumer ;
3433import java .util .function .Function ;
3534import java .util .stream .Collectors ;
@@ -322,30 +321,17 @@ public void testIsMetadataField() throws IOException {
322321 return createMapperService (settingsBuilder .build (), mapping (b -> {}));
323322 };
324323
325- Consumer <MapperService > assertMapperService = initMapperServiceConsumer (version );
326-
327- for (IndexMode indexMode : IndexMode .values ()) {
328- MapperService mapperService = initMapperService .apply (indexMode );
329- assertMapperService .accept (mapperService );
330- }
331- }
332-
333- private static Consumer <MapperService > initMapperServiceConsumer (IndexVersion version ) {
334- BiFunction <String , MapperService , Boolean > shouldSkipField = (field , mapperService ) -> {
335- if (NestedPathFieldMapper .NAME .equals (field ) && version .before (IndexVersions .V_8_0_0 )) {
336- return true ; // Nested field does not exist in the 7x line
337- }
338-
339- boolean isTimeSeriesField = field .equals ("_tsid" ) || field .equals ("_ts_routing_hash" );
340- // should only skip for these fields if index mode is set to time_series
341- return isTimeSeriesField && mapperService .getIndexSettings ().getMode ().equals (IndexMode .TIME_SERIES ) == false ;
342- };
343-
344- return (mapperService ) -> {
324+ Consumer <MapperService > assertMapperService = (mapperService ) -> {
345325 assertFalse (mapperService .isMetadataField (randomAlphaOfLengthBetween (10 , 15 )));
346326
347327 for (String builtIn : IndicesModule .getBuiltInMetadataFields ()) {
348- if (shouldSkipField .apply (builtIn , mapperService )) {
328+ if (NestedPathFieldMapper .NAME .equals (builtIn ) && version .before (IndexVersions .V_8_0_0 )) {
329+ continue ; // Nested field does not exist in the 7x line
330+ }
331+ boolean isTimeSeriesField = builtIn .equals ("_tsid" ) || builtIn .equals ("_ts_routing_hash" );
332+ boolean isTimeSeriesMode = mapperService .getIndexSettings ().getMode ().equals (IndexMode .TIME_SERIES );
333+
334+ if (isTimeSeriesField && isTimeSeriesMode == false ) {
349335 continue ;
350336 }
351337 assertTrue (
@@ -354,6 +340,11 @@ private static Consumer<MapperService> initMapperServiceConsumer(IndexVersion ve
354340 );
355341 }
356342 };
343+
344+ for (IndexMode indexMode : IndexMode .values ()) {
345+ MapperService mapperService = initMapperService .apply (indexMode );
346+ assertMapperService .accept (mapperService );
347+ }
357348 }
358349
359350 public void testMappingUpdateChecks () throws IOException {
0 commit comments