org.apache.flink.api.java.typeutils.runtime

Class RuntimeSerializerFactory<T>

java.lang.Object

org.apache.flink.api.java.typeutils.runtime.RuntimeSerializerFactory<T>

All Implemented Interfaces:

Serializable, TypeSerializerFactory<T>

@Internal
public final class RuntimeSerializerFactory<T>
extends Object
implements TypeSerializerFactory<T>, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RuntimeSerializerFactory()
RuntimeSerializerFactory(TypeSerializer<T> serializer, Class<T> clazz)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Class<T>	getDataType()
TypeSerializer<T>	getSerializer()
int	hashCode()
void	readParametersFromConfig(Configuration config, ClassLoader cl)
void	writeParametersToConfig(Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeSerializerFactory

public RuntimeSerializerFactory()

RuntimeSerializerFactory

public RuntimeSerializerFactory(TypeSerializer<T> serializer,
                                Class<T> clazz)

Method Detail

writeParametersToConfig

public void writeParametersToConfig(Configuration config)

Specified by:

writeParametersToConfig in interface TypeSerializerFactory<T>

readParametersFromConfig

public void readParametersFromConfig(Configuration config,
                                     ClassLoader cl)
                              throws ClassNotFoundException

Specified by:

readParametersFromConfig in interface TypeSerializerFactory<T>

Throws:

ClassNotFoundException

getSerializer

public TypeSerializer<T> getSerializer()

Specified by:

getSerializer in interface TypeSerializerFactory<T>

getDataType

public Class<T> getDataType()

Specified by:

getDataType in interface TypeSerializerFactory<T>

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object