1818import org .elasticsearch .common .Strings ;
1919import org .elasticsearch .common .time .DateUtils ;
2020import org .elasticsearch .common .xcontent .support .XContentMapValues ;
21- import org .elasticsearch .core .UpdateForV9 ;
2221import org .elasticsearch .index .mapper .DateFieldMapper ;
2322import org .elasticsearch .index .mapper .SourceFieldMapper ;
2423import org .elasticsearch .index .mapper .TimeSeriesIdFieldMapper ;
@@ -258,90 +257,47 @@ private void bulk(String index, String valueSuffix, int count) throws IOExceptio
258257 }
259258
260259 public void testTsdb () throws IOException {
261- final Version oldClusterVersion = Version .fromString (getOldClusterVersion ());
262-
263260 StringBuilder bulk = new StringBuilder ();
264261 if (isOldCluster ()) {
265262 createTsdbIndex ();
266263 tsdbBulk (bulk , TSDB_DIMS .get (0 ), TSDB_TIMES [0 ], TSDB_TIMES [1 ], 0.1 );
267264 tsdbBulk (bulk , TSDB_DIMS .get (1 ), TSDB_TIMES [0 ], TSDB_TIMES [1 ], -0.1 );
268265 bulk ("tsdb" , bulk .toString ());
269- assertTsdbAgg (oldClusterVersion , EXPECTED_TSDB_TSIDS_NODES_0 , closeTo (215.95 , 0.005 ), closeTo (-215.95 , 0.005 ));
266+ assertTsdbAgg (EXPECTED_TSDB_TSIDS_NODES_0 , closeTo (215.95 , 0.005 ), closeTo (-215.95 , 0.005 ));
270267 } else if (isFirstMixedCluster ()) {
271268 tsdbBulk (bulk , TSDB_DIMS .get (0 ), TSDB_TIMES [1 ], TSDB_TIMES [2 ], 0.1 );
272269 tsdbBulk (bulk , TSDB_DIMS .get (1 ), TSDB_TIMES [1 ], TSDB_TIMES [2 ], -0.1 );
273270 tsdbBulk (bulk , TSDB_DIMS .get (2 ), TSDB_TIMES [0 ], TSDB_TIMES [2 ], 1.1 );
274271 bulk ("tsdb" , bulk .toString ());
275- if (oldClusterVersion .onOrAfter (Version .V_8_13_0 )) {
276- assertTsdbAgg (
277- oldClusterVersion ,
278- EXPECTED_TSDB_TSIDS_NODES_1 ,
279- closeTo (217.45 , 0.005 ),
280- closeTo (2391.95 , 0.005 ),
281- closeTo (-217.45 , 0.005 )
282- );
283- } else {
284- assertTsdbAgg (
285- oldClusterVersion ,
286- EXPECTED_TSDB_TSIDS_NODES_1 ,
287- closeTo (217.45 , 0.005 ),
288- closeTo (-217.45 , 0.005 ),
289- closeTo (2391.95 , 0.005 )
290- );
291- }
272+ assertTsdbAgg (EXPECTED_TSDB_TSIDS_NODES_1 , closeTo (217.45 , 0.005 ), closeTo (2391.95 , 0.005 ), closeTo (-217.45 , 0.005 ));
292273 } else if (isMixedCluster ()) {
293274 tsdbBulk (bulk , TSDB_DIMS .get (0 ), TSDB_TIMES [2 ], TSDB_TIMES [3 ], 0.1 );
294275 tsdbBulk (bulk , TSDB_DIMS .get (1 ), TSDB_TIMES [2 ], TSDB_TIMES [3 ], -0.1 );
295276 tsdbBulk (bulk , TSDB_DIMS .get (2 ), TSDB_TIMES [2 ], TSDB_TIMES [3 ], 1.1 );
296277 tsdbBulk (bulk , TSDB_DIMS .get (3 ), TSDB_TIMES [0 ], TSDB_TIMES [3 ], 10 );
297278 bulk ("tsdb" , bulk .toString ());
298- if (oldClusterVersion .onOrAfter (Version .V_8_13_0 )) {
299- assertTsdbAgg (
300- oldClusterVersion ,
301- EXPECTED_TSDB_TSIDS_NODES_2 ,
302- closeTo (218.95 , 0.5 ),
303- closeTo (21895.0 , 0.005 ),
304- closeTo (2408.45 , 0.005 ),
305- closeTo (-218.95 , 0.005 )
306- );
307- } else {
308- assertTsdbAgg (
309- oldClusterVersion ,
310- EXPECTED_TSDB_TSIDS_NODES_2 ,
311- closeTo (218.95 , 0.005 ),
312- closeTo (-218.95 , 0.005 ),
313- closeTo (2408.45 , 0.005 ),
314- closeTo (21895 , 0.5 )
315- );
316- }
279+ assertTsdbAgg (
280+ EXPECTED_TSDB_TSIDS_NODES_2 ,
281+ closeTo (218.95 , 0.5 ),
282+ closeTo (21895.0 , 0.005 ),
283+ closeTo (2408.45 , 0.005 ),
284+ closeTo (-218.95 , 0.005 )
285+ );
317286 } else {
318287 tsdbBulk (bulk , TSDB_DIMS .get (0 ), TSDB_TIMES [3 ], TSDB_TIMES [4 ], 0.1 );
319288 tsdbBulk (bulk , TSDB_DIMS .get (1 ), TSDB_TIMES [3 ], TSDB_TIMES [4 ], -0.1 );
320289 tsdbBulk (bulk , TSDB_DIMS .get (2 ), TSDB_TIMES [3 ], TSDB_TIMES [4 ], 1.1 );
321290 tsdbBulk (bulk , TSDB_DIMS .get (3 ), TSDB_TIMES [3 ], TSDB_TIMES [4 ], 10 );
322291 tsdbBulk (bulk , TSDB_DIMS .get (4 ), TSDB_TIMES [0 ], TSDB_TIMES [4 ], -5 );
323292 bulk ("tsdb" , bulk .toString ());
324- if (oldClusterVersion .onOrAfter (Version .V_8_13_0 )) {
325- assertTsdbAgg (
326- oldClusterVersion ,
327- EXPECTED_TSDB_TSIDS_NODES_3 ,
328- closeTo (220.45 , 0.005 ),
329- closeTo (-11022.5 , 0.5 ),
330- closeTo (22045 , 0.5 ),
331- closeTo (2424.95 , 0.005 ),
332- closeTo (-220.45 , 0.005 )
333- );
334- } else {
335- assertTsdbAgg (
336- oldClusterVersion ,
337- EXPECTED_TSDB_TSIDS_NODES_3 ,
338- closeTo (220.45 , 0.005 ),
339- closeTo (-220.45 , 0.005 ),
340- closeTo (2424.95 , 0.005 ),
341- closeTo (22045 , 0.5 ),
342- closeTo (-11022.5 , 0.5 )
343- );
344- }
293+ assertTsdbAgg (
294+ EXPECTED_TSDB_TSIDS_NODES_3 ,
295+ closeTo (220.45 , 0.005 ),
296+ closeTo (-11022.5 , 0.5 ),
297+ closeTo (22045 , 0.5 ),
298+ closeTo (2424.95 , 0.005 ),
299+ closeTo (-220.45 , 0.005 )
300+ );
345301 }
346302 }
347303
@@ -383,10 +339,7 @@ private void tsdbBulk(StringBuilder bulk, String dim, long timeStart, long timeE
383339 }
384340 }
385341
386- private void assertTsdbAgg (final Version oldClusterVersion , final List <String > expectedTsids , final Matcher <?>... expected )
387- throws IOException {
388- @ UpdateForV9 (owner = UpdateForV9 .Owner .SEARCH_ANALYTICS )
389- boolean onOrAfterTsidHashingVersion = oldClusterVersion .onOrAfter (Version .V_8_13_0 );
342+ private void assertTsdbAgg (final List <String > expectedTsids , final Matcher <?>... expected ) throws IOException {
390343 Request request = new Request ("POST" , "/tsdb/_search" );
391344 request .addParameter ("size" , "0" );
392345 XContentBuilder body = JsonXContent .contentBuilder ().startObject ();
@@ -403,8 +356,7 @@ private void assertTsdbAgg(final Version oldClusterVersion, final List<String> e
403356 request .setJsonEntity (Strings .toString (body .endObject ()));
404357 ListMatcher tsidsExpected = matchesList ();
405358 for (int d = 0 ; d < expected .length ; d ++) {
406- // NOTE: from Version 8.12.0 on we use tsid hashing for the _tsid field
407- Object key = onOrAfterTsidHashingVersion ? expectedTsids .get (d ) : Map .of ("dim" , IndexingIT .TSDB_DIMS .get (d ));
359+ Object key = expectedTsids .get (d );
408360 tsidsExpected = tsidsExpected .item (matchesMap ().extraOk ().entry ("key" , key ).entry ("avg" , Map .of ("value" , expected [d ])));
409361 }
410362 assertMap (
0 commit comments