org.apache.flink.runtime.util

Class SerializedValue<T>

java.lang.Object

org.apache.flink.runtime.util.SerializedValue<T>

Type Parameters:

T - The type of the value held.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

AccumulatorEvent

public class SerializedValue<T>
extends Object
implements Serializable

This class is used to transfer (via serialization) objects whose classes are not available in the system class loader. When those objects are deserialized without access to their special class loader, the deserialization fails with a ClassNotFoundException. To work around that issue, the SerializedValue serialized data immediately into a byte array. When send through RPC or another service that uses serialization, the only the byte array is transferred. The object is deserialized later (upon access) and requires the accessor to provide the corresponding class loader.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SerializedValue(T value)

Method Summary

Modifier and Type	Method and Description
T	deserializeValue(ClassLoader loader)
boolean	equals(Object obj)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SerializedValue

public SerializedValue(T value)
                throws IOException

Throws:

IOException

Method Detail

deserializeValue

public T deserializeValue(ClassLoader loader)
                   throws IOException,
                          ClassNotFoundException

Throws:

IOException

ClassNotFoundException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object