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/25 09:38:35 UTC
[incubator-iotdb] branch cluster_new updated (59f8529 -> 76d9bcd)
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 59f8529 add catch up with snapshot
add 76d9bcd add data transfer framework
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/cluster/log/LogManager.java | 4 +
.../iotdb/cluster/log/PartitionedSnapshot.java | 1 -
.../iotdb/cluster/log/RemoteSimpleSnapshot.java | 62 +++++++++
.../apache/iotdb/cluster/log/SimpleSnapshot.java | 70 ++++++++++
.../org/apache/iotdb/cluster/log/Snapshot.java | 18 +++
.../iotdb/cluster/log/manage/MemoryLogManager.java | 27 +++-
.../log/manage/PartitionedSnapshotLogManager.java | 28 ++--
.../log/manage/SingleSnapshotLogManager.java | 56 +-------
.../iotdb/cluster/partition/PartitionTable.java | 6 +-
.../cluster/partition/SocketPartitionTable.java | 15 ++-
.../iotdb/cluster/server/DataClusterServer.java | 16 ++-
...atchUpHandler.java => PullSnapshotHandler.java} | 41 +++---
...uestHandler.java => ForwardAddNodeHandler.java} | 4 +-
.../forwarder/ForwardPullSnapshotHandler.java} | 27 ++--
.../cluster/server/member/DataGroupMember.java | 144 ++++++++++++++++++++-
.../cluster/server/member/MetaGroupMember.java | 48 +++++--
.../iotdb/cluster/server/member/RaftMember.java | 12 +-
service-rpc/src/main/thrift/cluster.thrift | 2 +-
18 files changed, 447 insertions(+), 134 deletions(-)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/RemoteSimpleSnapshot.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/SimpleSnapshot.java
copy cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{SnapshotCatchUpHandler.java => PullSnapshotHandler.java} (57%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/{ForwardAddNodeRequestHandler.java => ForwardAddNodeHandler.java} (89%)
copy cluster/src/main/java/org/apache/iotdb/cluster/{log/applier/DataLogApplier.java => server/handlers/forwarder/ForwardPullSnapshotHandler.java} (51%)