org.apache.flink.statefun.sdk.io

Interface Router.Downstream<T>

Type Parameters:

T - the type of messages being routed to downstream functions.

Enclosing interface:

Router<InT>

public static interface Router.Downstream<T>

Interface for invoking downstream functions.

Method Summary

Modifier and Type	Method and Description
void	forward(Address to, T message) Forwards the message as an input to a downstream function, addressed by a specified Address.
default void	forward(FunctionType functionType, java.lang.String id, T message) Forwards the message as an input to a downstream function, addressed by a specified FunctionType and the functions unique id within its type.
Metrics	metrics() Returns the metrics that are scoped to this ingress.

Method Detail

forward

void forward(Address to,
             T message)

Forwards the message as an input to a downstream function, addressed by a specified Address.

Parameters:

to - the target function's address.

message - the message being forwarded.

forward

default void forward(FunctionType functionType,
                     java.lang.String id,
                     T message)

Forwards the message as an input to a downstream function, addressed by a specified FunctionType and the functions unique id within its type.

Parameters:

functionType - the target function's type.

id - the target function's unique id.

message - the message being forwarded.

metrics

Metrics metrics()

Returns the metrics that are scoped to this ingress.

Every metric defined here will be associated to the ingress, that this router is attached to. For example, if this router is attached to an ingress with an IngressIdentifier("foo", "bar"), then every metric name M will appear as "routers.foo.bar.M".