fix fury

apache · Nov 3, 2024 · ddb5766 · ddb5766
1 parent 04dd07f
commit ddb5766
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 2 deletions.
diff --git a/java/fury-core/src/main/java/org/apache/fury/Fury.java b/java/fury-core/src/main/java/org/apache/fury/Fury.java
@@ -197,7 +197,13 @@ public void register(Class<?> cls, int id, boolean createSerializer) {
   /** register class with given type tag which will be used for cross-language serialization. */
   public void register(Class<?> cls, String typeName) {
     Preconditions.checkArgument(language != Language.JAVA);
-    register(cls, "", typeName);
+    int idx = typeName.lastIndexOf('.');
+    String namespace = "";
+    if (idx > 0) {
+      namespace = typeName.substring(0, idx);
+      typeName = typeName.substring(idx);
+    }
+    register(cls, namespace, typeName);
   }
 
   public void register(Class<?> cls, String namespace, String typeName) {

diff --git a/java/fury-core/src/main/java/org/apache/fury/resolver/XtypeResolver.java b/java/fury-core/src/main/java/org/apache/fury/resolver/XtypeResolver.java
@@ -76,7 +76,7 @@ public void register(Class<?> type, int typeId) {
     if (serializer == null) {
       if (type.isEnum()) {
         classResolver.registerSerializer(
-            type, new EnumSerializer<>(classResolver.getFury(), type.asSubclass(Enum.class)));
+            type, new EnumSerializer(classResolver.getFury(), (Class<Enum>) type));
       } else {
         classResolver.registerSerializer(
             type, new StructSerializer<>(classResolver.getFury(), type));

diff --git a/java/fury-core/src/main/java/org/apache/fury/type/ScalaTypes.java b/java/fury-core/src/main/java/org/apache/fury/type/ScalaTypes.java
@@ -28,6 +28,7 @@
 /** Scala types utils using reflection without dependency on scala library. */
 @SuppressWarnings({"unchecked", "rawtypes"})
 public class ScalaTypes {
+
   private static final Class<?> SCALA_MAP_TYPE;
   private static final Class<?> SCALA_SEQ_TYPE;
   private static final Class<?> SCALA_SET_TYPE;