This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch 5.0.0-beta-compact
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 9a9f44566 Fix examine consume stats for none static topic (#4571)
new d19196b3e resolve conflict
new 8a8cd7900 merge beta
new 5c0f64baa bugfix
new 92dcd2afb apache-rat check fix
new e10a534a1 fix service name
new f52972ab0 compaction topic use example
new b82596689 compaction unit test
new be46fb989 conflict
new 8b803ccf9 Merge remote-tracking branch 'origin/5.0.0-beta' into
5.0.0-beta-ctopic
new c1302241c conflict
new fdcb12f80 fix unit test
new 9f9f082de fix unit test
new d1783ea68 optimize offsetMap build
new ca94afc71 Merge pull request #4118 from ltamber/5.0.0-beta-ctopic
The 2169 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:
.gitignore | 1 +
.../broker/processor/SendMessageProcessor.java | 14 +
.../apache/rocketmq/common/TopicAttributes.java | 16 +-
.../rocketmq/common/attribute/DeletePolicy.java | 8 +-
.../rocketmq/common/message/MessageDecoder.java | 5 +-
...{QueueTypeUtils.java => DeletePolicyUtils.java} | 23 +-
docs/cn/Example_Compaction_Topic_cn.md | 47 ++
docs/en/Example_Compaction_Topic.md | 49 ++
.../apache/rocketmq/store/AppendMessageResult.java | 7 +
.../java/org/apache/rocketmq/store/CommitLog.java | 280 +------
...eLock.java => CompactionAppendMsgCallback.java} | 9 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 29 +-
.../apache/rocketmq/store/GetMessageResult.java | 16 +
.../org/apache/rocketmq/store/MappedFileQueue.java | 28 +-
.../apache/rocketmq/store/MessageExtEncoder.java | 299 ++++++++
.../rocketmq/store/MultiPathMappedFileQueue.java | 2 +-
.../rocketmq/store/config/MessageStoreConfig.java | 53 ++
.../rocketmq/store/dledger/DLedgerCommitLog.java | 7 +-
.../store/kv/CommitLogDispatcherCompaction.java | 25 +-
.../apache/rocketmq/store/kv/CompactionLog.java | 834 +++++++++++++++++++++
.../rocketmq/store/kv/CompactionPositionMgr.java | 88 +++
.../rocketmq/store/kv/CompactionService.java | 158 ++++
.../apache/rocketmq/store/kv/CompactionStore.java | 163 ++++
.../rocketmq/store/logfile/DefaultMappedFile.java | 104 +++
.../apache/rocketmq/store/logfile/MappedFile.java | 19 +-
.../rocketmq/store/queue/BatchConsumeQueue.java | 107 +--
.../rocketmq/store/queue/SparseConsumeQueue.java | 333 ++++++++
.../apache/rocketmq/store/AppendCallbackTest.java | 1 -
.../apache/rocketmq/store/MappedFileQueueTest.java | 94 +++
.../rocketmq/store/kv/CompactionLogTest.java | 226 ++++++
.../store/kv/CompactionPositionMgrTest.java | 66 ++
.../apache/rocketmq/store/kv/OffsetMapTest.java | 51 ++
.../store/logfile/DefaultMappedFileTest.java | 64 ++
.../store/queue/SparseConsumeQueueTest.java | 165 ++++
34 files changed, 3025 insertions(+), 366 deletions(-)
copy
test/src/main/java/org/apache/rocketmq/test/util/data/collect/DataFilter.java
=> common/src/main/java/org/apache/rocketmq/common/attribute/DeletePolicy.java
(89%)
copy
common/src/main/java/org/apache/rocketmq/common/utils/{QueueTypeUtils.java =>
DeletePolicyUtils.java} (62%)
create mode 100644 docs/cn/Example_Compaction_Topic_cn.md
create mode 100644 docs/en/Example_Compaction_Topic.md
copy store/src/main/java/org/apache/rocketmq/store/{PutMessageLock.java =>
CompactionAppendMsgCallback.java} (82%)
create mode 100644
store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java
copy
common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java
=>
store/src/main/java/org/apache/rocketmq/store/kv/CommitLogDispatcherCompaction.java
(62%)
create mode 100644
store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/kv/CompactionPositionMgr.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/kv/CompactionService.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/kv/CompactionStore.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/kv/CompactionLogTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/kv/CompactionPositionMgrTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/kv/OffsetMapTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/logfile/DefaultMappedFileTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/queue/SparseConsumeQueueTest.java
