Skip to content

Commit c3864e3

Browse files
author
Cheng-Yuan-Lai
committed
fix: redacting data source string
1 parent a0e6d69 commit c3864e3

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

datafusion/core/tests/physical_optimizer/enforce_sorting.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
// specific language governing permissions and limitations
1616
// under the License.
1717

18-
use insta::assert_snapshot;
1918
use std::sync::Arc;
2019

2120
use crate::physical_optimizer::test_utils::{

datafusion/core/tests/sql/explain_analyze.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ async fn explain_analyze_baseline_metrics() {
6666
.join("\n");
6767
insta::with_settings!({filters => vec![
6868
(r"\d+\.?\d*[µmn]?s", "[TIME]"),
69+
(r"\[\[[^\]]*?/(testing/data/csv/[^/]+\.csv)\]\]", "[[$1]]"),
6970
]}, {
7071
insta::assert_snapshot!(actual,@r#"
7172
plan
@@ -83,7 +84,7 @@ async fn explain_analyze_baseline_metrics() {
8384
CoalesceBatchesExec: target_batch_size=4096, metrics=[output_rows=99, elapsed_compute=[TIME]]
8485
FilterExec: c13@1 != C2GT5KVyOPZpgKVl110TyZO0NcJ434, projection=[c1@0], metrics=[output_rows=99, elapsed_compute=[TIME]]
8586
RepartitionExec: partitioning=RoundRobinBatch(3), input_partitions=1, metrics=[fetch_time=[TIME], repartition_time=[TIME], send_time=[TIME]]
86-
DataSourceExec: file_groups={1 group: [[home/ian/open_source/datafusion/testing/data/csv/aggregate_test_100.csv]]}, projection=[c1, c13], file_type=csv, has_header=true, metrics=[output_rows=100, elapsed_compute=[TIME], file_open_errors=0, file_scan_errors=0, time_elapsed_opening=[TIME], time_elapsed_processing=[TIME], time_elapsed_scanning_total=[TIME], time_elapsed_scanning_until_data=[TIME]]
87+
DataSourceExec: file_groups={1 group: [[testing/data/csv/aggregate_test_100.csv]]}, projection=[c1, c13], file_type=csv, has_header=true, metrics=[output_rows=100, elapsed_compute=[TIME], file_open_errors=0, file_scan_errors=0, time_elapsed_opening=[TIME], time_elapsed_processing=[TIME], time_elapsed_scanning_total=[TIME], time_elapsed_scanning_until_data=[TIME]]
8788
ProjectionExec: expr=[1 as cnt], metrics=[output_rows=1, elapsed_compute=[TIME]]
8889
PlaceholderRowExec, metrics=[]
8990
ProjectionExec: expr=[lead(b.c1,Int64(1)) ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING@1 as cnt], metrics=[output_rows=1, elapsed_compute=[TIME]]

0 commit comments

Comments
 (0)