refactor(idpe-17789): rename partition_stream mod to compaction_job_s…

…tream mod
Shopify · Jul 25, 2023 · 8abce6b · 8abce6b
1 parent 74e48dc
commit 8abce6b
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/...rc/components/partition_stream/endless.rs → ...mponents/compaction_job_stream/endless.rs b/...rc/components/partition_stream/endless.rs → ...mponents/compaction_job_stream/endless.rs
diff --git a/...or/src/components/partition_stream/mod.rs → ...c/components/compaction_job_stream/mod.rs b/...or/src/components/partition_stream/mod.rs → ...c/components/compaction_job_stream/mod.rs
diff --git a/...r/src/components/partition_stream/once.rs → .../components/compaction_job_stream/once.rs b/...r/src/components/partition_stream/once.rs → .../components/compaction_job_stream/once.rs
diff --git a/compactor/src/components/hardcoded.rs b/compactor/src/components/hardcoded.rs
@@ -13,6 +13,9 @@ use crate::{config::Config, error::ErrorKind, object_store::ignore_writes::Ignor
 use super::{
  changed_files_filter::logging::LoggingChangedFiles,
  commit::CommitToScheduler,
+ compaction_job_stream::{
+ endless::EndlessCompactionJobStream, once::OnceCompactionJobStream, CompactionJobStream,
+ },
  compaction_jobs_source::{
  logging::LoggingCompactionJobsWrapper, metrics::MetricsCompactionJobsSourceWrapper,
  not_empty::NotEmptyCompactionJobsSourceWrapper,
@@ -63,9 +66,6 @@ use super::{
  catalog::CatalogPartitionSource, logging::LoggingPartitionSourceWrapper,
  metrics::MetricsPartitionSourceWrapper,
  },
- partition_stream::{
- endless::EndlessCompactionJobStream, once::OnceCompactionJobStream, CompactionJobStream,
- },
  post_classification_partition_filter::{
  logging::LoggingPostClassificationFilterWrapper,
  metrics::MetricsPostClassificationFilterWrapper, possible_progress::PossibleProgressFilter,

diff --git a/compactor/src/components/mod.rs b/compactor/src/components/mod.rs
@@ -2,17 +2,18 @@ use std::sync::Arc;
 
 use self::{
  changed_files_filter::ChangedFilesFilter, commit::CommitToScheduler,
- df_plan_exec::DataFusionPlanExec, df_planner::DataFusionPlanner, divide_initial::DivideInitial,
- file_classifier::FileClassifier, ir_planner::IRPlanner, parquet_files_sink::ParquetFilesSink,
+ compaction_job_stream::CompactionJobStream, df_plan_exec::DataFusionPlanExec,
+ df_planner::DataFusionPlanner, divide_initial::DivideInitial, file_classifier::FileClassifier,
+ ir_planner::IRPlanner, parquet_files_sink::ParquetFilesSink,
  partition_done_sink::PartitionDoneSink, partition_files_source::PartitionFilesSource,
  partition_filter::PartitionFilter, partition_info_source::PartitionInfoSource,
- partition_stream::CompactionJobStream,
  post_classification_partition_filter::PostClassificationPartitionFilter,
  round_info_source::RoundInfoSource, round_split::RoundSplit, scratchpad::ScratchpadGen,
 };
 
 pub mod changed_files_filter;
 pub(crate) mod commit;
+pub mod compaction_job_stream;
 pub mod compaction_jobs_source;
 pub mod df_plan_exec;
 pub mod df_planner;
@@ -30,7 +31,6 @@ pub mod partition_files_source;
 pub mod partition_filter;
 pub mod partition_info_source;
 pub mod partition_source;
-pub mod partition_stream;
 pub mod post_classification_partition_filter;
 pub mod report;
 pub mod round_info_source;