Supports streaming load mem chunk & Push down filter, limit and offset to MemPointIterator#16246
Supports streaming load mem chunk & Push down filter, limit and offset to MemPointIterator#16246JackieTien97 merged 30 commits intomasterfrom
Conversation
Codecov Report❌ Patch coverage is Additional details and impacted files@@ Coverage Diff @@
## master #16246 +/- ##
============================================
- Coverage 38.99% 38.98% -0.01%
Complexity 198 198
============================================
Files 4886 4895 +9
Lines 319614 320997 +1383
Branches 40346 40670 +324
============================================
+ Hits 124620 125140 +520
- Misses 194994 195857 +863 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
There was a problem hiding this comment.
Pull Request Overview
This PR implements streaming memory chunk loading and pushes down filter, limit, and offset operations to MemPointIterator for improved query performance.
Key changes include:
- Addition of streaming query capability for memory chunks to avoid loading excessive data
- Implementation of filter, limit, and offset pushdown to MemPointIterator for more efficient data processing
- Support for both ascending and descending scan orders in memory iteration
Reviewed Changes
Copilot reviewed 24 out of 24 changed files in this pull request and generated 1 comment.
Show a summary per file
| File | Description |
|---|---|
| MemPointIterator.java | Converted to abstract class with streaming support and pushdown capabilities |
| TVList.java | Enhanced iterator with scan order support and filter/pagination pushdown |
| AlignedTVList.java | Added streaming query support and scan order handling for aligned data |
| ReadOnlyMemChunk.java | Added fake statistics generation for streaming queries |
| SeriesScanUtil.java | Integrated lazy memory page readers for streaming chunk processing |
| IoTDBConfig.java | Added configuration for streaming query memory chunks |
Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.
.../src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/SeriesScanUtil.java
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/TVList.java
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/TVList.java
Outdated
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/TVList.java
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/TVList.java
Outdated
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java
Show resolved
Hide resolved
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/AlignedTVList.java
Show resolved
Hide resolved
|




Description
Supports streaming load mem chunk & Push down filter, limit and offset to MemPointIterator