From 56dc4715bef55aa38467752381de055daaab8baa Mon Sep 17 00:00:00 2001 From: zhang2014 Date: Tue, 27 Jun 2023 21:32:11 +0800 Subject: [PATCH] chore(query): fix typo --- src/query/catalog/src/table.rs | 2 +- src/query/service/src/table_functions/async_crash_me.rs | 2 +- .../src/table_functions/infer_schema/infer_schema_table.rs | 2 +- .../src/table_functions/list_stage/list_stage_table.rs | 2 +- .../service/src/table_functions/numbers/numbers_table.rs | 2 +- src/query/service/src/table_functions/openai/ai_to_sql.rs | 2 +- src/query/service/src/table_functions/srf/range.rs | 2 +- src/query/service/src/table_functions/sync_crash_me.rs | 2 +- src/query/storages/fuse/src/fuse_table.rs | 4 ++-- .../clustering_information/clustering_information_table.rs | 2 +- .../fuse/src/table_functions/fuse_blocks/fuse_block_table.rs | 2 +- .../src/table_functions/fuse_segments/fuse_segment_table.rs | 2 +- .../src/table_functions/fuse_snapshots/fuse_snapshot_table.rs | 2 +- .../table_functions/fuse_statistics/fuse_statistic_table.rs | 2 +- src/query/storages/hive/hive/src/hive_table.rs | 2 +- src/query/storages/iceberg/src/table.rs | 2 +- src/query/storages/memory/src/memory_table.rs | 2 +- src/query/storages/null/src/null_table.rs | 2 +- src/query/storages/parquet/src/parquet_table/table.rs | 2 +- src/query/storages/random/src/random_table.rs | 2 +- src/query/storages/result_cache/src/table_function/table.rs | 2 +- src/query/storages/stage/src/stage_table.rs | 2 +- src/query/storages/system/src/log_queue.rs | 2 +- src/query/storages/system/src/table.rs | 4 ++-- src/query/storages/system/src/tracing_table.rs | 2 +- 25 files changed, 27 insertions(+), 27 deletions(-) diff --git a/src/query/catalog/src/table.rs b/src/query/catalog/src/table.rs index 178777126ad39..8622348077086 100644 --- a/src/query/catalog/src/table.rs +++ b/src/query/catalog/src/table.rs @@ -154,7 +154,7 @@ pub trait Table: Sync + Send { &self, ctx: Arc, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { let (_, _) = (ctx, push_downs); Err(ErrorCode::Unimplemented(format!( diff --git a/src/query/service/src/table_functions/async_crash_me.rs b/src/query/service/src/table_functions/async_crash_me.rs index 2f51d256c2620..68ccc0e501721 100644 --- a/src/query/service/src/table_functions/async_crash_me.rs +++ b/src/query/service/src/table_functions/async_crash_me.rs @@ -111,7 +111,7 @@ impl Table for AsyncCrashMeTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { // dummy statistics Ok((PartStatistics::new_exact(1, 1, 1, 1), Partitions::default())) diff --git a/src/query/service/src/table_functions/infer_schema/infer_schema_table.rs b/src/query/service/src/table_functions/infer_schema/infer_schema_table.rs index 7bd20e2442574..c9c73132bd035 100644 --- a/src/query/service/src/table_functions/infer_schema/infer_schema_table.rs +++ b/src/query/service/src/table_functions/infer_schema/infer_schema_table.rs @@ -111,7 +111,7 @@ impl Table for InferSchemaTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/service/src/table_functions/list_stage/list_stage_table.rs b/src/query/service/src/table_functions/list_stage/list_stage_table.rs index 983aa63fde728..7c6117ed7b942 100644 --- a/src/query/service/src/table_functions/list_stage/list_stage_table.rs +++ b/src/query/service/src/table_functions/list_stage/list_stage_table.rs @@ -115,7 +115,7 @@ impl Table for ListStageTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/service/src/table_functions/numbers/numbers_table.rs b/src/query/service/src/table_functions/numbers/numbers_table.rs index dd37c45e35802..48dbde9b3803f 100644 --- a/src/query/service/src/table_functions/numbers/numbers_table.rs +++ b/src/query/service/src/table_functions/numbers/numbers_table.rs @@ -137,7 +137,7 @@ impl Table for NumbersTable { &self, ctx: Arc, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { let max_block_size = ctx.get_settings().get_max_block_size()?; let mut limit = None; diff --git a/src/query/service/src/table_functions/openai/ai_to_sql.rs b/src/query/service/src/table_functions/openai/ai_to_sql.rs index 0802d61bc32f0..9b942526158a2 100644 --- a/src/query/service/src/table_functions/openai/ai_to_sql.rs +++ b/src/query/service/src/table_functions/openai/ai_to_sql.rs @@ -122,7 +122,7 @@ impl Table for GPT2SQLTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { // dummy statistics Ok((PartStatistics::default_exact(), Partitions::default())) diff --git a/src/query/service/src/table_functions/srf/range.rs b/src/query/service/src/table_functions/srf/range.rs index 4fc33175ca0ea..ca8cd5e0b2344 100644 --- a/src/query/service/src/table_functions/srf/range.rs +++ b/src/query/service/src/table_functions/srf/range.rs @@ -144,7 +144,7 @@ impl Table for RangeTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { // dummy statistics Ok((PartStatistics::default_exact(), Partitions::default())) diff --git a/src/query/service/src/table_functions/sync_crash_me.rs b/src/query/service/src/table_functions/sync_crash_me.rs index 0039bd2f2fa8c..6e1a6fb2ca368 100644 --- a/src/query/service/src/table_functions/sync_crash_me.rs +++ b/src/query/service/src/table_functions/sync_crash_me.rs @@ -111,7 +111,7 @@ impl Table for SyncCrashMeTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { // dummy statistics Ok((PartStatistics::new_exact(1, 1, 1, 1), Partitions::default())) diff --git a/src/query/storages/fuse/src/fuse_table.rs b/src/query/storages/fuse/src/fuse_table.rs index 059fe0c3d5675..519aeda72dc81 100644 --- a/src/query/storages/fuse/src/fuse_table.rs +++ b/src/query/storages/fuse/src/fuse_table.rs @@ -489,9 +489,9 @@ impl Table for FuseTable { &self, ctx: Arc, push_downs: Option, - dyn_run: bool, + dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { - self.do_read_partitions(ctx, push_downs, dyn_run).await + self.do_read_partitions(ctx, push_downs, dry_run).await } #[tracing::instrument(level = "debug", name = "fuse_table_read_data", skip(self, ctx, pipeline), fields(ctx.id = ctx.get_id().as_str()))] diff --git a/src/query/storages/fuse/src/table_functions/clustering_information/clustering_information_table.rs b/src/query/storages/fuse/src/table_functions/clustering_information/clustering_information_table.rs index ea0eb185f5542..a120fad388e83 100644 --- a/src/query/storages/fuse/src/table_functions/clustering_information/clustering_information_table.rs +++ b/src/query/storages/fuse/src/table_functions/clustering_information/clustering_information_table.rs @@ -98,7 +98,7 @@ impl Table for ClusteringInformationTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/fuse/src/table_functions/fuse_blocks/fuse_block_table.rs b/src/query/storages/fuse/src/table_functions/fuse_blocks/fuse_block_table.rs index fc80c9ab3f0cf..cef963311d37e 100644 --- a/src/query/storages/fuse/src/table_functions/fuse_blocks/fuse_block_table.rs +++ b/src/query/storages/fuse/src/table_functions/fuse_blocks/fuse_block_table.rs @@ -97,7 +97,7 @@ impl Table for FuseBlockTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/fuse/src/table_functions/fuse_segments/fuse_segment_table.rs b/src/query/storages/fuse/src/table_functions/fuse_segments/fuse_segment_table.rs index 73e20a3b5a2f4..086aa28b8ebd9 100644 --- a/src/query/storages/fuse/src/table_functions/fuse_segments/fuse_segment_table.rs +++ b/src/query/storages/fuse/src/table_functions/fuse_segments/fuse_segment_table.rs @@ -97,7 +97,7 @@ impl Table for FuseSegmentTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/fuse/src/table_functions/fuse_snapshots/fuse_snapshot_table.rs b/src/query/storages/fuse/src/table_functions/fuse_snapshots/fuse_snapshot_table.rs index a186fe91ab52e..f227dadf4ff05 100644 --- a/src/query/storages/fuse/src/table_functions/fuse_snapshots/fuse_snapshot_table.rs +++ b/src/query/storages/fuse/src/table_functions/fuse_snapshots/fuse_snapshot_table.rs @@ -94,7 +94,7 @@ impl Table for FuseSnapshotTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/fuse/src/table_functions/fuse_statistics/fuse_statistic_table.rs b/src/query/storages/fuse/src/table_functions/fuse_statistics/fuse_statistic_table.rs index fdd073c900e49..07cc49017eaab 100644 --- a/src/query/storages/fuse/src/table_functions/fuse_statistics/fuse_statistic_table.rs +++ b/src/query/storages/fuse/src/table_functions/fuse_statistics/fuse_statistic_table.rs @@ -94,7 +94,7 @@ impl Table for FuseStatisticTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/hive/hive/src/hive_table.rs b/src/query/storages/hive/hive/src/hive_table.rs index 76d365b3afe7e..639f08c516a55 100644 --- a/src/query/storages/hive/hive/src/hive_table.rs +++ b/src/query/storages/hive/hive/src/hive_table.rs @@ -573,7 +573,7 @@ impl Table for HiveTable { &self, ctx: Arc, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { self.do_read_partitions(ctx, push_downs).await } diff --git a/src/query/storages/iceberg/src/table.rs b/src/query/storages/iceberg/src/table.rs index 7dcce2510d989..9436e5f048a0a 100644 --- a/src/query/storages/iceberg/src/table.rs +++ b/src/query/storages/iceberg/src/table.rs @@ -174,7 +174,7 @@ impl Table for IcebergTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { todo!() } diff --git a/src/query/storages/memory/src/memory_table.rs b/src/query/storages/memory/src/memory_table.rs index d3b074be6b82b..847290447340c 100644 --- a/src/query/storages/memory/src/memory_table.rs +++ b/src/query/storages/memory/src/memory_table.rs @@ -162,7 +162,7 @@ impl Table for MemoryTable { &self, ctx: Arc, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { let blocks = self.blocks.read(); diff --git a/src/query/storages/null/src/null_table.rs b/src/query/storages/null/src/null_table.rs index 8cf7c0b452a31..d3c6e72398fe3 100644 --- a/src/query/storages/null/src/null_table.rs +++ b/src/query/storages/null/src/null_table.rs @@ -67,7 +67,7 @@ impl Table for NullTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/parquet/src/parquet_table/table.rs b/src/query/storages/parquet/src/parquet_table/table.rs index 9fc03a47ce170..1dd1d267dd0f6 100644 --- a/src/query/storages/parquet/src/parquet_table/table.rs +++ b/src/query/storages/parquet/src/parquet_table/table.rs @@ -114,7 +114,7 @@ impl Table for ParquetTable { &self, ctx: Arc, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { self.do_read_partitions(ctx, push_downs).await } diff --git a/src/query/storages/random/src/random_table.rs b/src/query/storages/random/src/random_table.rs index 100941c9ce329..9480ea2625b9f 100644 --- a/src/query/storages/random/src/random_table.rs +++ b/src/query/storages/random/src/random_table.rs @@ -95,7 +95,7 @@ impl Table for RandomTable { &self, ctx: Arc, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { let settings = ctx.get_settings(); let block_size = settings.get_max_block_size()? as usize; diff --git a/src/query/storages/result_cache/src/table_function/table.rs b/src/query/storages/result_cache/src/table_function/table.rs index 07717f59c2c37..bcfd10aa1f0c7 100644 --- a/src/query/storages/result_cache/src/table_function/table.rs +++ b/src/query/storages/result_cache/src/table_function/table.rs @@ -109,7 +109,7 @@ impl Table for ResultScan { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/stage/src/stage_table.rs b/src/query/storages/stage/src/stage_table.rs index e955bfcae25cd..336f05aa2e8f3 100644 --- a/src/query/storages/stage/src/stage_table.rs +++ b/src/query/storages/stage/src/stage_table.rs @@ -110,7 +110,7 @@ impl Table for StageTable { &self, ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { let stage_info = &self.table_info; // User set the files. diff --git a/src/query/storages/system/src/log_queue.rs b/src/query/storages/system/src/log_queue.rs index 0cfa1102fb133..924d7ad8dad2e 100644 --- a/src/query/storages/system/src/log_queue.rs +++ b/src/query/storages/system/src/log_queue.rs @@ -160,7 +160,7 @@ impl Table for SystemLogTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) } diff --git a/src/query/storages/system/src/table.rs b/src/query/storages/system/src/table.rs index 531ff07d29e95..f3838b88ae764 100644 --- a/src/query/storages/system/src/table.rs +++ b/src/query/storages/system/src/table.rs @@ -109,7 +109,7 @@ impl Table for SyncOneBlockSystemTable, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { self.inner_table.get_partitions(ctx, push_downs) } @@ -231,7 +231,7 @@ impl Table for AsyncOneBlockSystemTable, push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { self.inner_table.get_partitions(ctx, push_downs).await } diff --git a/src/query/storages/system/src/tracing_table.rs b/src/query/storages/system/src/tracing_table.rs index f6dc4591e8a3b..9644fb35ff53f 100644 --- a/src/query/storages/system/src/tracing_table.rs +++ b/src/query/storages/system/src/tracing_table.rs @@ -108,7 +108,7 @@ impl Table for TracingTable { &self, _ctx: Arc, _push_downs: Option, - _dyn_run: bool, + _dry_run: bool, ) -> Result<(PartStatistics, Partitions)> { Ok((PartStatistics::default(), Partitions::default())) }