clean

risingwavelabs · Nov 6, 2024 · 79bdbdf · 79bdbdf
1 parent 69958d9
commit 79bdbdf
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/src/connector/src/source/iceberg/mod.rs b/src/connector/src/source/iceberg/mod.rs
@@ -251,7 +251,6 @@ impl IcebergSplitEnumerator {
         let mut position_delete_files = vec![];
         let mut data_files = vec![];
         let mut equality_delete_files = vec![];
-        // TODO(kwannoel): add filter here.
         let scan = table
             .scan()
             .with_filter(predicate)

diff --git a/src/frontend/src/scheduler/plan_fragmenter.rs b/src/frontend/src/scheduler/plan_fragmenter.rs
@@ -270,7 +270,7 @@ impl Query {
 }
 
 #[derive(Debug, Clone)]
-enum SourceFetchParameters {
+pub enum SourceFetchParameters {
     IcebergPredicate(IcebergPredicate),
     KafkaTimebound {
         lower: Option<i64>,