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 01c2bee separate network layer and raft transaction layer
add 65176e2 support initialize partition table
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/cluster/config/ClusterConfig.java | 6 +
...tException.java => NoHeaderVNodeException.java} | 8 +-
.../NotInSameGroupException.java} | 24 +--
.../apache/iotdb/cluster/log/MemoryLogManager.java | 11 -
.../applier/DataLogApplier.java} | 10 +-
.../iotdb/cluster/log/applier/MetaLogApplier.java | 38 ++++
.../cluster/partition/HashRingPartitionTable.java | 111 +++++++---
.../iotdb/cluster/partition/PartitionGroup.java | 45 ++--
.../iotdb/cluster/partition/PartitionTable.java | 15 +-
.../iotdb/cluster/server/DataClusterServer.java | 130 +++++++++++
.../iotdb/cluster/server/MetaClusterServer.java | 41 +++-
.../apache/iotdb/cluster/server/RaftServer.java | 21 +-
.../{partition/VNode.java => server/Response.java} | 32 ++-
.../server/handlers/caller/AppendEntryHandler.java | 8 +-
.../server/handlers/caller/CatchUpHandler.java | 5 +-
.../server/handlers/caller/ElectionHandler.java | 2 +-
.../server/handlers/caller/HeartBeatHandler.java | 2 +-
.../server/handlers/caller/JoinClusterHandler.java | 12 +-
.../cluster/server/heartbeat/HeartBeatThread.java | 3 -
.../server/heartbeat/MetaHeartBeatThread.java | 3 +-
.../cluster/server/member/DataGroupMember.java | 138 ++++++++++++
.../cluster/server/member/MetaGroupMember.java | 237 ++++++++++++++++-----
.../iotdb/cluster/server/member/RaftMember.java | 82 +++----
service-rpc/src/main/thrift/cluster.thrift | 45 +++-
24 files changed, 770 insertions(+), 259 deletions(-)
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/{RequestTimeOutException.java
=> NoHeaderVNodeException.java} (81%)
copy cluster/src/main/java/org/apache/iotdb/cluster/{partition/VNode.java =>
exception/NotInSameGroupException.java} (66%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{exception/RequestTimeOutException.java
=> log/applier/DataLogApplier.java} (78%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/applier/MetaLogApplier.java
rename cluster/src/main/java/org/apache/iotdb/cluster/{partition/VNode.java =>
server/Response.java} (56%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
