You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/11/15 06:52:29 UTC
[incubator-iotdb] branch cluster_new updated (01c2bee -> 65176e2)
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