yiguolei commented on code in PR #38403:
URL: https://github.com/apache/doris/pull/38403#discussion_r1696428144
##########
be/src/exec/schema_scanner.h:
##########
@@ -101,8 +106,23 @@ class SchemaScanner {
// factory function
static std::unique_ptr<SchemaScanner> create(TSchemaTableType::type type);
TSchemaTableType::type type() const { return _schema_table_type; }
+ void set_dependency(std::shared_ptr<pipeline::Dependency> dep,
+ std::shared_ptr<pipeline::Dependency> fin_dep) {
+ _dependency = dep;
+ _finish_dependency = fin_dep;
+ }
+
+ void init_block(vectorized::Block* src_block);
protected:
Review Comment:
schema scanner
FeBasedSchemaScanner
vector<Block> _block;
bool has_started = false
dependency dep;
get_block_async() {
thread_pool.submit() {
if (!has_started) {
start();
}
get_block_internal();
queue.push_block();
}
}
get_block(Block* block) {
block = _block;
}
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
