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 Description RuntimeSerializerFactory()
RuntimeSerializerFactory(TypeSerializer<T> serializer, Class<T> clazz)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
Class<T>
getDataType()
TypeSerializer<T>
getSerializer()
int
hashCode()
void
readParametersFromConfig(Configuration config, ClassLoader cl)
void
writeParametersToConfig(Configuration config)
-
-
-
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 interfaceTypeSerializerFactory<T>
-
readParametersFromConfig
public void readParametersFromConfig(Configuration config, ClassLoader cl) throws ClassNotFoundException
- Specified by:
readParametersFromConfig
in interfaceTypeSerializerFactory<T>
- Throws:
ClassNotFoundException
-
getSerializer
public TypeSerializer<T> getSerializer()
- Specified by:
getSerializer
in interfaceTypeSerializerFactory<T>
-
getDataType
public Class<T> getDataType()
- Specified by:
getDataType
in interfaceTypeSerializerFactory<T>
-
-