Uses of Interface
org.apache.flink.statefun.sdk.io.Router.Downstream

Packages that use Router.Downstream

Package	Description
org.apache.flink.statefun.e2e.smoke.driver
org.apache.flink.statefun.flink.io.common
org.apache.flink.statefun.sdk.io

Uses of Router.Downstream in org.apache.flink.statefun.e2e.smoke.driver

Methods in org.apache.flink.statefun.e2e.smoke.driver with parameters of type Router.Downstream

Modifier and Type	Method and Description
void	CommandRouter.route(TypedValue command, Router.Downstream<TypedValue> downstream)

Uses of Router.Downstream in org.apache.flink.statefun.flink.io.common

Methods in org.apache.flink.statefun.flink.io.common with parameters of type Router.Downstream

Modifier and Type	Method and Description
void	AutoRoutableProtobufRouter.route(com.google.protobuf.Message message, Router.Downstream<com.google.protobuf.Message> downstream) Note: while the input and type of this method is both Message, we actually do a conversion here.

Uses of Router.Downstream in org.apache.flink.statefun.sdk.io

Methods in org.apache.flink.statefun.sdk.io with parameters of type Router.Downstream

Modifier and Type	Method and Description
void	Router.route(InT message, Router.Downstream<InT> downstream) Routes a given message to downstream StatefulFunctions.