55import com .esotericsoftware .kryo .kryo5 .Serializer ;
66import com .esotericsoftware .kryo .kryo5 .io .Input ;
77import com .esotericsoftware .kryo .kryo5 .io .Output ;
8+ import com .esotericsoftware .kryo .kryo5 .serializers .JavaSerializer ;
89import com .esotericsoftware .kryo .kryo5 .serializers .MapSerializer ;
910import org .dizitart .no2 .collection .Document ;
1011import org .dizitart .no2 .collection .NitriteId ;
@@ -206,19 +207,6 @@ public BoundingBox read(Kryo kryo, Input input, Class<? extends BoundingBox> typ
206207 }
207208 }
208209
209- private static class DBValueSerializer extends Serializer <DBValue > {
210- @ Override
211- public void write (Kryo kryo , Output output , DBValue object ) {
212- kryo .writeObject (output , object .getValue ());
213- }
214-
215- @ Override
216- public DBValue read (Kryo kryo , Input input , Class <? extends DBValue > type ) {
217- Object value = kryo .readObject (input , Object .class );
218- return new DBValue ((Comparable <?>) value );
219- }
220- }
221-
222210 private static class SpatialKeySerializer extends Serializer <SpatialKey > {
223211 @ Override
224212 public void write (Kryo kryo , Output output , SpatialKey spatialKey ) {
@@ -243,7 +231,7 @@ public static void registerAll(KryoObjectFormatter kryoObjectFormatter) {
243231 kryoObjectFormatter .registerSerializer (UserCredential .class , new UserCredentialSerializer ());
244232 kryoObjectFormatter .registerSerializer (Attributes .class , new AttributesSerializer ());
245233 kryoObjectFormatter .registerSerializer (Fields .class , new FieldsSerializer ());
246- kryoObjectFormatter .registerSerializer (DBValue .class , new DBValueSerializer ());
234+ kryoObjectFormatter .registerSerializer (DBValue .class , new JavaSerializer ());
247235 kryoObjectFormatter .registerSerializer (BoundingBox .class , new BoundingBoxSerializer ());
248236 kryoObjectFormatter .registerSerializer (SpatialKey .class , new SpatialKeySerializer ());
249237 }
0 commit comments