(tsfile) branch dev/1.1 updated: Make Binary implement Accountable

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch dev/1.1
in repository https://gitbox.apache.org/repos/asf/tsfile.git


The following commit(s) were added to refs/heads/dev/1.1 by this push:
     new bf06a687 Make Binary implement Accountable
bf06a687 is described below

commit bf06a687294f53ad6a776d58e9cb05587fa7aa11
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Tue Oct 22 11:55:35 2024 +0800

    Make Binary implement Accountable
    
    (cherry picked from commit 3865e195f4385ddb5c55343583ccb6a9f10bac63)
---
 java/common/src/main/java/org/apache/tsfile/utils/Binary.java | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/java/common/src/main/java/org/apache/tsfile/utils/Binary.java 
b/java/common/src/main/java/org/apache/tsfile/utils/Binary.java
index d1dc347b..86a87ae6 100644
--- a/java/common/src/main/java/org/apache/tsfile/utils/Binary.java
+++ b/java/common/src/main/java/org/apache/tsfile/utils/Binary.java
@@ -23,12 +23,16 @@ import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
 
+import static org.apache.tsfile.utils.RamUsageEstimator.shallowSizeOfInstance;
+import static org.apache.tsfile.utils.RamUsageEstimator.sizeOf;
+
 /**
  * Override compareTo() and equals() function to Binary class. This class is 
used to accept Java
  * String type
  */
-public class Binary implements Comparable<Binary>, Serializable {
+public class Binary implements Comparable<Binary>, Serializable, Accountable {
 
+  private static final long INSTANCE_SIZE = 
shallowSizeOfInstance(Binary.class);
   private static final long serialVersionUID = 6394197743397020735L;
   public static final Binary EMPTY_VALUE = new Binary(new byte[0]);
 
@@ -119,4 +123,9 @@ public class Binary implements Comparable<Binary>, 
Serializable {
   public void setValues(byte[] values) {
     this.values = values;
   }
+
+  @Override
+  public long ramBytesUsed() {
+    return INSTANCE_SIZE + sizeOf(values);
+  }
 }