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

Class MessageFactory

java.lang.Object

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

public final class MessageFactory
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static MessageFactory	forKey(MessageFactoryKey key)
Message	from(Address from, Address to, java.lang.Object payload)
Message	from(Address from, Address to, java.lang.Object payload, java.lang.String cancellationToken)
Message	from(org.apache.flink.core.memory.DataInputView input)
Message	from(long checkpointId)

Methods inherited from class java.lang.Object

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

Method Detail

forKey

public static MessageFactory forKey(MessageFactoryKey key)

from

public Message from(long checkpointId)

from

public Message from(org.apache.flink.core.memory.DataInputView input)
             throws java.io.IOException

Throws:

java.io.IOException

from

public Message from(Address from,
                    Address to,
                    java.lang.Object payload)

from

public Message from(Address from,
                    Address to,
                    java.lang.Object payload,
                    java.lang.String cancellationToken)