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 f6973615341 add appendCompressedSingleEntryies
add d9091092521 add pipeline compressor
No new revisions were added by this update.
Summary of changes:
.../consensus/natraft/protocol/RaftMember.java | 9 +-
.../protocol/log/dispatch/DispatcherThread.java | 15 +-
.../protocol/log/dispatch/ILogDispatcher.java} | 28 +-
.../protocol/log/dispatch/LogDispatcher.java | 22 +-
.../log/dispatch/QueueBasedDispatcherThread.java | 13 +-
.../log/dispatch/flowcontrol/FlowBalancer.java | 11 +-
.../FlowWindow.java => pipeline/DispatchTask.java} | 22 +-
.../PipelineDispatcherGroup.java} | 82 ++++--
.../pipeline/PipelineDispatcherThread.java | 144 ++++++++++
.../dispatch/pipeline/PipelinedLogDispatcher.java | 301 +++++++++++++++++++++
.../iotdb/consensus/natraft/utils/LogUtils.java | 16 ++
.../concurrent/dynamic/DynamicThreadGroup.java | 9 +-
12 files changed, 576 insertions(+), 96 deletions(-)
copy
consensus/src/main/java/org/apache/iotdb/consensus/{exception/IllegalPeerEndpointException.java
=> natraft/protocol/log/dispatch/ILogDispatcher.java} (67%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/{flowcontrol/FlowWindow.java
=> pipeline/DispatchTask.java} (71%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/{DispatcherGroup.java
=> pipeline/PipelineDispatcherGroup.java} (64%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/pipeline/PipelineDispatcherThread.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/pipeline/PipelinedLogDispatcher.java
