org.apache.flink.statefun.flink.core.message

Class MessagePayloadSerializerKryo

java.lang.Object

org.apache.flink.statefun.flink.core.message.MessagePayloadSerializerKryo

All Implemented Interfaces:

MessagePayloadSerializer

public final class MessagePayloadSerializerKryo
extends java.lang.Object
implements MessagePayloadSerializer

Constructor Summary

Constructors

Constructor and Description
MessagePayloadSerializerKryo()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	copy(java.lang.ClassLoader targetClassLoader, java.lang.Object what)
java.lang.Object	deserialize(java.lang.ClassLoader targetClassLoader, Payload payload)
Payload	serialize(java.lang.Object payloadObject)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagePayloadSerializerKryo

public MessagePayloadSerializerKryo()

Method Detail

serialize

public Payload serialize(@Nonnull
                         java.lang.Object payloadObject)

Specified by:

serialize in interface MessagePayloadSerializer

deserialize

public java.lang.Object deserialize(@Nonnull
                                    java.lang.ClassLoader targetClassLoader,
                                    @Nonnull
                                    Payload payload)

Specified by:

deserialize in interface MessagePayloadSerializer

copy

public java.lang.Object copy(@Nonnull
                             java.lang.ClassLoader targetClassLoader,
                             @Nonnull
                             java.lang.Object what)

Specified by:

copy in interface MessagePayloadSerializer