This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 14b09db Merge branch 'cluster_premerge' into cluster_new
add a44b62f add plan index and flush/close listeners
add 462c9c5 add min plan index and register interface.
add 0f0119d Merge branch 'master' into add_plan_index
add 30466d5 Merge branch 'add_plan_index' into cluster_new
add 1697fc0 use plan index in FileSnapshot
add f05755b remove historical version
add 33e0cb1 fix SeriesReaderTest
add 7a891d8 fix test and delete
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/cluster/RemoteTsFileResource.java | 35 ++--
.../manage/FilePartitionedSnapshotLogManager.java | 25 ++-
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 60 ++++---
.../iotdb/cluster/query/ClusterPlanExecutor.java | 6 +-
.../iotdb/cluster/server/member/RaftMember.java | 1 +
.../org/apache/iotdb/cluster/common/TestUtils.java | 3 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 12 +-
.../log/snapshot/PartitionedSnapshotTest.java | 2 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 2 +-
.../cluster/server/member/DataGroupMemberTest.java | 12 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 61 +++++--
.../iotdb/db/engine/flush/CloseFileListener.java | 9 +-
.../iotdb/db/engine/flush/FlushListener.java | 28 ++--
.../iotdb/db/engine/flush/MemTableFlushTask.java | 2 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 23 +++
.../apache/iotdb/db/engine/memtable/IMemTable.java | 4 +
.../iotdb/db/engine/merge/task/MergeFileTask.java | 18 +--
.../engine/storagegroup/StorageGroupProcessor.java | 176 ++++++++++-----------
.../db/engine/storagegroup/TsFileProcessor.java | 70 +++++---
.../db/engine/storagegroup/TsFileResource.java | 105 +++++++-----
.../tsfilemanagement/utils/HotCompactionUtils.java | 5 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 3 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 14 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 9 ++
.../iotdb/db/qp/physical/crud/DeletePlan.java | 6 +
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 6 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 5 +
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 6 +
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 6 +
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 4 +
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 4 +
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 6 +
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 6 +
.../db/qp/physical/sys/LoadConfigurationPlan.java | 3 +
.../db/qp/physical/sys/SetStorageGroupPlan.java | 4 +
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 6 +
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 4 +
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 -
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +
.../WALFlushListener.java} | 35 ++--
.../writelog/recover/TsFileRecoverPerformer.java | 11 +-
.../iotdb/db/engine/merge/MergeOverLapTest.java | 9 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 9 +-
.../engine/modification/DeletionFileNodeTest.java | 28 ++--
.../db/engine/modification/DeletionQueryTest.java | 52 +++---
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
.../query/reader/series/SeriesReaderTestUtil.java | 11 +-
.../db/sync/receiver/load/FileLoaderTest.java | 5 +
tsfile/format-changelist.md | 5 +
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 47 ++++--
.../iotdb/tsfile/read/TsFileSequenceReader.java | 12 ++
.../write/writer/RestorableTsFileIOWriter.java | 15 ++
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 21 ++-
54 files changed, 650 insertions(+), 369 deletions(-)
copy
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java
=>
server/src/main/java/org/apache/iotdb/db/engine/flush/CloseFileListener.java
(74%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/IPageReader.java
=> server/src/main/java/org/apache/iotdb/db/engine/flush/FlushListener.java
(61%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/flush/NotifyFlushMemTable.java
=> writelog/WALFlushListener.java} (53%)
