yiguolei commented on code in PR #28103:
URL: https://github.com/apache/doris/pull/28103#discussion_r1435902632
##########
be/src/vec/exec/scan/new_olap_scan_node.cpp:
##########
@@ -508,48 +503,103 @@ Status
NewOlapScanNode::_init_scanners(std::list<VScannerSPtr>* scanners) {
std::vector<std::pair<BaseTabletSPtr, int64_t /* version */>>
tablets_to_scan;
tablets_to_scan.reserve(_scan_ranges.size());
+ std::vector<TabletWithVersion> tablets;
+
for (auto&& scan_range : _scan_ranges) {
auto tablet = DORIS_TRY(ExecEnv::get_tablet(scan_range->tablet_id));
int64_t version = 0;
std::from_chars(scan_range->version.data(),
scan_range->version.data() +
scan_range->version.size(), version);
+ tablets.emplace_back(
+ TabletWithVersion {std::dynamic_pointer_cast<Tablet>(tablet),
version});
tablets_to_scan.emplace_back(std::move(tablet), version);
}
+ bool is_dup_mow_key = true;
+ bool unique_keys_with_mor = false;
+ bool enable_parallel_scan = _state->enable_parallel_scan();
+
// Split tablet segment by scanner, only use in pipeline in duplicate key
// 1. if tablet count lower than scanner thread num, count segment num of
all tablet ready for scan
// TODO: some tablet may do not have segment, may need split segment all
case
if (_shared_scan_opt && _scan_ranges.size() <
config::doris_scanner_thread_pool_thread_num) {
Review Comment:
我想了想，我们还是不要让他跟shared scan 关联。
他可以作为一个独立的feature，这样测试感觉好测试。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
