This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch negative_timestamp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2238fd3b327 fix compile error
add 804156cb557 rename getTimePartition to getTimePartitionSlot
add 450e16f4d11 add UT
add a4d2b2b8ab4 add more UT
add eb43b4909a7 Pipe: Report queue size in PipeHeartbeatEvent (#10997)
add eee581e1c1f Perfect plan graph for last query scan node
add 7d9ac670327 [IOTDB-6130] Delete data by specific pattern didn't work
add 1a3568ff2a0 Pipe: Improve performance for 10000+ pipes (#11021)
add 43aa7db32f3 Added file overlap analysis tool (#11030)
add 815c21b3fb8 Fixed wal triggering disk threshold loop too many times
(#11017)
add 4be0aaaafdd [RatisConsensus] use warn_and_return to enable cluster
restart when log corruption can be ignored (#11036)
add eb500c9db70 Fix mods file contains writable view
add 746331cb165 Merge branch 'master' of github.com:apache/iotdb into
negative_timestamp
add 40cd37309a9 add more UT
add da81f6d6460 add parseLongToDate test
add 008455e5426 Add IT
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 23 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 45 ++++
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 67 ++++++
.../manager/partition/PartitionManager.java | 2 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 2 +
...idate-tsfile.bat => overlap-statistic-tool.bat} | 4 +-
...alidate-tsfile.sh => overlap-statistic-tool.sh} | 4 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 9 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 89 +++++++-
.../PipeHistoricalDataRegionTsFileExtractor.java | 36 ++-
.../PipeRealtimeDataRegionHybridExtractor.java | 10 +-
.../PipeRealtimeDataRegionLogExtractor.java | 10 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 10 +-
.../realtime/assigner/DisruptorQueue.java | 6 +
.../resource/tsfile/PipeTsFileResourceManager.java | 7 +-
.../pipe/task/connection/PipeEventCollector.java | 4 +
.../connection/UnboundedBlockingPendingQueue.java | 4 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../execution/load/AlignedChunkData.java | 2 +-
.../execution/load/NonAlignedChunkData.java | 2 +-
.../queryengine/execution/load/TsFileSplitter.java | 18 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 12 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 7 +
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 20 +-
.../plan/node/source/LastQueryScanNode.java | 20 +-
.../planner/plan/node/write/InsertRowNode.java | 4 +-
.../planner/plan/node/write/InsertRowsNode.java | 2 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +-
.../planner/plan/node/write/InsertTabletNode.java | 8 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 3 +-
.../plan/statement/crud/InsertTabletStatement.java | 4 +-
.../ITimeRange.java} | 13 +-
.../ProcessChunkType.java => tool/Interval.java} | 34 ++-
.../compaction/tool/ListTimeRangeImpl.java | 89 ++++++++
.../compaction/tool/OverlapStatistic.java | 91 ++++++++
.../compaction/tool/OverlapStatisticTool.java | 248 +++++++++++++++++++++
.../dataregion/compaction/tool/PrintUtil.java | 209 +++++++++++++++++
.../SequenceFileSubTaskThreadExecutor.java} | 26 ++-
.../compaction/tool/SequenceFileTaskSummary.java} | 54 ++---
.../compaction/tool/SingleSequenceFileTask.java | 104 +++++++++
.../compaction/tool/TimePartitionProcessTask.java | 143 ++++++++++++
.../tool/TimePartitionProcessWorker.java | 58 +++++
.../compaction/tool/TsFileStatisticReader.java | 96 ++++++++
.../compaction/tool/UnseqSpaceStatistics.java | 84 +++++++
.../storageengine/dataregion/wal/WALManager.java | 27 ++-
.../storageengine/dataregion/wal/node/WALNode.java | 8 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 2 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 26 ++-
.../iotdb/db/storageengine/StorageEngineTest.java | 13 ++
.../compaction/tools/ListTimeRangeImplTest.java | 138 ++++++++++++
.../compaction/tools/UnseqSpaceStatisticsTest.java | 63 ++++++
.../apache/iotdb/commons/path/PathPatternTree.java | 10 -
.../iotdb/commons/path/PathPatternTreeTest.java | 2 +-
56 files changed, 1807 insertions(+), 179 deletions(-)
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/RpcUtilsTest.java
copy
iotdb-core/datanode/src/assembly/resources/tools/tsfile/{validate-tsfile.bat =>
overlap-statistic-tool.bat} (89%)
copy
iotdb-core/datanode/src/assembly/resources/tools/tsfile/{validate-tsfile.sh =>
overlap-statistic-tool.sh} (90%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{execute/performer/ICrossCompactionPerformer.java
=> tool/ITimeRange.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{schedule/constant/ProcessChunkType.java
=> tool/Interval.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/ListTimeRangeImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/OverlapStatistic.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/OverlapStatisticTool.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/PrintUtil.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{schedule/constant/ProcessChunkType.java
=> tool/SequenceFileSubTaskThreadExecutor.java} (61%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/DFAState.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/SequenceFileTaskSummary.java}
(51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/SingleSequenceFileTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/TimePartitionProcessTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/TimePartitionProcessWorker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/TsFileStatisticReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/UnseqSpaceStatistics.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tools/ListTimeRangeImplTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tools/UnseqSpaceStatisticsTest.java
