Skip to content

Commit

Permalink
override supports_rewrite for FederationOptimizerRule and SQLFederati…
Browse files Browse the repository at this point in the history
…onOptimizerRule
  • Loading branch information
hozan23 authored and backkem committed Aug 23, 2024
1 parent d9449e5 commit ac84a50
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 0 deletions.
6 changes: 6 additions & 0 deletions datafusion-federation/src/optimizer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,12 @@ impl OptimizerRule for FederationOptimizerRule {
fn name(&self) -> &str {
"federation_optimizer_rule"
}

/// XXX
/// Does this rule support rewriting owned plans (rather than by reference)?
fn supports_rewrite(&self) -> bool {
false
}
}

enum ScanResult {
Expand Down
6 changes: 6 additions & 0 deletions datafusion-federation/src/sql/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,12 @@ impl OptimizerRule for SQLFederationOptimizerRule {
fn name(&self) -> &str {
"federate_sql"
}

/// XXX
/// Does this rule support rewriting owned plans (rather than by reference)?
fn supports_rewrite(&self) -> bool {
false
}
}
struct SQLFederationPlanner {
executor: Arc<dyn SQLExecutor>,
Expand Down

0 comments on commit ac84a50

Please sign in to comment.