This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/PredicatePushDown
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5a3e509e816 tmp ignore
add dff87437e88 Update client-cpp.yml to fix cpp build error on Windows
(#11863)
add e1370838190 set default config item
'enableInsertionCrossSpaceCompaction' to true (#11861)
add 4af1bf8c4a0 Pipe: fix constructor of `PipeTsFileInsertionEvent` &
filter out empty events on sender side (#11862)
add 8e567c5c979 Bump follow-redirects in /iotdb-connector/grafana-plugin
(#11864)
add ccbfd065e13 [IOTDB-6190] Increase the threshold for Ratis to shut
itself down if it detects that a process is stuck (#11865)
add 4c6396afdba Fix delete and recreate the same timeseries with different
datatype bug
add 038277a1882 Fix some errors of writing metric (#11867)
add 01cd2902b6d Fix duplicated create logical view in PBTree mode (#11869)
add 3865a81fdaa Make timeout error msg (#11868)
add 76599aee279 Fix insertRecords may cause sequence data overlapped
(#11872)
add 6a478f67012 [IOTDB-6286] Add new query optimize rule: Use TopKNode to
replace SortNode when order by expression + limit N
add 452749143da Fix more writing metric errors (#11873)
add 0fbf857bfb0 Pipe: Improved batch performance by reducing unnecessary
serialization (#11850)
add 97af4d47101 set status of compaction target file to NORMAL after
delete compaction log file (#11551)
add 18173c0b9f1 Fix using too much memory when estimate compaction task
memory (#10619)
add 4031ddf7b8d Fix NPE while right side finished
add 5e8d43f2faa Fix PBTree metric and support async flushAll (#11884)
add 782e97aa75e Fix distributed plan of GroupLevelNode
add e19a94b0867 Merge remote-tracking branch 'origin/master' into
lmh/PredicatePushDown
add ec25fb0293a fix UT
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 6 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 37 +
... => IoTDBAlignedSeriesQueryWithMisMatchIT.java} | 65 +-
.../apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java | 22 +
iotdb-connector/grafana-plugin/yarn.lock | 6 +-
.../manager/consensus/ConsensusManager.java | 4 +
.../apache/iotdb/consensus/config/RatisConfig.java | 23 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 4 +
.../db/consensus/SchemaRegionConsensusImpl.java | 4 +
.../builder/PipeTransferBatchReqBuilder.java | 75 +-
.../request/PipeTransferTabletBatchReq.java | 60 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 16 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 16 +-
.../PipeTransferTabletBatchEventHandler.java | 3 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 15 +-
.../protocol/writeback/WriteBackConnector.java | 18 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 1 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../tablet/TabletInsertionDataContainer.java | 12 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 9 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 4 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 18 +-
.../execution/schedule/DriverScheduler.java | 7 +-
.../db/queryengine/plan/analyze/Analysis.java | 10 +-
.../OrderByExpressionWithLimitChangeToTopK.java | 309 +++++++
.../plan/planner/LogicalPlanBuilder.java | 100 ++-
.../plan/planner/LogicalPlanVisitor.java | 21 +-
.../plan/planner/TemplatedLogicalPlan.java | 22 +-
.../planner/distribution/DistributionPlanner.java | 11 +-
.../planner/distribution/ExchangeNodeAdder.java | 8 +-
.../plan/planner/distribution/SourceRewriter.java | 12 +-
.../plan/planner/plan/node/process/FillNode.java | 5 +
.../plan/planner/plan/node/process/OffsetNode.java | 5 +
.../plan/planner/plan/node/process/SortNode.java | 5 +
.../plan/planner/plan/node/process/TopKNode.java | 6 +-
.../scheduler/FixedRateFragInsStateTracker.java | 8 +-
.../plan/statement/crud/QueryStatement.java | 2 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 2 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 110 ++-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 3 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 7 +-
.../schemafile/pagemgr/BTreePageManager.java | 10 +-
.../pbtree/schemafile/pagemgr/IPageManager.java | 3 +
.../pbtree/schemafile/pagemgr/PageManager.java | 16 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 33 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 50 +-
.../execute/task/CrossSpaceCompactionTask.java | 6 +-
.../execute/task/InnerSpaceCompactionTask.java | 5 +-
.../estimator/CompactionEstimateUtils.java | 43 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../connector/PipeDataNodeThriftRequestTest.java | 69 ++
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 60 +-
.../join/LeftOuterTimeJoinOperatorTest.java | 290 +++++-
.../distribution/AggregationDistributionTest.java | 33 +-
.../AlignByDeviceOrderByLimitOffsetTest.java | 987 ++++++++++++++++++---
.../AlignByTimeOrderByLimitOffsetTest.java | 316 +++++++
.../planner/distribution/AlignedByDeviceTest.java | 408 ++++-----
.../storageengine/dataregion/DataRegionTest.java | 38 +
.../resources/conf/iotdb-common.properties | 2 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 5 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 26 +-
65 files changed, 2686 insertions(+), 802 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAlignedSeriesQueryWithDeletionIT.java
=> IoTDBAlignedSeriesQueryWithMisMatchIT.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/OrderByExpressionWithLimitChangeToTopK.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AlignByTimeOrderByLimitOffsetTest.java
