Struct QueryMerger 

pub struct QueryMerger { /* private fields */ }

A PartitionMerger that executes a SQL query to merge partitions.

Implementations

impl QueryMerger

pub fn new( view_factory: Arc<ViewFactory>, session_configurator: Arc<dyn SessionConfigurator>, file_schema: Arc<Schema>, query: Arc<String>, ) -> QueryMerger

pub fn with_merge_scan_ordering(self, ordering: ScanOrdering) -> QueryMerger

Declares an ordering the merge’s source scan already satisfies (see PartitionedTableProvider::with_scan_ordering), letting DataFusion elide the merge query’s Sort node instead of buffering. Default: Unordered (matching today’s behavior for every existing caller).

Trait Implementations

impl Debug for QueryMerger

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl PartitionMerger for QueryMerger

fn execute_merge_query<'life0, 'async_trait>( &'life0 self, lakehouse: Arc<LakehouseContext>, partitions_to_merge: Arc<Vec<Partition>>, partitions_all_views: Arc<PartitionCache>, insert_range: TimeRange, ) -> Pin<Box<dyn Future<Output = Result<MergeQueryResult, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, QueryMerger: 'async_trait,

Executes the merge query.