rename

Signed-off-by: coldWater <forsaken628@gmail.com>

Author: forsaken628

src/query/pipeline/transforms/src/processors/transforms/transform_multi_sort_merge.rs

@@ -77,7 +77,7 @@ pub fn try_add_multi_sort_merge(
             }
             let output_port = OutputPort::create();
 
-            let processor = ProcessorPtr::create(create_multi_sort_merge_processor(
+            let processor = ProcessorPtr::create(create_processor(
                 inputs_port.clone(),
                 output_port.clone(),
                 schema,
@@ -98,7 +98,7 @@ pub fn try_add_multi_sort_merge(
     }
 }
 
-pub fn create_multi_sort_merge_processor(
+fn create_processor(
     inputs: Vec<Arc<InputPort>>,
     output: Arc<OutputPort>,
     schema: DataSchemaRef,

src/query/service/src/pipelines/processors/transforms/sort/mod.rs

@@ -25,19 +25,19 @@ use sort_spill::SpillableBlock;
 use crate::spillers::Spiller;
 
 mod bounds;
-mod builder;
-mod collect;
-mod exchange;
-mod execute;
 mod merge_sort;
-mod route;
-mod shuffle;
+mod sort_builder;
+mod sort_collect;
+mod sort_exchange;
+mod sort_execute;
+mod sort_route;
+mod sort_shuffle;
 mod sort_spill;
 
-pub use builder::*;
-pub use exchange::*;
-pub use route::*;
-pub use shuffle::*;
+pub use sort_builder::*;
+pub use sort_exchange::*;
+pub use sort_route::*;
+pub use sort_shuffle::*;
 
 #[derive(Clone)]
 struct Base {

src/query/service/src/pipelines/processors/transforms/sort/builder.rs renamed to src/query/service/src/pipelines/processors/transforms/sort/sort_builder.rs

@@ -33,11 +33,11 @@ use databend_common_pipeline_transforms::sort::Rows;
 use databend_common_pipeline_transforms::sort::RowsTypeVisitor;
 use databend_common_pipeline_transforms::MemorySettings;
 
-use super::collect::TransformSortCollect;
-use super::execute::TransformSortExecute;
 use super::merge_sort::TransformSort;
-use super::shuffle::SortSampleState;
-use super::shuffle::TransformSortShuffle;
+use super::sort_collect::TransformSortCollect;
+use super::sort_execute::TransformSortExecute;
+use super::sort_shuffle::SortSampleState;
+use super::sort_shuffle::TransformSortShuffle;
 use super::Base;
 use crate::spillers::Spiller;
 

src/query/service/src/pipelines/processors/transforms/sort/collect.rs renamed to src/query/service/src/pipelines/processors/transforms/sort/sort_collect.rs

@@ -634,7 +634,7 @@ impl DefaultSettings {
                     range: Some(SettingRange::Numeric(4 * 1024..=u64::MAX)),
                 }),
                 ("range_shuffle_sort_simple_size", DefaultSettingValue {
-                    value: UserSettingValue::UInt64(20),
+                    value: UserSettingValue::UInt64(0),
                     desc: "Sets the simple size per partition used for range shuffle sorting, 0 to disable range shuffle sorting.",
                     mode: SettingMode::Both,
                     scope: SettingScope::Both,