import org.apache.fory.*; import org.apache.fory.config.*; // Create Fory instance (should be reused) Fory fory = Fory.builder() .requireClassRegistration(true) .build(); // Register your classes fory.register(MyClass.class); // Serialize MyClass object = new MyClass(); byte[] bytes = fory.serialize(object); // Deserialize MyClass result = (MyClass) fory.deserialize(bytes);

import org.apache.fory.*; import org.apache.fory.config.*; // Create thread-safe Fory instance private static final ThreadSafeFory fory = Fory.builder().buildThreadSafeFory(); static { fory.register(MyClass.class); } // Use in multiple threads byte[] bytes = fory.serialize(object); Object result = fory.deserialize(bytes);

// Enable forward/backward compatibility Fory fory = Fory.builder() .withCompatibleMode(CompatibleMode.COMPATIBLE) .build(); // Serialization and deserialization can use different class versions // New fields will be ignored, missing fields will use default values

// Enable reference tracking for circular/shared references Fory fory = Fory.builder() .withRefTracking(true) .build(); // Serialize complex object graphs GraphNode node = new GraphNode(); node.next = node; // Circular reference byte[] bytes = fory.serialize(node);

// Use XLANG mode for cross-language compatibility Fory fory = Fory.builder() .withLanguage(Language.XLANG) .withRefTracking(true) .build(); // Register with cross-language type id/name fory.register(MyClass.class, 1); // fory.register(MyClass.class, "com.example.MyClass"); // Bytes can be deserialized by Python, Go, etc. byte[] bytes = fory.serialize(object);

Fory fory = Fory.builder() // Language mode: JAVA (fastest) or XLANG (cross-language) .withLanguage(Language.JAVA) // Reference tracking for circular/shared references .withRefTracking(true) // Schema evolution mode .withCompatibleMode(CompatibleMode.COMPATIBLE) // Compression options .withIntCompressed(true) .withLongCompressed(true) .withStringCompressed(false) // Security options .requireClassRegistration(true) .withMaxDepth(50) // Performance options .withCodeGen(true) .withAsyncCompilation(true) // Class loader .withClassLoader(classLoader) .build();

public class MyClass implements Serializable { private void writeObject(ObjectOutputStream out) throws IOException { // Custom serialization logic } private void readObject(ObjectInputStream in) throws IOException { // Custom deserialization logic } private Object writeReplace() { // Return replacement object } private Object readResolve() { // Return resolved object } }

Fory fory = Fory.builder() .withLanguage(Language.JAVA) .withRefCopy(true) .build(); MyClass original = new MyClass(); MyClass copy = fory.copy(original);

import org.apache.fory.format.encoder.*; import org.apache.fory.format.row.*; public class Bar { String f1; List<Long> f2; } public class Foo { int f1; List<Integer> f2; Map<String, Integer> f3; List<Bar> f4; } // Create row encoder RowEncoder<Foo> encoder = Encoders.bean(Foo.class); // Serialize to row format Foo foo = new Foo(); foo.f1 = 10; foo.f2 = IntStream.range(0, 1000).boxed().collect(Collectors.toList()); BinaryRow binaryRow = encoder.toRow(foo); // Zero-copy random access to fields BinaryArray f2Array = binaryRow.getArray(1); // Access f2 without deserializing entire object BinaryArray f4Array = binaryRow.getArray(3); // Access f4 // Zero-copy access nested fields BinaryRow barStruct = f4Array.getStruct(10); // Get 11th element long value = barStruct.getArray(1).getInt64(5); // Access nested field // Partial deserialization RowEncoder<Bar> barEncoder = Encoders.bean(Bar.class); Bar partialBar = barEncoder.fromRow(barStruct); // Deserialize only one Bar object // Full deserialization Foo deserializedFoo = encoder.fromRow(binaryRow);

import org.apache.fory.simd.*; Fory fory = Fory.builder() .withIntArrayCompressed(true) .withLongArrayCompressed(true) .build(); // Register compressed array serializers CompressedArraySerializers.registerSerializers(fory); // Arrays with small values are automatically compressed int[] data = new int[1000000]; byte[] bytes = fory.serialize(data);