feat(java): zstd meta compressor

java/fury-core/pom.xml

@@ -58,6 +58,10 @@
       <artifactId>slf4j-api</artifactId>
       <optional>true</optional>
     </dependency>
+    <dependency>
+      <groupId>com.github.luben</groupId>
+      <artifactId>zstd-jni</artifactId>
+    </dependency>
     <dependency>
       <groupId>com.google.guava</groupId>
       <artifactId>guava</artifactId>

java/fury-core/src/main/java/org/apache/fury/meta/ZstdMetaCompressor.java

@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.fury.meta;
+
+import com.github.luben.zstd.Zstd;
+import com.github.luben.zstd.ZstdException;
+
+public class ZstdMetaCompressor implements MetaCompressor {
+
+  @Override
+  public byte[] compress(byte[] data, int offset, int size) {
+
+    long maxCompressedSize = Zstd.compressBound(size);
+    if (maxCompressedSize > Integer.MAX_VALUE) {
+      throw new ZstdException(Zstd.errGeneric(), "Max output size is greater than MAX_INT");
+    }
+
+    byte[] compressedData = new byte[(int) maxCompressedSize];
+    Zstd.compressByteArray(
+        compressedData,
+        0,
+        (int) maxCompressedSize,
+        data,
+        offset,
+        size,
+        Zstd.defaultCompressionLevel());
+
+    return compressedData;
+  }
+
+  @Override
+  public byte[] decompress(byte[] data, int offset, int size) {
+    int decompressedSize = (int) Zstd.getFrameContentSize(data, offset, size, false);
+    byte[] decompressedBytes = new byte[decompressedSize];
+    Zstd.decompressByteArray(decompressedBytes, 0, decompressedSize, data, offset, size);
+    return decompressedBytes;
+  }
+
+  @Override
+  public int hashCode() {
+    return ZstdMetaCompressor.class.hashCode();
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    return o != null && getClass() == o.getClass();
+  }
+}

java/fury-core/src/test/java/org/apache/fury/meta/ClassDefEncoderTest.java

@@ -50,6 +50,21 @@ public void testBasicClassDef() throws Exception {
     Assert.assertEquals(classDef.getFieldsInfo(), fieldsInfo);
   }
 
+  @Test
+  public void testBasicClassDef_zstdMetaCompressor() throws Exception {
+    Fury fury =
+        Fury.builder().withMetaShare(true).withMetaCompressor(new ZstdMetaCompressor()).build();
+    Class<ClassDefTest.TestFieldsOrderClass1> type = ClassDefTest.TestFieldsOrderClass1.class;
+    List<ClassDef.FieldInfo> fieldsInfo = buildFieldsInfo(fury.getClassResolver(), type);
+    MemoryBuffer buffer =
+        ClassDefEncoder.encodeClassDef(
+            fury.getClassResolver(), type, getClassFields(type, fieldsInfo), true);
+    ClassDef classDef = ClassDef.readClassDef(fury.getClassResolver(), buffer);
+    Assert.assertEquals(classDef.getClassName(), type.getName());
+    Assert.assertEquals(classDef.getFieldsInfo().size(), type.getDeclaredFields().length);
+    Assert.assertEquals(classDef.getFieldsInfo(), fieldsInfo);
+  }
+
   @Test
   public void testBigMetaEncoding() {
     for (Class<?> type :

java/pom.xml

@@ -81,6 +81,7 @@
     <maven.compiler.target>1.8</maven.compiler.target>
     <guava.version>32.1.2-jre</guava.version>
     <janino.version>3.1.10</janino.version>
+    <zstd.version>1.5.6-9</zstd.version>
     <commons_codec.version>1.13</commons_codec.version>
     <fury.java.rootdir>${basedir}</fury.java.rootdir>
     <maven-spotless-plugin.version>2.41.1</maven-spotless-plugin.version>
@@ -105,6 +106,11 @@
         <artifactId>janino</artifactId>
         <version>${janino.version}</version>
       </dependency>
+      <dependency>
+        <groupId>com.github.luben</groupId>
+        <artifactId>zstd-jni</artifactId>
+        <version>${zstd.version}</version>
+      </dependency>
       <!-- Cxeb68d52e-5509 -->
       <dependency>
         <groupId>commons-codec</groupId>