This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/optAlignedPageReader in repository https://gitbox.apache.org/repos/asf/tsfile.git
commit f52ebadb7337ac0d1995d4275079067e768102dc Author: JackieTien97 <[email protected]> AuthorDate: Tue May 14 15:38:02 2024 +0800 Opt AlignedPageReader --- .../java/org/apache/tsfile/read/reader/page/AlignedPageReader.java | 2 +- .../org/apache/tsfile/read/reader/series/PaginationController.java | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AlignedPageReader.java b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AlignedPageReader.java index 383f4195..b1ff14e3 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AlignedPageReader.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/page/AlignedPageReader.java @@ -422,7 +422,7 @@ public class AlignedPageReader implements IPageReader { @Override public void initTsBlockBuilder(List<TSDataType> dataTypes) { - if (paginationController.hasCurLimit()) { + if (paginationController.hasLimit()) { builder = new TsBlockBuilder( (int) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/series/PaginationController.java b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/series/PaginationController.java index 5fe4137e..cbd72a86 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/series/PaginationController.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/series/PaginationController.java @@ -80,6 +80,10 @@ public class PaginationController { } } + public boolean hasLimit() { + return hasLimit && curLimit > 0; + } + public TsBlock applyTsBlock(TsBlock resultTsBlock) { int fromIndex = 0; int length = resultTsBlock.getPositionCount();
