public final class MessageFactory
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static MessageFactory |
forType(MessageFactoryType type) |
Message |
from(Address from,
Address to,
java.lang.Object payload) |
Message |
from(org.apache.flink.core.memory.DataInputView input) |
Message |
from(long checkpointId) |
public static MessageFactory forType(MessageFactoryType type)
public Message from(long checkpointId)
public Message from(org.apache.flink.core.memory.DataInputView input) throws java.io.IOException
java.io.IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.