You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by al...@apache.org on 2024/09/01 13:00:31 UTC
(datafusion) branch main updated: Remove FileScanConfig::repartition_file_groups function (#12242)
This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new ff7d76d8fe Remove FileScanConfig::repartition_file_groups function (#12242)
ff7d76d8fe is described below
commit ff7d76d8fe5527101557327cf0047f1ef72ee893
Author: Piotr Findeisen <pi...@gmail.com>
AuthorDate: Sun Sep 1 15:00:27 2024 +0200
Remove FileScanConfig::repartition_file_groups function (#12242)
Deprecated since 33.0.0.
---
.../src/datasource/physical_plan/file_scan_config.rs | 17 +----------------
1 file changed, 1 insertion(+), 16 deletions(-)
diff --git a/datafusion/core/src/datasource/physical_plan/file_scan_config.rs b/datafusion/core/src/datasource/physical_plan/file_scan_config.rs
index 3ea467539a..9f67418569 100644
--- a/datafusion/core/src/datasource/physical_plan/file_scan_config.rs
+++ b/datafusion/core/src/datasource/physical_plan/file_scan_config.rs
@@ -22,9 +22,7 @@ use std::{
borrow::Cow, collections::HashMap, fmt::Debug, marker::PhantomData, sync::Arc, vec,
};
-use super::{
- get_projected_output_ordering, statistics::MinMaxStatistics, FileGroupPartitioner,
-};
+use super::{get_projected_output_ordering, statistics::MinMaxStatistics};
use crate::datasource::{listing::PartitionedFile, object_store::ObjectStoreUrl};
use crate::{error::Result, scalar::ScalarValue};
@@ -296,19 +294,6 @@ impl FileScanConfig {
})
}
- #[allow(missing_docs)]
- #[deprecated(since = "33.0.0", note = "Use SessionContext::new_with_config")]
- pub fn repartition_file_groups(
- file_groups: Vec<Vec<PartitionedFile>>,
- target_partitions: usize,
- repartition_file_min_size: usize,
- ) -> Option<Vec<Vec<PartitionedFile>>> {
- FileGroupPartitioner::new()
- .with_target_partitions(target_partitions)
- .with_repartition_file_min_size(repartition_file_min_size)
- .repartition_file_groups(&file_groups)
- }
-
/// Attempts to do a bin-packing on files into file groups, such that any two files
/// in a file group are ordered and non-overlapping with respect to their statistics.
/// It will produce the smallest number of file groups possible.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org