diff --git a/compactor/src/handler.rs b/compactor/src/handler.rs index d4bea8b6bd..c1ec811b92 100644 --- a/compactor/src/handler.rs +++ b/compactor/src/handler.rs @@ -1,18 +1,14 @@ //! Compactor handler use async_trait::async_trait; -use backoff::{Backoff, BackoffConfig}; -use data_types::SequencerId; +use backoff::Backoff; use futures::{ future::{BoxFuture, Shared}, FutureExt, StreamExt, TryFutureExt, }; -use iox_catalog::interface::Catalog; use iox_query::exec::Executor; -use iox_time::TimeProvider; use metric::Attributes; use observability_deps::tracing::*; -use parquet_file::storage::ParquetStorage; use std::sync::Arc; use thiserror::Error; use tokio::{ @@ -66,29 +62,7 @@ pub struct CompactorHandlerImpl { impl CompactorHandlerImpl { /// Initialize the Compactor - pub fn new( - sequencers: Vec, - catalog: Arc, - store: ParquetStorage, - exec: Arc, - time_provider: Arc, - registry: Arc, - config: CompactorConfig, - ) -> Self { - Self::new_with_compactor(Compactor::new( - sequencers, - catalog, - store, - exec, - time_provider, - BackoffConfig::default(), - config, - registry, - )) - } - - /// Initialize the Compactor - pub fn new_with_compactor(compactor: Compactor) -> Self { + pub fn new(compactor: Compactor) -> Self { let compactor_data = Arc::new(compactor); let shutdown = CancellationToken::new(); diff --git a/ioxd_compactor/src/lib.rs b/ioxd_compactor/src/lib.rs index 0f489f6865..31f8402ebd 100644 --- a/ioxd_compactor/src/lib.rs +++ b/ioxd_compactor/src/lib.rs @@ -146,7 +146,7 @@ pub async fn create_compactor_server_type( ) .await?; - let compactor_handler = Arc::new(CompactorHandlerImpl::new_with_compactor(compactor)); + let compactor_handler = Arc::new(CompactorHandlerImpl::new(compactor)); let compactor = CompactorServer::new(metric_registry, compactor_handler); Ok(Arc::new(CompactorServerType::new(compactor, common_state))) }