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

Interface Message

All Superinterfaces:

RoutableMessage

public interface Message
extends RoutableMessage

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.String>	cancellationToken()
Message	copy(MessageFactory context)
java.util.OptionalLong	isBarrierMessage() isBarrierMessage - returns an empty optional for non barrier messages or wrapped checkpointId for barrier messages.
java.lang.Object	payload(MessageFactory context, java.lang.ClassLoader targetClassLoader)
default void	postApply()
void	writeTo(MessageFactory context, org.apache.flink.core.memory.DataOutputView target)

Methods inherited from interface org.apache.flink.statefun.flink.core.message.RoutableMessage

source, target

Method Detail

payload

java.lang.Object payload(MessageFactory context,
                         java.lang.ClassLoader targetClassLoader)

isBarrierMessage

java.util.OptionalLong isBarrierMessage()

isBarrierMessage - returns an empty optional for non barrier messages or wrapped checkpointId for barrier messages.

When this message represents a checkpoint barrier, this method returns an Optional of a checkpoint id that produced that barrier. For other types of messages (i.e. Payload) this method returns an empty Optional.

cancellationToken

java.util.Optional<java.lang.String> cancellationToken()

copy

Message copy(MessageFactory context)

writeTo

void writeTo(MessageFactory context,
             org.apache.flink.core.memory.DataOutputView target)
      throws java.io.IOException

Throws:

java.io.IOException

postApply

default void postApply()