add vectorized vjson_scanner and apply vexpr

apache · May 7, 2022 · e3df45f · e3df45f
1 parent 69529c1
commit e3df45f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/be/src/vec/exec/vjson_scanner.cpp b/be/src/vec/exec/vjson_scanner.cpp
@@ -117,12 +117,12 @@ Status VJsonScanner::get_next(vectorized::Block& output_block, bool* eof) {
 
  // filter src tuple by preceding filter first
  if (!_vpre_filter_ctxs.empty()) {
- auto old_rows = output_block.rows();
  for (auto _vpre_filter_ctx : _vpre_filter_ctxs) {
+ auto old_rows = output_block.rows();
  RETURN_IF_ERROR(
  VExprContext::filter_block(_vpre_filter_ctx, &output_block, slot_num));
+ _counter->num_rows_unselected += old_rows - output_block.rows();
  }
- _counter->num_rows_unselected += old_rows - output_block.rows();
  }
  }
  }