chore: clean up code for legacy frontend (#3181)

risingwavelabs · Jun 13, 2022 · 27d1717 · 27d1717
1 parent bdac332
commit 27d1717
Showing 1 changed file with 2 additions and 11 deletions.
diff --git a/src/stream/src/from_proto/batch_query.rs b/src/stream/src/from_proto/batch_query.rs
@@ -59,17 +59,8 @@ impl ExecutorBuilder for BatchQueryExecutorBuilder {
             .collect_vec();
 
         let parallel_unit_id = node.get_parallel_unit_id() as u32;
-        let hash_filter = if let Some(mapping) = &node.hash_mapping {
-            generate_hash_filter(mapping, parallel_unit_id)
-        } else {
-            // TODO: remove this branch once we deprecate Java frontend.
-            // manually build bitmap with full of ones
-            let mut hash_filter_builder = BitmapBuilder::with_capacity(VIRTUAL_NODE_COUNT);
-            for _ in 0..VIRTUAL_NODE_COUNT {
-                hash_filter_builder.append(true);
-            }
-            hash_filter_builder.finish()
-        };
+        let mapping = node.hash_mapping.as_ref().unwrap();
+        let hash_filter = generate_hash_filter(mapping, parallel_unit_id);
 
         let schema = table.schema().clone();
         let executor = BatchQueryExecutor::new(