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

Packages that use RoutableMessage

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

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

Subinterfaces of RoutableMessage in org.apache.flink.statefun.flink.core.message

Modifier and Type	Interface and Description
interface	Message

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

Modifier and Type	Method and Description
RoutableMessage	RoutableMessageBuilder.build()

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

Method parameters in org.apache.flink.statefun.flink.core.translation with type arguments of type RoutableMessage

Modifier and Type	Method and Description
<T extends StatefulFunctionProvider & java.io.Serializable> java.util.Map<EgressIdentifier<?>,org.apache.flink.streaming.api.datastream.DataStream<?>>	EmbeddedTranslator.translate(java.util.List<org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage>> ingresses, java.lang.Iterable<EgressIdentifier<?>> egressesIds, java.util.Map<FunctionType,T> functions)

Uses of RoutableMessage in org.apache.flink.statefun.flink.datastream

Method parameters in org.apache.flink.statefun.flink.datastream with type arguments of type RoutableMessage

Modifier and Type	Method and Description
StatefulFunctionDataStreamBuilder	StatefulFunctionDataStreamBuilder.withDataStreamAsIngress(org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage> ingress) Adds an ingress of incoming messages.