public interface Message
Modifier and Type | Method and Description |
---|---|
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() |
Address |
source() |
Address |
target() |
void |
writeTo(MessageFactory context,
org.apache.flink.core.memory.DataOutputView target) |
@Nullable Address source()
Address target()
java.lang.Object payload(MessageFactory context, java.lang.ClassLoader targetClassLoader)
java.util.OptionalLong isBarrierMessage()
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
.
Message copy(MessageFactory context)
void writeTo(MessageFactory context, org.apache.flink.core.memory.DataOutputView target) throws java.io.IOException
java.io.IOException
default void postApply()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.