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

Class KryoRegistration

java.lang.Object

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

All Implemented Interfaces:

Serializable

@Internal
public class KryoRegistration
extends Object
implements Serializable

A KryoRegistration resembles a registered class and its serializer in Kryo.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KryoRegistration.SerializerDefinitionType IMPORTANT: the order of the enumerations must not change, since their ordinals are used for serialization.

Constructor Summary

Constructors

Constructor and Description
KryoRegistration(Class<?> registeredClass)
KryoRegistration(Class<?> registeredClass, Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)
KryoRegistration(Class<?> registeredClass, ExecutionConfig.SerializableSerializer<? extends com.esotericsoftware.kryo.Serializer<?>> serializableSerializerInstance)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Class<?>	getRegisteredClass()
ExecutionConfig.SerializableSerializer<? extends com.esotericsoftware.kryo.Serializer<?>>	getSerializableSerializerInstance()
com.esotericsoftware.kryo.Serializer<?>	getSerializer(com.esotericsoftware.kryo.Kryo kryo)
Class<? extends com.esotericsoftware.kryo.Serializer<?>>	getSerializerClass()
KryoRegistration.SerializerDefinitionType	getSerializerDefinitionType()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

KryoRegistration

public KryoRegistration(Class<?> registeredClass)

KryoRegistration

public KryoRegistration(Class<?> registeredClass,
                        Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)

KryoRegistration

public KryoRegistration(Class<?> registeredClass,
                        ExecutionConfig.SerializableSerializer<? extends com.esotericsoftware.kryo.Serializer<?>> serializableSerializerInstance)

Method Detail

getRegisteredClass

public Class<?> getRegisteredClass()

getSerializerDefinitionType

public KryoRegistration.SerializerDefinitionType getSerializerDefinitionType()

getSerializerClass

@Nullable
public Class<? extends com.esotericsoftware.kryo.Serializer<?>> getSerializerClass()

getSerializableSerializerInstance

@Nullable
public ExecutionConfig.SerializableSerializer<? extends com.esotericsoftware.kryo.Serializer<?>> getSerializableSerializerInstance()

getSerializer

public com.esotericsoftware.kryo.Serializer<?> getSerializer(com.esotericsoftware.kryo.Kryo kryo)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object