Uses of Interface
org.apache.flink.statefun.flink.core.message.Message

Packages that use Message

Package	Description
org.apache.flink.statefun.flink.core.functions
org.apache.flink.statefun.flink.core.message
org.apache.flink.statefun.flink.core.translation

Uses of Message in org.apache.flink.statefun.flink.core.functions

Methods in org.apache.flink.statefun.flink.core.functions with type parameters of type Message

Modifier and Type	Method and Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Message>> T	FunctionGroupDispatchFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Message> streamOperatorParameters)

Methods in org.apache.flink.statefun.flink.core.functions with parameters of type Message

Modifier and Type	Method and Description
void	ApplyingContext.apply(org.apache.flink.statefun.flink.core.functions.LiveFunction function, Message inMessage)

Method parameters in org.apache.flink.statefun.flink.core.functions with type arguments of type Message

Modifier and Type	Method and Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Message>> T	FunctionGroupDispatchFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Message> streamOperatorParameters)
void	FunctionGroupOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Message> record)

Uses of Message in org.apache.flink.statefun.flink.core.message

Methods in org.apache.flink.statefun.flink.core.message that return Message

Modifier and Type	Method and Description
Message	MessageTypeSerializer.copy(Message message)
Message	Message.copy(MessageFactory context)
Message	MessageTypeSerializer.copy(Message message, Message reuse)
Message	MessageTypeSerializer.createInstance()
Message	MessageTypeSerializer.deserialize(org.apache.flink.core.memory.DataInputView dataInputView)
Message	MessageTypeSerializer.deserialize(Message message, org.apache.flink.core.memory.DataInputView dataInputView)
Message	MessageFactory.from(Address from, Address to, java.lang.Object payload)
Message	MessageFactory.from(Address from, Address to, java.lang.Object payload, java.lang.String cancellationToken)
Message	MessageFactory.from(org.apache.flink.core.memory.DataInputView input)
Message	MessageFactory.from(long checkpointId)

Methods in org.apache.flink.statefun.flink.core.message that return types with arguments of type Message

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.TypeSerializer<Message>	MessageTypeInformation.createSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)
org.apache.flink.api.common.typeutils.TypeSerializer<Message>	MessageTypeSerializer.duplicate()
java.lang.Class<Message>	MessageTypeInformation.getTypeClass()
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<Message>	MessageTypeSerializer.Snapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<Message> typeSerializer)
org.apache.flink.api.common.typeutils.TypeSerializer<Message>	MessageTypeSerializer.Snapshot.restoreSerializer()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Message>	MessageTypeSerializer.snapshotConfiguration()

Methods in org.apache.flink.statefun.flink.core.message with parameters of type Message

Modifier and Type	Method and Description
Message	MessageTypeSerializer.copy(Message message)
Message	MessageTypeSerializer.copy(Message message, Message reuse)
Message	MessageTypeSerializer.deserialize(Message message, org.apache.flink.core.memory.DataInputView dataInputView)
java.lang.String	MessageKeySelector.getKey(Message value)
void	MessageTypeSerializer.serialize(Message message, org.apache.flink.core.memory.DataOutputView dataOutputView)

Method parameters in org.apache.flink.statefun.flink.core.message with type arguments of type Message

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<Message>	MessageTypeSerializer.Snapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<Message> typeSerializer)

Uses of Message in org.apache.flink.statefun.flink.core.translation

Constructor parameters in org.apache.flink.statefun.flink.core.translation with type arguments of type Message

Constructor and Description
EmbeddedTranslator(StatefulFunctionsConfig config, FeedbackKey<Message> feedbackKey)
FlinkUniverse(FeedbackKey<Message> feedbackKey, StatefulFunctionsConfig configuration, StatefulFunctionsUniverse universe)