org.apache.flink.statefun.sdk.io

Interface Router<InT>

Type Parameters:

InT - the type of messages being routed.

All Known Implementing Classes:

AutoRoutableProtobufRouter, CommandRouter

public interface Router<InT>

A Router routes messages from ingresses to individual StatefulFunctions.

Implementations should be stateless, as any state in routers are not persisted by the system.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	Router.Downstream<T> Interface for invoking downstream functions.

Method Summary

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

Method Detail

route

void route(InT message,
           Router.Downstream<InT> downstream)

Routes a given message to downstream StatefulFunctions. A single message may result in multiple functions being invoked.

Parameters:

message - the message to route.

downstream - used to invoke downstream functions.