make lint

Author: SkyFan2002

src/query/service/src/pipelines/builders/mod.rs

@@ -16,6 +16,7 @@ mod builder_add_stream_column;
 mod builder_aggregate;
 mod builder_append_table;
 mod builder_async_function;
+mod builder_broadcast;
 mod builder_column_mutation;
 mod builder_commit;
 mod builder_compact;
@@ -40,7 +41,6 @@ mod builder_recluster;
 mod builder_recursive_cte;
 mod builder_replace_into;
 mod builder_row_fetch;
-mod builder_broadcast;
 mod builder_scalar;
 mod builder_scan;
 mod builder_sort;

src/query/service/src/pipelines/processors/transforms/mod.rs

@@ -13,6 +13,7 @@
 // limitations under the License.
 
 pub mod aggregator;
+#[allow(dead_code)]
 mod broadcast;
 mod hash_join;
 pub(crate) mod range_join;

src/query/service/tests/it/pipelines/builders/runtime_filter.rs

@@ -100,7 +100,6 @@ async fn join_build_state(
         &join.build_projections,
         join_state.clone(),
         1,
-        None,
     )?;
     Ok(build_state)
 }

src/query/service/tests/it/sql/exec/get_table_bind_test.rs

@@ -1037,6 +1037,10 @@ impl TableContext for CtxDelegation {
     async fn get_warehouse_cluster(&self) -> Result<Arc<Cluster>> {
         todo!()
     }
+
+    fn get_next_broadcast_id(&self) -> u32 {
+        self.ctx.get_next_broadcast_id()
+    }
 }
 
 #[tokio::test(flavor = "multi_thread")]

src/query/service/tests/it/storages/fuse/operations/commit.rs

@@ -396,6 +396,10 @@ impl TableContext for CtxDelegation {
         todo!()
     }
 
+    fn get_next_broadcast_id(&self) -> u32 {
+        self.ctx.get_next_broadcast_id()
+    }
+
     fn txn_mgr(&self) -> TxnManagerRef {
         self.ctx.txn_mgr()
     }