Package org.apache.wayang.basic.operators

Class ObjectFileSerialization

java.lang.Object

org.apache.wayang.basic.operators.ObjectFileSerialization

public final class ObjectFileSerialization
extends Object

Utility methods that convert between Java objects and the on-disk representation used by ObjectFileSink.

Method Summary

Modifier and Type	Method	Description
static List<Object>	deserializeChunk(byte[] payload, ObjectFileSerializationMode mode, Class<?> elementType)	Deserialize a chunk of objects.
static byte[]	serializeChunk(Object[] chunk, int validLength, ObjectFileSerializationMode mode)	Serialize a chunk of objects using the provided ObjectFileSerializationMode.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

serializeChunk

public static byte[] serializeChunk(Object[] chunk,
 int validLength,
 ObjectFileSerializationMode mode)
                             throws IOException

Serialize a chunk of objects using the provided ObjectFileSerializationMode.

Parameters:

chunk - buffer that contains the objects to serialize

validLength - number of valid entries inside chunk

mode - the serialization mode

Returns:

serialized bytes

Throws:

IOException - if serialization fails

deserializeChunk

public static List<Object> deserializeChunk(byte[] payload,
 ObjectFileSerializationMode mode,
 Class<?> elementType)
                                     throws IOException,
ClassNotFoundException

Deserialize a chunk of objects.

Parameters:

payload - the serialized data

mode - the serialization mode

elementType - the expected element type

Returns:

list of deserialized objects (never null)

Throws:

IOException - if deserialization fails

ClassNotFoundException - if a class cannot be resolved in legacy mode