alluxio.job.util

Class SerializationUtils

java.lang.Object

alluxio.job.util.SerializationUtils

@ThreadSafe
public final class SerializationUtils
extends Object

Serialization related utility methods.

Method Summary

Modifier and Type	Method and Description
static Serializable	deserialize(byte[] bytes) Deserializes a byte array into an object.
static Serializable	deserialize(byte[] bytes, String errorMessage) Wrapper around #deserialize(Object) which throws a runtime exception with the given message on failure.
static <S,T extends Serializable> Map<S,ArrayList<T>>	makeValuesSerializable(Map<S,Collection<T>> map)
static byte[]	serialize(Object obj) Serializes an object into a byte array.
static byte[]	serialize(Object obj, String errorMessage) Wrapper around serialize(Object) which throws a runtime exception with the given message on failure.

Methods inherited from class java.lang.Object

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

Method Detail

serialize

public static byte[] serialize(Object obj)
                        throws IOException

Serializes an object into a byte array. When the object is null, returns null.

Parameters:

obj - the object to serialize

Returns:

the serialized bytes

Throws:

IOException - if the serialization fails

serialize

public static byte[] serialize(Object obj,
                               String errorMessage)

Wrapper around serialize(Object) which throws a runtime exception with the given message on failure.

Parameters:

obj - the object the serialize

errorMessage - the message to show if serialization fails

Returns:

the serialized bytes

deserialize

public static Serializable deserialize(byte[] bytes)
                                throws IOException,
                                       ClassNotFoundException

Deserializes a byte array into an object. When the bytes are null, returns null.

Parameters:

bytes - the byte array to deserialize

Returns:

the deserialized object

Throws:

IOException - if the deserialization fails

ClassNotFoundException - if no class found to deserialize into

deserialize

public static Serializable deserialize(byte[] bytes,
                                       String errorMessage)

Wrapper around #deserialize(Object) which throws a runtime exception with the given message on failure.

Parameters:

bytes - the byte array the deserialize

errorMessage - the message to show if deserialization fails

Returns:

the deserialized object

makeValuesSerializable

public static <S,T extends Serializable> Map<S,ArrayList<T>> makeValuesSerializable(Map<S,Collection<T>> map)

Type Parameters:

S - the key type for the Map

T - the type of the values in the collections which are the values for the Map

Parameters:

map - a map to make serializable

Returns:

a copy of the map with serializable values