@@ -36,7 +36,7 @@ use datafusion::arrow::ipc::convert;
3636use datafusion:: arrow:: ipc:: writer:: { DictionaryTracker , IpcDataGenerator , IpcWriteOptions } ;
3737use datafusion:: arrow:: record_batch:: RecordBatch ;
3838use futures:: { StreamExt , stream} ;
39- use modelardb_test:: data_generation;
39+ use modelardb_test:: data_generation:: generate_multivariate_time_series ;
4040use modelardb_test:: table:: {
4141 NORMAL_TABLE_NAME , TIME_SERIES_TABLE_NAME , table_metadata_protobuf_bytes,
4242} ;
@@ -265,15 +265,14 @@ impl TestContext {
265265 multiply_noise_range : Option < Range < f32 > > ,
266266 maybe_tag : Option < & str > ,
267267 ) -> RecordBatch {
268- let ( uncompressed_timestamps, mut uncompressed_values) =
269- data_generation:: generate_multivariate_time_series (
270- TIME_SERIES_TEST_LENGTH ,
271- 5 ,
272- SEGMENT_TEST_MINIMUM_LENGTH ..2 * SEGMENT_TEST_MINIMUM_LENGTH + 1 ,
273- generate_irregular_timestamps,
274- multiply_noise_range,
275- 100.0 ..200.0 ,
276- ) ;
268+ let ( uncompressed_timestamps, mut uncompressed_values) = generate_multivariate_time_series (
269+ TIME_SERIES_TEST_LENGTH ,
270+ 5 ,
271+ SEGMENT_TEST_MINIMUM_LENGTH ..2 * SEGMENT_TEST_MINIMUM_LENGTH + 1 ,
272+ generate_irregular_timestamps,
273+ multiply_noise_range,
274+ 100.0 ..200.0 ,
275+ ) ;
277276
278277 let time_series_len = uncompressed_timestamps. len ( ) ;
279278
0 commit comments