org.apache.flink.connectors.hive

Class CachedSerializedValue<T>

java.lang.Object

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

org.apache.flink.connectors.hive.CachedSerializedValue<T>

All Implemented Interfaces:

Serializable

public class CachedSerializedValue<T>
extends org.apache.flink.util.SerializedValue<T>

An extension of SerializedValue which caches the deserialized data.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CachedSerializedValue(T value)

Method Summary

Modifier and Type	Method and Description
T	deserializeValue()
T	deserializeValue(ClassLoader loader)

Methods inherited from class org.apache.flink.util.SerializedValue

equals, fromBytes, getByteArray, hashCode, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CachedSerializedValue

public CachedSerializedValue(T value)
                      throws IOException

Throws:

IOException

Method Detail

deserializeValue

public T deserializeValue(ClassLoader loader)
                   throws IOException,
                          ClassNotFoundException

Overrides:

deserializeValue in class org.apache.flink.util.SerializedValue<T>

Throws:

IOException

ClassNotFoundException

deserializeValue

public T deserializeValue()
                   throws IOException,
                          ClassNotFoundException

Throws:

IOException

ClassNotFoundException