From d54629c33f8011b2558ac36d2edf4fd70c6b167b Mon Sep 17 00:00:00 2001 From: ayanamist Date: Tue, 30 Mar 2021 20:10:51 +0800 Subject: [PATCH] Add abbreviation for fields of PopCheckPoint to save commit log size. --- .../org/apache/rocketmq/store/pop/PopCheckPoint.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java b/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java index f5b7ac6c..a4a3aac0 100644 --- a/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java +++ b/store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java @@ -16,19 +16,30 @@ */ package org.apache.rocketmq.store.pop; +import com.alibaba.fastjson.annotation.JSONField; import java.util.ArrayList; import java.util.List; public class PopCheckPoint { + @JSONField(name = "so") private long startOffset; + @JSONField(name = "pt") private long popTime; + @JSONField(name = "it") private long invisibleTime; + @JSONField(name = "bm") private int bitMap; + @JSONField(name = "n") private byte num; + @JSONField(name = "q") private byte queueId; + @JSONField(name = "t") private String topic; + @JSONField(name = "c") private String cid; + @JSONField(name = "ro") private long reviveOffset; + @JSONField(name = "d") private List queueOffsetDiff; public long getReviveOffset() { -- GitLab