This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0ec0351658 add delayed dispatcher group
new a1006dc39d add statistics
new 71916f6391 Merge branch 'native_raft' of github.com:apache/iotdb into
native_raft
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../common/request/ByteBufferConsensusRequest.java | 5 +
.../iotdb/consensus/natraft/RaftConsensus.java | 31 ++++
.../consensus/natraft/protocol/RaftConfig.java | 55 +++++++
.../consensus/natraft/protocol/RaftMember.java | 83 +++++++---
.../protocol/heartbeat/HeartbeatThread.java | 4 +
.../log/appender/SlidingWindowLogAppender.java | 6 +-
.../log/dispatch/AppendNodeEntryHandler.java | 3 +
.../protocol/log/dispatch/LogDispatcher.java | 2 +-
.../log/dispatch/flowcontrol/FlowBalancer.java | 69 ++++++--
.../log/dispatch/flowcontrol/FlowMonitor.java | 86 ++++++----
.../dispatch/flowcontrol/FlowMonitorManager.java | 28 +++-
.../log/dispatch/flowcontrol/FlowWindow.java | 18 +--
.../protocol/log/manager/RaftLogManager.java | 3 +
.../serialization/SyncLogDequeSerializer.java | 1 +
.../iotdb/consensus/natraft/utils/NodeReport.java | 176 +++++++++++++++++++++
.../iotdb/consensus/natraft/utils/Timer.java | 23 ++-
.../distribute-ecs.sh | 27 ++--
.../plan/planner/plan/node/write/InsertNode.java | 10 ++
.../planner/plan/node/write/InsertTabletNode.java | 43 +++++
.../java/org/apache/iotdb/session/Session.java | 5 +-
20 files changed, 572 insertions(+), 106 deletions(-)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/flowcontrol/FlowWindow.java
(75%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/natraft/utils/NodeReport.java
copy mlnode/resources/conf/logging_config.ini =>
distribution/distribute-ecs.sh (66%)
