Skip to content

Commit 94d7f2e

Browse files
[refactor](segment iterator) rename _non_predicate_column_ids to _common_expr_column_ids (#56931)
1 parent 33db05e commit 94d7f2e

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

be/src/olap/rowset/segment_v2/segment_iterator.cpp

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1817,7 +1817,7 @@ Status SegmentIterator::_vec_init_lazy_materialization() {
18171817
_lazy_materialization_read = true;
18181818
}
18191819
if (_is_common_expr_column[cid]) {
1820-
_non_predicate_column_ids.push_back(cid);
1820+
_common_expr_column_ids.push_back(cid);
18211821
} else {
18221822
_non_predicate_columns.push_back(cid);
18231823
}
@@ -1846,7 +1846,7 @@ Status SegmentIterator::_vec_init_lazy_materialization() {
18461846
_short_cir_pred_column_ids.end());
18471847
pred_id_set.insert(_vec_pred_column_ids.begin(), _vec_pred_column_ids.end());
18481848

1849-
DCHECK(_non_predicate_column_ids.empty());
1849+
DCHECK(_common_expr_column_ids.empty());
18501850
// _non_predicate_column_ids must be empty. Otherwise _lazy_materialization_read must not false.
18511851
for (int i = 0; i < _schema->num_column_ids(); i++) {
18521852
auto cid = _schema->column_id(i);
@@ -1881,7 +1881,7 @@ Status SegmentIterator::_vec_init_lazy_materialization() {
18811881
"_schema_block_id_map: [{}]",
18821882
_lazy_materialization_read, _col_predicates.size(),
18831883
fmt::join(_predicate_column_ids, ","), fmt::join(_non_predicate_columns, ","),
1884-
fmt::join(_non_predicate_column_ids, ","), fmt::join(_columns_to_filter, ","),
1884+
fmt::join(_common_expr_column_ids, ","), fmt::join(_columns_to_filter, ","),
18851885
fmt::join(_schema_block_id_map, ","));
18861886
return Status::OK();
18871887
}
@@ -2542,13 +2542,13 @@ Status SegmentIterator::_next_batch_internal(vectorized::Block* block) {
25422542
// step 3.2: read remaining expr column and evaluate it.
25432543
if (_is_need_expr_eval) {
25442544
// The predicate column contains the remaining expr column, no need second read.
2545-
if (_non_predicate_column_ids.size() > 0) {
2545+
if (_common_expr_column_ids.size() > 0) {
25462546
SCOPED_RAW_TIMER(&_opts.stats->non_predicate_read_ns);
25472547
RETURN_IF_ERROR(_read_columns_by_rowids(
2548-
_non_predicate_column_ids, _block_rowids, _sel_rowid_idx.data(),
2548+
_common_expr_column_ids, _block_rowids, _sel_rowid_idx.data(),
25492549
_selected_size, &_current_return_columns));
2550-
_replace_version_col_if_needed(_non_predicate_column_ids, _selected_size);
2551-
RETURN_IF_ERROR(_process_columns(_non_predicate_column_ids, block));
2550+
_replace_version_col_if_needed(_common_expr_column_ids, _selected_size);
2551+
RETURN_IF_ERROR(_process_columns(_common_expr_column_ids, block));
25522552
}
25532553

25542554
DCHECK(block->columns() > _schema_block_id_map[*_common_expr_columns.begin()]);
@@ -2558,7 +2558,7 @@ Status SegmentIterator::_next_batch_internal(vectorized::Block* block) {
25582558
} else {
25592559
_fill_column_nothing();
25602560
if (_is_need_expr_eval) {
2561-
RETURN_IF_ERROR(_process_columns(_non_predicate_column_ids, block));
2561+
RETURN_IF_ERROR(_process_columns(_common_expr_column_ids, block));
25622562
}
25632563
}
25642564
} else if (_is_need_expr_eval) {

be/src/olap/rowset/segment_v2/segment_iterator.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -434,7 +434,7 @@ class SegmentIterator : public RowwiseIterator {
434434
// second, read non-predicate columns
435435
// so we need a field to stand for columns first time to read
436436
std::vector<ColumnId> _predicate_column_ids;
437-
std::vector<ColumnId> _non_predicate_column_ids;
437+
std::vector<ColumnId> _common_expr_column_ids;
438438
// TODO: Should use std::vector<size_t>
439439
std::vector<ColumnId> _columns_to_filter;
440440
std::vector<bool> _converted_column_ids;

0 commit comments

Comments
 (0)