This is an automated email from the ASF dual-hosted git repository.
suxiaogang223 pushed a commit to branch refact_reader_branch
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/refact_reader_branch by this
push:
new aabcbc3b51f [parquet] Clarify reader lifecycle comments
aabcbc3b51f is described below
commit aabcbc3b51ff465646b453e38c81f242aef05077
Author: Socrates <[email protected]>
AuthorDate: Wed May 27 14:38:12 2026 +0800
[parquet] Clarify reader lifecycle comments
---
be/src/format/new_parquet/parquet_reader.h | 4 ++--
be/src/format/reader/file_reader.h | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/be/src/format/new_parquet/parquet_reader.h
b/be/src/format/new_parquet/parquet_reader.h
index 40213ebb0d6..d7a9dc19a59 100644
--- a/be/src/format/new_parquet/parquet_reader.h
+++ b/be/src/format/new_parquet/parquet_reader.h
@@ -54,8 +54,8 @@ public:
// init 成功后可以调用 get_schema() 获取 Parquet file-local schema。
Status init(RuntimeState* state) override;
- // 解析 Parquet footer 并返回 Parquet 文件自身的 schema。
- // 该方法只能在 open() 成功后调用，不要求 init() 已经执行。
+ // 返回 init() 阶段解析出的 Parquet 文件自身 schema。
+ // 该方法只能在 init() 成功后调用，不要求 open() 已经执行。
// 这里不做 Iceberg schema evolution，也不把字段转换成 table/global schema。
Status get_schema(std::vector<reader::SchemaField>* file_schema) const
override;
diff --git a/be/src/format/reader/file_reader.h
b/be/src/format/reader/file_reader.h
index 0b0527535e5..cb2096fd80a 100644
--- a/be/src/format/reader/file_reader.h
+++ b/be/src/format/reader/file_reader.h
@@ -159,7 +159,7 @@ public:
}
// 读取下一批 file-local block。
- // 该方法只能在 init(FileScanRequest) 成功后调用。
+ // 该方法只能在 open(FileScanRequest) 成功后调用。
// file_block 的列顺序和类型必须遵守 FileScanRequest，而不是 table/global schema。
// rows 返回当前批次输出行数；eof 表示当前文件 reader 是否读完；多文件切换由
// TableReader 负责。
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
