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/incubator-iotdb.git.
from 8fda671 Merge pull request #1635 from
neuyilan/apache_cluster_new_0819_async_applier
add 24f4598 shrink PartitionTable interface & add SlotStrategy
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClusterMain.java | 39 +++++++++++++++++
.../iotdb/cluster/log/applier/DataLogApplier.java | 4 +-
.../manage/FilePartitionedSnapshotLogManager.java | 6 +--
.../log/manage/PartitionedSnapshotLogManager.java | 6 +--
.../cluster/partition/NodeAdditionResult.java | 20 +--------
.../iotdb/cluster/partition/NodeRemovalResult.java | 20 ++-------
.../iotdb/cluster/partition/PartitionTable.java | 38 ++--------------
.../cluster/partition/{ => slot}/SlotManager.java | 19 ++------
.../SlotNodeAdditionResult.java} | 18 ++------
.../slot/SlotNodeRemovalResult.java} | 19 +++++---
.../partition/{ => slot}/SlotPartitionTable.java | 51 +++++-----------------
.../iotdb/cluster/partition/slot/SlotStrategy.java | 36 +++++++++++++++
.../iotdb/cluster/query/ClusterPlanExecutor.java | 5 +--
.../iotdb/cluster/query/ClusterPlanRouter.java | 3 +-
.../iotdb/cluster/query/filter/SlotSgFilter.java | 4 +-
.../cluster/query/filter/SlotTsFileFilter.java | 4 +-
.../iotdb/cluster/server/DataClusterServer.java | 9 ++--
.../cluster/server/member/DataGroupMember.java | 29 +++++++-----
.../cluster/server/member/MetaGroupMember.java | 2 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 5 ++-
.../iotdb/cluster/common/TestDataGroupMember.java | 2 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 2 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 4 +-
.../FilePartitionedSnapshotLogManagerTest.java | 4 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 2 +-
.../iotdb/cluster/partition/SlotManagerTest.java | 14 +++---
.../cluster/partition/SlotPartitionTableTest.java | 35 ++++-----------
.../server/heartbeat/MetaHeartbeatThreadTest.java | 40 -----------------
.../cluster/server/member/DataGroupMemberTest.java | 10 +++--
.../iotdb/cluster/server/member/MemberTest.java | 2 +-
31 files changed, 185 insertions(+), 269 deletions(-)
rename cluster/src/main/java/org/apache/iotdb/cluster/partition/{ =>
slot}/SlotManager.java (92%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/partition/{NodeAdditionResult.java
=> slot/SlotNodeAdditionResult.java} (79%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{exception/NotInSameGroupException.java
=> partition/slot/SlotNodeRemovalResult.java} (62%)
rename cluster/src/main/java/org/apache/iotdb/cluster/partition/{ =>
slot}/SlotPartitionTable.java (91%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/partition/slot/SlotStrategy.java
