This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/meituan in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 811ba441051fa68af226eaad3bc02a79179141b0 Author: JackieTien97 <[email protected]> AuthorDate: Mon Nov 27 15:15:37 2023 +0800 Use min(limt, page size) as the init capacity of result block --- .../iotdb/tsfile/read/reader/page/AlignedPageReader.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/AlignedPageReader.java b/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/AlignedPageReader.java index 67058a9661f..f5d56777dea 100644 --- a/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/AlignedPageReader.java +++ b/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/AlignedPageReader.java @@ -420,6 +420,16 @@ public class AlignedPageReader implements IPageReader, IAlignedPageReader { @Override public void initTsBlockBuilder(List<TSDataType> dataTypes) { - builder = new TsBlockBuilder((int) timePageReader.getStatistics().getCount(), dataTypes); + if (paginationController.hasCurLimit()) { + builder = + new TsBlockBuilder( + (int) + Math.min( + paginationController.getCurLimit(), + timePageReader.getStatistics().getCount()), + dataTypes); + } else { + builder = new TsBlockBuilder((int) timePageReader.getStatistics().getCount(), dataTypes); + } } }
