Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: Organize use statements

pull/24376/head
Carol (Nichols || Goulding) 2023-04-14 14:18:22 -04:00
parent b4bad29357
commit 4f7fe18e51
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
compactor2_test_utils/src/lib.rs
View File

@ -15,12 +15,8 @@
mod commit_wrapper; mod commit_wrapper;
mod display; mod display;
mod simulator; mod simulator;
use commit_wrapper::{CommitRecorderBuilder, InvariantCheck};
pub use display::{display_format, display_size, format_files, format_files_split}; pub use display::{display_format, display_size, format_files, format_files_split};
use iox_catalog::interface::Catalog;
use iox_query::exec::ExecutorType;
use simulator::ParquetFileSimulator;
use tracker::AsyncSemaphoreMetrics;
use std::{ use std::{
collections::HashSet, collections::HashSet,
@ -30,12 +26,23 @@ use std::{
time::Duration, time::Duration,
}; };
use crate::{
commit_wrapper::{CommitRecorderBuilder, InvariantCheck},
simulator::ParquetFileSimulator,
};
use async_trait::async_trait; use async_trait::async_trait;
use backoff::BackoffConfig; use backoff::BackoffConfig;
use compactor2::{
compact,
config::{Config, PartitionsSourceConfig},
hardcoded_components, Components, PanicDataFusionPlanner, PartitionInfo,
};
use data_types::{ColumnType, CompactionLevel, ParquetFile, TableId, TRANSITION_SHARD_NUMBER}; use data_types::{ColumnType, CompactionLevel, ParquetFile, TableId, TRANSITION_SHARD_NUMBER};
use datafusion::arrow::record_batch::RecordBatch; use datafusion::arrow::record_batch::RecordBatch;
use datafusion_util::config::register_iox_object_store; use datafusion_util::config::register_iox_object_store;
use futures::TryStreamExt; use futures::TryStreamExt;
use iox_catalog::interface::Catalog;
use iox_query::exec::ExecutorType;
use iox_tests::{ use iox_tests::{
ParquetFileBuilder, TestCatalog, TestNamespace, TestParquetFileBuilder, TestPartition, ParquetFileBuilder, TestCatalog, TestNamespace, TestParquetFileBuilder, TestPartition,
TestShard, TestTable, TestShard, TestTable,
@ -44,12 +51,7 @@ use iox_time::{MockProvider, Time, TimeProvider};
use object_store::{path::Path, DynObjectStore}; use object_store::{path::Path, DynObjectStore};
use parquet_file::storage::{ParquetStorage, StorageId}; use parquet_file::storage::{ParquetStorage, StorageId};
use schema::sort::SortKey; use schema::sort::SortKey;
use tracker::AsyncSemaphoreMetrics;
use compactor2::{
compact,
config::{Config, PartitionsSourceConfig},
hardcoded_components, Components, PanicDataFusionPlanner, PartitionInfo,
};
// Default values for the test setup builder // Default values for the test setup builder
const SHARD_INDEX: i32 = TRANSITION_SHARD_NUMBER; const SHARD_INDEX: i32 = TRANSITION_SHARD_NUMBER;