fix(df-repr): enable subquery rules (#223)

Signed-off-by: Alex Chi <[email protected]>

Author: skyzh

optd-datafusion-repr/src/lib.rs

@@ -83,11 +83,11 @@ impl DatafusionOptimizer {
             Arc::new(rules::EliminateLimitRule::new()),
             Arc::new(rules::EliminateDuplicatedSortExprRule::new()),
             Arc::new(rules::EliminateDuplicatedAggExprRule::new()),
-            // Arc::new(rules::DepJoinEliminate::new()),
-            // Arc::new(rules::DepInitialDistinct::new()),
-            // Arc::new(rules::DepJoinPastProj::new()),
-            // Arc::new(rules::DepJoinPastFilter::new()),
-            // Arc::new(rules::DepJoinPastAgg::new()),
+            Arc::new(rules::DepJoinEliminate::new()),
+            Arc::new(rules::DepInitialDistinct::new()),
+            Arc::new(rules::DepJoinPastProj::new()),
+            Arc::new(rules::DepJoinPastFilter::new()),
+            Arc::new(rules::DepJoinPastAgg::new()),
             Arc::new(rules::ProjectMergeRule::new()),
             Arc::new(rules::FilterMergeRule::new()),
         ]

optd-datafusion-repr/src/rules.rs

@@ -6,7 +6,7 @@ mod joins;
 mod macros;
 mod physical;
 mod project_transpose;
-// mod subquery;
+mod subquery;
 
 pub use eliminate_duplicated_expr::*;
 pub use eliminate_limit::*;
@@ -15,6 +15,6 @@ pub use filter_pushdown::*;
 pub use joins::*;
 pub use physical::PhysicalConversionRule;
 pub use project_transpose::*;
-// pub use subquery::{
-//     DepInitialDistinct, DepJoinEliminate, DepJoinPastAgg, DepJoinPastFilter, DepJoinPastProj,
-// };
+pub use subquery::{
+    DepInitialDistinct, DepJoinEliminate, DepJoinPastAgg, DepJoinPastFilter, DepJoinPastProj,
+};